1.服务端设置

通过采用spring配置以及反射的方式来实现.对于一个服务提供者来说，需要提供端口，接口以及接口实现类，因此在接口中spring配置文件中配置如下

接下来定义ThriftServerProxy类,定义bean中需要用到的3个属性,接下来通过反射来实现服务的启动。

public class RpcServerProxy {    // 端口    private int port;    // 服务接口    private String serviceInterface;    //服务实现类    private Object serviceImplObject;    /**     * 启动RPC服务     */    public void start() {        ExecutorService cachedThreadPool = Executors.newCachedThreadPool();        cachedThreadPool.execute(() -> {            try {                TNonblockingServerTransport serverTransport = new TNonblockingServerSocket(getPort());                Class processor = Class.forName(getServiceInterface() + "$Processor");                Class face = Class.forName(getServiceInterface() + "$Iface");                Constructor con = processor.getConstructor(face);                TProcessor tProcessor = (TProcessor) con.newInstance(serviceImplObject);                TBinaryProtocol.Factory factory = new TBinaryProtocol.Factory(true, true);                TThreadedSelectorServer.Args args = new TThreadedSelectorServer.Args(serverTransport);                args.protocolFactory(factory);                args.processor(tProcessor);                TServer server = new TThreadedSelectorServer(args);                // 启动服务                server.serve();            } catch (ClassNotFoundException | NoSuchMethodException | InstantiationException | IllegalAccessException                    | InvocationTargetException | TTransportException e) {                e.printStackTrace();            }        });    }    public Object getServiceImplObject() {        return serviceImplObject;    }    public void setServiceImplObject(Object serviceImplObject) {        this.serviceImplObject = serviceImplObject;    }    public int getPort() {        return port;    }    public void setPort(int port) {        this.port = port;    }    public String getServiceInterface() {        return serviceInterface;    }    public void setServiceInterface(String serviceInterface) {        this.serviceInterface = serviceInterface;    }}

配置监听启动服务

** * 服务启动监听器 */public class RpcServerStartListener implements ServletContextListener {    @Override    public void contextInitialized(ServletContextEvent event) {        try {            ApplicationContext context = WebApplicationContextUtils.getWebApplicationContext(event.getServletContext());            // 获取服务代理列表            List
    
      proxyList = ((List
     
      ) context.getBean("serverProxyList"));            if (!CollectionUtils.isEmpty(proxyList)) {                // 启动代理服务                proxyList.forEach(proxy -> proxy.start());            }        } catch (Exception e) {            e.printStackTrace();        }    }    @Override    public void contextDestroyed(ServletContextEvent servletContextEvent) {    }}
     
    

最后在web.xml中添加listener即可

2.客户端配置

对于客户端，从连接池里面获取一个可用的服务端连接，通过反射的方式获取客户端,在spring-client.xml中配置如下：

客户端的代理对象获取client代码：

public class ThriftClientProxy {    private ConnectionManager connectionManager;    public ConnectionManager getConnectionManager() {        return connectionManager;    }    public void setConnectionManager(ConnectionManager connectionManager) {        this.connectionManager = connectionManager;    }    public Object getClient(Class clazz) {        Object result = null;        try {            TTransport transport = connectionManager.getSocket();            TProtocol protocol = new TBinaryProtocol(transport);            Class client = Class.forName(clazz.getName() + "$Client");            Constructor con = client.getConstructor(TProtocol.class);            result = con.newInstance(protocol);            //transport.open();        } catch (Exception e) {            e.printStackTrace();        }        return result;    }}

使用：

ResourceMgtRpc.Iface client = (ResourceMgtRpc.Iface) thriftClientProxy.getClient(ResourceMgtRpc.class);// 封装请求参数QuerySyncStatusRequest requestPo = new QuerySyncStatusRequest();requestPo.setMasterSourceId(master.getResourceId());QuerySyncStatusResponse responsePo = client.querySynStatus(requestPo);

当前的不足: