Hi,
I am currently working on a little trade date streaming service that
basically listens to a service that streams finance tick data and after
applying some business logic, I'd like to publish this information on all
websocket clients that are connected to my server.
So far I added a Bootstrap that listens to the streaming service like this:
public class TickSource {
private static final byte FS = 28;
public void run() throws Exception {
String host = "localhost";
int port = 20077;
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
Bootstrap b = new Bootstrap();
b.group(workerGroup);
b.channel(NioSocketChannel.class);
b.option(ChannelOption.SO_KEEPALIVE, true);
b.handler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast(new DelimiterBasedFrameDecoder(81920,
Unpooled.wrappedBuffer(new byte[]{FS})));
ch.pipeline().addLast(new TickSourceHandler());
}
});
ChannelFuture f = b.connect(host, port).sync();
f.channel().closeFuture().sync();
} finally {
workerGroup.shutdownGracefully();
}
}
}
and another ServerBootstrap that publishes the information to the connected
clients:
public class TickDistributor {
public void run() throws Exception {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
final ServerBootstrap sb = new ServerBootstrap();
sb.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(final SocketChannel ch) throws
Exception {
ch.pipeline().addLast(
new HttpRequestDecoder(),
new HttpObjectAggregator(65536),
new HttpResponseEncoder(),
new
WebSocketServerProtocolHandler("/ticks"),
new TickDistributorHandler()
);
}
}
);
Channel ch = sb.bind(8080).sync().channel();
ch.closeFuture().sync();
} finally {
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
}
So, my problem is that I do not really know how to connect these two
Bootstraps with each other? Having read Netty in Action, I am aware that
you are able to bootstrap with the same Eventloop, which also uses the same
thread for all operations but in my case I have a 1->n relation, so one
producer and many consumers.
I thought about storing the ServerChannels in some collection and whenever
the Bootstrap client has a new message, forward it to the channels but I am
not sure if that is a good approach or if it can be done in a fashion that
suits netty better?
I also read about local channels, which are especially for Bootstraps
running on the same VM, not sure if it is a good fit though?
Thx,
u6f6o
--
You received this message because you are subscribed to the Google Groups
"Netty discussions" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To view this discussion on the web visit
https://groups.google.com/d/msgid/netty/70678360-8660-4276-91b2-b7fb7346d85c%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
