@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 ); }
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(); }
@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); }
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(); } } }); }
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();**/ }
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)); }