1

我打算用Netty来设计一个TCP Server。当客户端连接时,我必须立即开始连续向客户端发送 XML 数据……数小时/数天。就这么简单。

所以,我重写了“channelConnected”方法并从该方法发送数据,对吧?......那太好了。

我将使用以下 ChannelFactory

ChannelFactory factory =
    new NioServerSocketChannelFactory(
            Executors.newCachedThreadPool(),
            Executors.newCachedThreadPool());

NioServerSocketChannelFactory文件说

工作线程以非阻塞模式对一个或多个 Channel 执行非阻塞读写。

好的。

根据有效的 Java 第 51 条:不要依赖线程调度程序,我希望工作线程执行“工作单元”,然后完成/返回。

所以在我的情况下,虽然我必须连续发送数据,但我想发送一些块(比如说 1 MB)然后完成(工作单元完成),以便工作线程可以返回。然后我会再发送 1 MB。

下面的例子来自 Netty HERE的官方指南。
我想问题是,在这种情况下,如果我必须无条件地继续向客户发送时间,我将如何做,将每次发送视为一个工作单元。

一种方法是只放置一个while循环并执行Thread.Sleep。还有什么办法吗?

    package org.jboss.netty.example.time;

    public class TimeServerHandler extends SimpleChannelHandler {

        @Override
        public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) {
            Channel ch = e.getChannel();

            ChannelBuffer time = ChannelBuffers.buffer(4);
            time.writeInt(System.currentTimeMillis() / 1000);

            ChannelFuture f = ch.write(time);

            f.addListener(new ChannelFutureListener() {
                public void operationComplete(ChannelFuture future) {
                    Channel ch = future.getChannel();
                    ch.close();
                }
            });
        }

        @Override
        public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) {
            e.getCause().printStackTrace();
            e.getChannel().close();
        }
    }
4

1 回答 1

2

做一会儿/睡觉会起作用,但不会是 Netty 的超级可扩展风格。这将是每个连接的线程编程。

相反,在 Executor 上安排一个定期作业,将消息写入通道。

于 2011-11-14T02:55:58.410 回答