spring boot項目集成thrift事件交互

一、前言

上一篇文章對thrift進行說明，同時搭建了簡單的Java項目對thrift服務(wù)端，客戶端的項目搭建。但是如何集成到spring boot項目中？這將是本篇文章的主要課題，不多說了。直接上代碼

二、項目構(gòu)建

  • 2.1 pom文件
<dependency>
    <groupId>org.apache.thrift</groupId>
    <artifactId>libthrift</artifactId>
    <version>0.12.0</version>
</dependency>
<dependency>
   <groupId>org.projectlombok</groupId>
   <artifactId>lombok</artifactId>
   <version>1.18.8</version>
   <optional>true</optional>
</dependency>
  • 2.2 引入thirft生成的java文件
#由于生成的文件較大，不展示進行簡單說明
ConnectionInfo ：根據(jù)thrift語言自定義的對象
HelloService：此文件為主要文件，包含我們需要實現(xiàn)的接口Iface
  • 2.3 搭建Thrift服務(wù)
package cn.bintools.daios.example.thrift.server;

import cn.bintools.daios.example.thrift.HelloService;
import cn.bintools.daios.example.thrift.impl.HelloServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.apache.thrift.TProcessor;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TSimpleServer;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TServerTransport;
import org.apache.thrift.transport.TTransportException;
import org.apache.thrift.transport.TTransportFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * 初始化thrift服務(wù)
 *
 * @author <a href="jian.huang@bintools.cn">yunzhe</a>
 * @version 1.0.0 2019-07-02-下午7:10
 */
@Component
@Slf4j
public class ThriftServer {
    @Value("${thrift.port}")
    private int port;

    private TBinaryProtocol.Factory protocolFactory;

    private TTransportFactory transportFactory;



    public void init(){
        protocolFactory = new TBinaryProtocol.Factory();
        transportFactory = new TTransportFactory();
    }

    public void start(){
        // HelloService.Processor<HelloRpcController> processor = new HelloService.Processor<HelloRpcController>(new HelloRpcController());
        TProcessor processor = new HelloService.Processor<HelloService.Iface>(new HelloServiceImpl());
        init();
        try {
            TServerTransport transport = new TServerSocket(port);
            //TThreadPoolServer.Args tArgs = new TThreadPoolServer.Args(transport);
            TServer.Args tArgs = new TServer.Args(transport);
            tArgs.processor(processor);
            tArgs.protocolFactory(protocolFactory);
            tArgs.transportFactory(transportFactory);
            /*tArgs.minWorkerThreads(minThreads);
            tArgs.maxWorkerThreads(macThreads);*/
            //多線程 在關(guān)閉時多次請求報null異常
            //TServer server = new TThreadPoolServer(tArgs);
            TServer server = new TSimpleServer(tArgs);
            log.info("thrift server start success, port={}",port);
            server.serve();
        } catch (TTransportException e) {
            log.error("thrift server start fail",e);
        }
    }
}
  • 2.4 實現(xiàn)Thrift的Iface接口
package cn.bintools.daios.example.thrift.impl;
import cn.bintools.daios.example.thrift.ConnectionInfo;
import cn.bintools.daios.example.thrift.HelloService;
import org.apache.thrift.TException;

/**
 * 服務(wù)端實現(xiàn)
 *
 * @author <a href="jian.huang@bintools.cn">yunzhe</a>
 * @version 1.0.0 2019-07-02-下午7:14
 */
public class HelloServiceImpl implements HelloService.Iface {
    @Override
    public int add(int num1, int num2) throws TException {
        return num1+num2;
    }
    @Override
    public ConnectionInfo getConnInfoById(int cpId) throws TException {
        ConnectionInfo connectionInfo = new ConnectionInfo();
        connectionInfo.setConnId(12);
        connectionInfo.setConnectionName("ThrfaceiftConnName");
        connectionInfo.setUrl("192.168.1.162");
        connectionInfo.setPort(3306);
        connectionInfo.setUserName("mysql_conn");
        connectionInfo.setPassword("abc*&ABC123");
        return connectionInfo;
    }
}
  • 2.5 啟動類
    項目啟動時，需要將thrift服務(wù)也啟動。暴露thrift的端口。具體修改如下
package cn.bintools.daios.example.thrift;

import cn.bintools.daios.example.thrift.server.ThriftServer;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ApplicationContext;
@SpringBootApplication
public class DemoApplication {
    private static ThriftServer thriftServer;
    public static void main(String[] args) {
        ApplicationContext context = SpringApplication.run(DemoApplication.class, args);
        try {
            thriftServer = context.getBean(ThriftServer.class);
            thriftServer.start();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
  • 2.6 客戶端
package cn.bintools.daios.example.thrift.client;

import cn.bintools.daios.example.thrift.HelloService;
import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;
/**
 * 客戶端
 *
 * @author <a href="jian.huang@bintools.cn">yunzhe</a>
 * @version 1.0.0 2019-07-02-下午7:15
 */
public class HelloServiceClient {
    public static void main(String[] args) {
        try {
            TTransport tTransport = new TSocket("127.0.0.1", 9899);
            tTransport.open();
            TProtocol protocol = new TBinaryProtocol(tTransport);
            HelloService.Client client = new HelloService.Client(protocol);
            System.out.println(client.add(200,200));
            System.out.println("連接名稱"+client.getConnInfoById(12));
            tTransport.close();
        } catch (TTransportException e) {
            e.printStackTrace();
        }catch (TException e){
            e.fillInStackTrace();
        }
    }
}

三、結(jié)果展示

  • 3.1 服務(wù)啟動


    thirftServerResult.jpg

    從日志中可以明確看到thrift服務(wù)已經(jīng)啟動并開啟的端口是9899

  • 3.2 客戶端訪問結(jié)果
    clientResult.jpg

    從客戶端結(jié)果日志中可知：分別返回類impl類中的結(jié)果。同時是我們期望的結(jié)果信息。
    碼云地址：https://gitee.com/huangjian163/springboot_thrift.git

四、jar項目轉(zhuǎn)war項目

通過以上處理，我們已經(jīng)將thrift集成到springboot項目中，并得到我們預(yù)期的結(jié)果。但是以上是spring boot的jar項目，如果改成war包是否能得到我們想要的結(jié)果？如何將spring boot 的jar轉(zhuǎn)war可參考：http://www.itdecent.cn/p/0759610fbcdd

  • 4.1 項目修改成war后啟動結(jié)果


    thriftwar.jpg

    從日志中并未發(fā)現(xiàn)之前日志中輸出的thrift的端口，同時可以打開客戶端訪問。無法獲取到期望的信息。故將項目轉(zhuǎn)成 war后無法啟動thrift服務(wù)

  • 4.2 解決方案
    以上造成的原因是:jar啟動時會新啟動一個線程開啟thrift的服務(wù)，但是war包反正tomcat中不會做這一步操作，需要我們手動完成。
    • 4.2.1 創(chuàng)建thrift監(jiān)聽器
package cn.bintools.daios.example.thrift.listener;

import cn.bintools.daios.example.thrift.server.ThriftServer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationContext;
import org.springframework.web.context.support.WebApplicationContextUtils;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
/**
 * thrift服務(wù)啟動監(jiān)聽器
 *
 * @author <a href="jian.huang@bintools.cn">yunzhe</a>
 * @version 1.0.0 2019-06-20-下午4:36
 */
@Slf4j
public class ThriftServerStartListener implements ServletContextListener {
    private static ThriftServer thriftServer;
    @Override
    public void contextInitialized(ServletContextEvent event) {
        try {
            ApplicationContext context = WebApplicationContextUtils.getWebApplicationContext(event.getServletContext());
            thriftServer = context.getBean(ThriftServer.class);
            thriftServer.start();
        }catch (Exception e){
            log.error("開始thrift異常");
            e.printStackTrace();
        }
    }
    @Override
    public void contextDestroyed(ServletContextEvent servletContextEvent) {
    }
}
  • 4.2.2 通過config注冊監(jiān)聽器
package cn.bintools.daios.example.thrift.config;

import cn.bintools.daios.example.thrift.listener.ThriftServerStartListener;
import org.springframework.boot.web.servlet.ServletListenerRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * config 注冊Thrift監(jiān)聽器
 *
 * @author <a href="jian.huang@bintools.cn">yunzhe</a>
 * @version 1.0.0 2019-07-02-下午8:11
 */
@Configuration
public class ThrfitConfig {

    @SuppressWarnings({"rawtypes", "unchecked"})
    @Bean
    public ServletListenerRegistrationBean listenerRegist() {
        ServletListenerRegistrationBean srb = new ServletListenerRegistrationBean();
        srb.setListener(new ThriftServerStartListener());
        return srb;
    }
}
  • 4.2.3 修改thrift服務(wù)開啟方法
    通過新創(chuàng)建線程的方式處理，原因：thrift服務(wù)啟動會一直監(jiān)聽相應(yīng)的端口，如果不使用新線程監(jiān)聽則導(dǎo)致整個系統(tǒng)無法往下執(zhí)行。可能項目都無法啟動
  public void start(){
        new Thread(){
            @Override
            public void run(){
                TProcessor processor = new HelloService.Processor<HelloService.Iface>(new HelloServiceImpl());
                init();
                try{
                    TServerSocket serverSocket = new TServerSocket(port);
                    TThreadPoolServer.Args args = new TThreadPoolServer.Args(serverSocket);
                    args.protocolFactory(protocolFactory);
                    args.processor(processor);
                    args.transportFactory(transportFactory);
                    TServer server = new TThreadPoolServer(args);
                    log.info("thrift server start success, port={}",port);
                    server.serve();
                }catch (TTransportException e){
                    log.error("thrift server start fail",e);
                }
            }
        }.start();
    }
  • 4.2.4 修改啟動類
    由于thrift的線程通過監(jiān)聽器進行啟動，故需要將啟動類還原成默認的生成的類。
package cn.bintools.daios.example.thrift;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
@SpringBootApplication
public class DemoApplication extends SpringBootServletInitializer {
    public static void main(String[] args) { 
        SpringApplication.run(DemoApplication.class, args);
    }
}

通過以上修改，thrift服務(wù)將進行正常啟動，正常監(jiān)聽相應(yīng)的端口。具體結(jié)果信息：

thriftwarResult.jpg

碼云地址 ：https://gitee.com/huangjian163/springbootwar_thrift.git

五、總結(jié)

通過以上處理，我們可以將thrift集成到spring boot的jar/war項目并可以進行相應(yīng)的監(jiān)聽。以上的事例都是客戶端請求，服務(wù)端返回具體的值，如何在監(jiān)聽到thrift操作時進行業(yè)務(wù)處理呢？請查看下一篇文章--->地址：http://www.itdecent.cn/p/44a373192912

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容