下面列出了怎么用com.alibaba.dubbo.rpc.protocol.thrift.ext.MultiServiceProcessor的API类实例代码及写法，或者点击链接到github查看源代码。
protected TProcessor getProcessor() {
MultiServiceProcessor result = new MultiServiceProcessor();
result.addProcessor(
com.alibaba.dubbo.rpc.gen.dubbo.Demo.class,
new $__DemoStub.Processor(getServiceImpl()));
return result;
}
protected TProcessor getProcessor() {
MultiServiceProcessor result = new MultiServiceProcessor();
result.addProcessor(
com.alibaba.dubbo.rpc.gen.dubbo.Demo.class,
new $__DemoStub.Processor( getServiceImpl() ) );
return result;
}
protected TProcessor getProcessor() {
MultiServiceProcessor result = new MultiServiceProcessor();
result.addProcessor(
com.alibaba.dubbo.rpc.gen.dubbo.Demo.class,
new $__DemoStub.Processor( getServiceImpl() ) );
return result;
}
protected TProcessor getProcessor() {
MultiServiceProcessor result = new MultiServiceProcessor();
result.addProcessor(
com.alibaba.dubbo.rpc.gen.dubbo.Demo.class,
new $__DemoStub.Processor( getServiceImpl() ) );
return result;
}
protected TProcessor getProcessor() {
MultiServiceProcessor result = new MultiServiceProcessor();
result.addProcessor(
com.alibaba.dubbo.rpc.gen.dubbo.Demo.class,
new $__DemoStub.Processor( getServiceImpl() ) );
return result;
}
protected void init() throws Exception {
TServerTransport serverTransport = new TServerSocket(PORT);
DubboDemoImpl impl = new DubboDemoImpl();
$__DemoStub.Processor processor = new $__DemoStub.Processor(impl);
// for test
Field field = processor.getClass().getSuperclass().getDeclaredField("processMap");
field.setAccessible(true);
Object obj = field.get(processor);
if (obj instanceof Map) {
((Map) obj).remove("echoString");
}
// ~
TBinaryProtocol.Factory bFactory = new TBinaryProtocol.Factory();
MultiServiceProcessor wrapper = new MultiServiceProcessor();
wrapper.addProcessor(Demo.class, processor);
server = new TThreadPoolServer(
new TThreadPoolServer.Args(serverTransport)
.inputProtocolFactory(bFactory)
.outputProtocolFactory(bFactory)
.inputTransportFactory(getTransportFactory())
.outputTransportFactory(getTransportFactory())
.processor(wrapper));
Thread startTread = new Thread() {
@Override
public void run() {
server.serve();
}
};
startTread.start();
while (!server.isServing()) {
Thread.sleep(100);
}
}
protected void init() throws Exception {
TServerTransport serverTransport = new TServerSocket( PORT );
DubboDemoImpl impl = new DubboDemoImpl();
$__DemoStub.Processor processor = new $__DemoStub.Processor( impl );
// for test
Field field = processor.getClass().getSuperclass().getDeclaredField( "processMap" );
field.setAccessible( true );
Object obj = field.get( processor );
if ( obj instanceof Map ) {
( ( Map ) obj ).remove( "echoString" );
}
// ~
TBinaryProtocol.Factory bFactory = new TBinaryProtocol.Factory();
MultiServiceProcessor wrapper = new MultiServiceProcessor();
wrapper.addProcessor( Demo.class, processor );
server = new TThreadPoolServer(
new TThreadPoolServer.Args( serverTransport )
.inputProtocolFactory( bFactory )
.outputProtocolFactory( bFactory )
.inputTransportFactory( getTransportFactory() )
.outputTransportFactory( getTransportFactory() )
.processor( wrapper ) );
Thread startTread = new Thread() {
@Override
public void run() {
server.serve();
}
};
startTread.start();
while ( !server.isServing() ) {
Thread.sleep( 100 );
}
}
protected void init() throws Exception {
TServerTransport serverTransport = new TServerSocket( PORT );
DubboDemoImpl impl = new DubboDemoImpl();
$__DemoStub.Processor processor = new $__DemoStub.Processor( impl );
// for test
Field field = processor.getClass().getSuperclass().getDeclaredField( "processMap" );
field.setAccessible( true );
Object obj = field.get( processor );
if ( obj instanceof Map ) {
( ( Map ) obj ).remove( "echoString" );
}
// ~
TBinaryProtocol.Factory bFactory = new TBinaryProtocol.Factory();
MultiServiceProcessor wrapper = new MultiServiceProcessor();
wrapper.addProcessor( Demo.class, processor );
server = new TThreadPoolServer(
new TThreadPoolServer.Args( serverTransport )
.inputProtocolFactory( bFactory )
.outputProtocolFactory( bFactory )
.inputTransportFactory( getTransportFactory() )
.outputTransportFactory( getTransportFactory() )
.processor( wrapper ) );
Thread startTread = new Thread() {
@Override
public void run() {
server.serve();
}
};
startTread.start();
while ( !server.isServing() ) {
Thread.sleep( 100 );
}
}
protected void init() throws Exception {
TServerTransport serverTransport = new TServerSocket( PORT );
DubboDemoImpl impl = new DubboDemoImpl();
$__DemoStub.Processor processor = new $__DemoStub.Processor( impl );
// for test
Field field = processor.getClass().getSuperclass().getDeclaredField( "processMap" );
field.setAccessible( true );
Object obj = field.get( processor );
if ( obj instanceof Map ) {
( ( Map ) obj ).remove( "echoString" );
}
// ~
TBinaryProtocol.Factory bFactory = new TBinaryProtocol.Factory();
MultiServiceProcessor wrapper = new MultiServiceProcessor();
wrapper.addProcessor( Demo.class, processor );
server = new TThreadPoolServer(
new TThreadPoolServer.Args( serverTransport )
.inputProtocolFactory( bFactory )
.outputProtocolFactory( bFactory )
.inputTransportFactory( getTransportFactory() )
.outputTransportFactory( getTransportFactory() )
.processor( wrapper ) );
Thread startTread = new Thread() {
@Override
public void run() {
server.serve();
}
};
startTread.start();
while ( !server.isServing() ) {
Thread.sleep( 100 );
}
}
protected void init() throws Exception {
TServerTransport serverTransport = new TServerSocket( PORT );
DubboDemoImpl impl = new DubboDemoImpl();
$__DemoStub.Processor processor = new $__DemoStub.Processor( impl );
// for test
Field field = processor.getClass().getSuperclass().getDeclaredField( "processMap" );
field.setAccessible( true );
Object obj = field.get( processor );
if ( obj instanceof Map ) {
( ( Map ) obj ).remove( "echoString" );
}
// ~
TBinaryProtocol.Factory bFactory = new TBinaryProtocol.Factory();
MultiServiceProcessor wrapper = new MultiServiceProcessor();
wrapper.addProcessor( Demo.class, processor );
server = new TThreadPoolServer(
new TThreadPoolServer.Args( serverTransport )
.inputProtocolFactory( bFactory )
.outputProtocolFactory( bFactory )
.inputTransportFactory( getTransportFactory() )
.outputTransportFactory( getTransportFactory() )
.processor( wrapper ) );
Thread startTread = new Thread() {
@Override
public void run() {
server.serve();
}
};
startTread.start();
while ( !server.isServing() ) {
Thread.sleep( 100 );
}
}