import com.facebook.swift.service.ThriftServiceProcessor; //导入依赖的package包/类
@Bean
Servlet thrift(ThriftCodecManager thriftCodecManager, TProtocolFactory protocolFactory, TCalculatorService calculatorService) {
    ThriftServiceProcessor processor = new ThriftServiceProcessor(thriftCodecManager, Arrays.<ThriftEventHandler>asList(), calculatorService);

    return new TServlet(
            NiftyProcessorAdapters.processorToTProcessor(processor),
            protocolFactory,
            protocolFactory
    );
}
 

import com.facebook.swift.service.ThriftServiceProcessor; //导入依赖的package包/类
public TClientProxyProtocolServer(ClientProxyCommons commons, ClientProxyService proxyService) {
  this.proxyService = proxyService;
  ThriftCodecManager codecManager = new ThriftCodecManager();
  ThriftEventHandler eventHandler = new ThriftEventHandler();
  ThriftServiceProcessor processor = new ThriftServiceProcessor(codecManager, Arrays.asList(
      eventHandler), this);
  server = new ThriftServer(processor, getServerConfig(commons.conf)).start();
}
 

import com.facebook.swift.service.ThriftServiceProcessor; //导入依赖的package包/类
@PostConstruct
public void init() {
	ThriftCatalog catalog = new ThriftCatalog();
	catalog.addDefaultCoercions(MandrelCoercions.class);
	ThriftCodecManager codecManager = new ThriftCodecManager(new CompilerThriftCodecFactory(ThriftCodecManager.class.getClassLoader()), catalog,
			ImmutableSet.of());

	NiftyProcessor processor = new ThriftServiceProcessor(codecManager,
	// Arrays.asList(new ThriftServiceStatsHandler())
			ImmutableList.of(), resources);

	properties.setPort(transportProperties.getPort());
	properties.setBindAddress(transportProperties.getBindAddress());
	properties.setWorkerThreads(10);
	properties.setTaskExpirationTimeout(Duration.valueOf("10s"));

	server = new ThriftServer(processor, properties, new NiftyTimer("thrift"), ThriftServer.DEFAULT_FRAME_CODEC_FACTORIES,
			ThriftServer.DEFAULT_PROTOCOL_FACTORIES, ThriftServer.DEFAULT_WORKER_EXECUTORS, ThriftServer.DEFAULT_SECURITY_FACTORY,
			transportProperties.isLocal());
	server.start();

	services.add(new Service() {
		@Override
		public String getServiceName() {
			return ServiceIds.node();
		}
	});
	services.forEach(service -> {
		log.debug("Registering service {}", service.getServiceName());
		ServiceInstance instance = ServiceInstance.builder().host(transportProperties.getBindAddress()).port(transportProperties.getPort())
				.name(service.getServiceName()).build();
		discoveryClient.register(instance);
	});

	Event event = Event.forNode();
	event.getNode().setNodeId(discoveryClient.getInstanceId()).setType(NodeEventType.NODE_STARTED);
	send(event);
}
 

import com.facebook.swift.service.ThriftServiceProcessor; //导入依赖的package包/类
public static void startServer() {
    // Create the handler
    //ThriftTestService.Iface serviceInterface = 
   //	MyService.Iface serviceInterface = new MyServiceHandler();

    // Create the processor
    //TProcessor processor = new MyService.Processor<>(serviceInterface);

    // Create the processor
    //TProcessor processor = new ThriftTestService.Processor<>(new InMemoryScribe());
	
	InMemoryScribe inMemoryScribe = new InMemoryScribeImpl();
	TProtocolFactory protocolFactory  = new TBinaryProtocol.Factory();
	ThriftCodecManager thriftCodecManager = new ThriftCodecManager();
	 List list  = new ArrayList<>();
	 list.add(inMemoryScribe);
	 
    ThriftServiceProcessor processor = new ThriftServiceProcessor(thriftCodecManager, Arrays.<ThriftEventHandler>asList(), inMemoryScribe);

    // Build the server definition
    ThriftServerDef serverDef = new ThriftServerDefBuilder().withProcessor(processor)
                                                            .build();

    // Create the server transport
    final NettyServerTransport server = new NettyServerTransport(serverDef	);

    // Create netty boss and executor thread pools
    ExecutorService bossExecutor = Executors.newCachedThreadPool();
    ExecutorService workerExecutor = Executors.newCachedThreadPool();

    // Start the server
    //server.start(bossExecutor, workerExecutor);
    server.start();
    // Arrange to stop the server at shutdown
    Runtime.getRuntime().addShutdownHook(new Thread() {
        @Override
        public void run() {
            try {
                server.stop();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    });
}
 

import com.facebook.swift.service.ThriftServiceProcessor; //导入依赖的package包/类
public static void main(String[] args) {
	ThriftServiceProcessor processor = new ThriftServiceProcessor(
               new ThriftCodecManager(),
               ImmutableList.<ThriftEventHandler>of(),
               new ThirdPartyCollectionServiceImpl()
       );

	
	
	// Build the server definition
    ThriftServerDef serverDef = new ThriftServerDefBuilder()
    		.listen(8899)
    		.withProcessor(processor)
            .build();

    // Create the server transport
    final NettyServerTransport server = new NettyServerTransport(serverDef	);

    // Create netty boss and executor thread pools
    ExecutorService bossExecutor = Executors.newCachedThreadPool();
    ExecutorService workerExecutor = Executors.newCachedThreadPool();

    // Start the server
    //server.start(bossExecutor, workerExecutor);
    server.start();
    // Arrange to stop the server at shutdown
    Runtime.getRuntime().addShutdownHook(new Thread() {
        @Override
        public void run() {
            try {
                server.stop();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    });
	
	/**ThreadPool taskWorkerExecutor = newFixedThreadPool(1);

       ThriftServerDef serverDef = ThriftServerDef.newBuilder()
               .listen(8899)
               .withProcessor(processor)
               .using(taskWorkerExecutor)
               .build();

       bossExecutor = newCachedThreadPool();
       ioWorkerExecutor = newCachedThreadPool();

       NettyServerConfig serverConfig = NettyServerConfig.newBuilder()
               .setBossThreadExecutor(bossExecutor)
               .setWorkerThreadExecutor(ioWorkerExecutor)
               .build();

       server = new ThriftServer(serverConfig, serverDef);
       server.start();**/

}
 

import com.facebook.swift.service.ThriftServiceProcessor; //导入依赖的package包/类
ScribeCollector(Builder builder) {
  ScribeSpanConsumer scribe = new ScribeSpanConsumer(builder);
  ThriftServiceProcessor processor =
      new ThriftServiceProcessor(new ThriftCodecManager(), emptyList(), scribe);
  server = new ThriftServer(processor, new ThriftServerConfig().setPort(builder.port));
}