我正在学习Netty,我不太了解ChannelFuture的同步方法,这是我的示例:
public class EchoServer {
private final int port;
public EchoServer(int port) {
this.port = port;
}
public static void main(String[] args) throws Exception {
if (args.length != 1) {
System.err.println("Usage: " + EchoServer.class.getSimpleName() + " <port>");
return;
}
int port = Integer.parseInt(args[0]);
new EchoServer(port).start();
}
public void start() throws Exception {
// final EchoServerHandler serverHandler = new EchoServerHandler();
EventLoopGroup group = new NioEventLoopGroup();
try {
ServerBootstrap b = new ServerBootstrap();
b.group(group).channel(NioServerSocketChannel.class).localAddress(new InetSocketAddress(port)).childHandler(new ChannelInitializer<SocketChannel>() {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
// ch.pipeline().addLast(serverHandler);
}
});
ChannelFuture f = b.bind().sync();
f.channel().closeFuture().sync();
} finally {
group.shutdownGracefully().sync();
}
}
}
public class EchoClient {
private final String host;
private final int port;
public EchoClient(String host, int port) {
this.host = host;
this.port = port;
}
public void start() throws Exception {
EventLoopGroup group = new NioEventLoopGroup();
try {
Bootstrap b = new Bootstrap();
b.group(group).channel(NioSocketChannel.class).remoteAddress(new InetSocketAddress(host, port)).handler(new ChannelInitializer<SocketChannel>() {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
// ch.pipeline().addLast(new EchoClientHandler());
}
});
ChannelFuture f = b.connect().sync().addListener(future -> {
if(future.isSuccess()) {
System.out.println(port + " bind success");
} else{
System.err.println(port + " bind fail");
}
});
System.out.println("aaa");
f.channel().closeFuture().sync();
} finally {
group.shutdownGracefully().sync();
}
}
public static void main(String[] args) throws Exception {
if (args.length != 2) {
System.err.println("Usage: " + EchoClient.class.getSimpleName() + " <host> <port>");
return;
}
String host = args[0];
int port = Integer.parseInt(args[1]);
new EchoClient(host, port).start();
}
}
我的问题是,无论我在EchoClient中删除了什么sync()。ChannelFuture的类f=b.connect()。无论是否为sync(),结果总是:aaa 8811 bind success
在我看来,如果添加sync(),结果应该是:8811 bind success aaa
由于主线程会等待通道连接,
如果我删除 sync(),结果应该是:aaa 8811 绑定成功
由于connect()是异步的
为什么我错了?
sync()
将在操作完成后立即解除屏蔽,然后EventLoop
将通知所有附加的监听器到ChannelFuture
。由于您的主线程和EventLoop
线程是不同的,因此您很有可能会在ChannelFutureListener
中之前在主线程中看到System.out.println(…)
客户端通道在服务器入站通道激活方法中初始化。我可以看到pcap已经完成了三次握手(253是本地主机,15是远程主机) 但是当写入客户端通道时,它抛出 java.nio.channels。NotYetConnectedException:io.netty.channel.AbstractChannel$AbstractUnsafe处为null。flush0()(未知源) 根据我的理解,客户端通道应该
我想用Netty实现Slack API客户端。Slack有几十种方法,每种方法都有不同的URL和响应格式。 我应该为每种方法创建一个通道并重复使用单个引导程序,还是应该为所有通信使用单个通道?实际上,我做这个项目是为了学习Netty,我无法从文档和示例(这些都是非常基本的)中理解策略。 对于通道每API方法,我可以使用不同的处理程序来处理不同的数据类型,但对于单个通道,我无法做到这一点,是吗? 我
问题内容: 我正在使用以下示例代码创建频道: 所以在这里我得到了一个通道(将来的通道),但是我的应用程序吞吐量会很高,所以我认为一个通道是不够的,所以请让我知道我如何创建通道池。 我正在使用netty 4.0 问题答案: 请参阅http://netty.io/news/2015/05/07/4-0-28-Final.html上的部分
我正在使用Netty 4(alpha8)。 我想在管道中的ChannelHanders之间共享一些数据,在Netty的以前版本中,我想我会使用ChannelLocal,有没有Netty 4的等效版本?
我刚开始和内蒂一起工作。我已经有了一个服务器,我正在为一个客户端写代码。 在客户端,我用下面的代码为ClientBootstrap对象设置了一个新的PipelineFactory 其中ResponseHandler()是我扩展SimpleChannelHandler的类。 我想找到频道ID。我做到了。 但它会抛出IllelgalStateException并表示我无法调用getPipeline()
在Netty 4“代理”示例中,通道自动读取选项已被禁用: 如果注释了< code>childOption(ChannelOption。AUTO_READ,false),代理示例将无法工作。更详细地说,在类< code > hexdumproxyfrontendhandler 的方法< code>channelRead中,< code>outboundChannel将总是不活动的。 我研究了Net