- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
我有一个Java客户端,该客户端使用使用Java NIO的TCP套接字连接到C++服务器。这在Linux,AIX和HP/UX上有效,但是在Solaris上,OP_CONNECT
事件从不触发。
更多详细信息:
Selector.select()
返回0,并且“所选键集”为空。 import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Set;
public class NioTest3
{
public static void main(String[] args)
{
int i, tcount = 1, open = 0;
String[] addr = args[0].split(":");
int port = Integer.parseInt(addr[1]);
if (args.length == 2)
tcount = Integer.parseInt(args[1]);
InetSocketAddress inetaddr = new InetSocketAddress(addr[0], port);
try
{
Selector selector = Selector.open();
SocketChannel channel;
for (i = 0; i < tcount; i++)
{
channel = SocketChannel.open();
channel.configureBlocking(false);
channel.register(selector, SelectionKey.OP_CONNECT);
channel.connect(inetaddr);
}
open = tcount;
while (open > 0)
{
int selected = selector.select();
System.out.println("Selected=" + selected);
Iterator<SelectionKey> it = selector.selectedKeys().iterator();
while (it.hasNext())
{
SelectionKey key = it.next();
it.remove();
channel = (SocketChannel)key.channel();
if (key.isConnectable())
{
System.out.println("isConnectable");
if (channel.finishConnect())
{
System.out.println(formatAddr(channel) + " connected");
key.interestOps(SelectionKey.OP_WRITE);
}
}
else if (key.isWritable())
{
System.out.println(formatAddr(channel) + " isWritable");
String message = formatAddr(channel) + " the quick brown fox jumps over the lazy dog";
ByteBuffer buffer = ByteBuffer.wrap(message.getBytes());
channel.write(buffer);
key.interestOps(SelectionKey.OP_READ);
}
else if (key.isReadable())
{
System.out.println(formatAddr(channel) + " isReadable");
ByteBuffer buffer = ByteBuffer.allocate(1024);
channel.read(buffer);
buffer.flip();
byte[] bytes = new byte[buffer.remaining()];
buffer.get(bytes);
String message = new String(bytes);
System.out.println(formatAddr(channel) + " read: '" + message + "'");
channel.close();
open--;
}
}
}
}
catch (IOException e)
{
e.printStackTrace();
}
}
static String formatAddr(SocketChannel channel)
{
return Integer.toString(channel.socket().getLocalPort());
}
}
java -cp . NioTest3 <ipaddr>:<port> <num-connections>
java -cp . NioTest3 127.0.0.1:7 5
$ cc -o echoserver echoserver.c -lsocket -lnsl
$ ./echoserver 8007 > out 2>&1 &
最佳答案
您的错误报告已关闭为“不是错误”,并附有解释。您将忽略connect()
的结果,如果为true,则表示OP_CONNECT
将永远不会触发,因为该 channel 已连接。如果返回的结果为false,则只需要整个OP_CONNECT/finishConnect()
megillah。因此,除非OP_CONNECT
返回false,否则您甚至不应该注册connect()
,更不用说在甚至调用connect().
之前注册它了。
进一步说明:
在后台,OP_CONNECT
和OP_WRITE
是同一件事,这解释了其中的一部分。
由于您只有一个线程,解决方法是在阻塞模式下进行连接,然后将I/O切换为非阻塞。
在使用Selector
注册 channel 之后,您是否正在执行select()?
处理非阻塞连接的正确方法如下:
channel.configureBlocking(false);
if (!channel.connect(...))
{
channel.register(sel, SelectionKey.OP_CONNECT, ...); // ... is the attachment, or absent
}
// else channel is connected, maybe register for OP_READ ...
// select() loop runs ...
// Process the ready keys ...
if (key.isConnectable())
{
if (channel.finishConnect())
{
key.interestOps(0); // or SelectionKey.OP_READ or OP_WRITE, whatever is appropriate
}
}
在查看您的扩展代码后,一些非详尽的注释:
removeInterest()
方法。TYPE_DEREGISTER_OBJECT
也关闭 channel 。不确定这是否是您真正想要的。我以为它应该只是取消键,并且应该有一个单独的操作来关闭 channel 。addInterest()
和removeInterest()
是很好的例子。他们捕获了异常,将其记录下来,然后进行设置或清除了一点,就好像未发生异常一样进行处理:一行代码。而且最重要的是,它们同时具有静态和非静态版本。所有调用key.cancel()
,channel.close()
等的小方法也是如此。这没有任何意义,只是增加了代码行数。它只会增加模糊性,并使您的代码更难以理解。只需内联进行所需的操作,并在select循环的底部具有单个捕获器即可。finishConnect()
返回false,则不是连接失败,它尚未完成。如果抛出Exception
,则表明连接失败。OP_CONNECT
和OP_READ
。这没有道理,可能会引起问题。在OP_CONNECT
触发之前,没有任何内容可供阅读。只需先注册OP_CONNECT
。ByteBuffer
。这非常浪费。在连接的整个生命周期中,请使用相同的连接器。read()
的结果。可以为零。它可以是-1,表示EOS,您必须在该 channel 上关闭 channel 。您还假设一次读取即可获得完整的应用程序消息。你不能以为。这就是为什么在连接的整个生命周期内都应使用单个ByteBuffer
的另一个原因。write()
的结果。调用时它可能小于buffer.remaining(
)。可以为零。NetSelectable
设置为键附件,可以大大简化此过程。然后,您可以删除一些内容,例如 channel 映射和断言,因为键的 channel 必须始终等于键的附件的 channel 。finishConnect()
代码移动到NetSelector
,并让connectEvent()
只是成功/失败通知。您不想散布这种东西。对readEvent()
进行相同的操作,即使用NetSelector
提供的缓冲区在NetSelectable
中进行读取,然后将读取结果通知给NetSelectable
:count或-1或NetSelectable
中写入一些内容,将其写入NetSelector中,然后通知结果。您可以让通知回调返回一些内容以指示下一步要执行的操作,例如关闭 channel 。关于java - Java Solaris NIO OP_CONNECT问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/6540346/
关闭。这个问题是off-topic .它目前不接受答案。 想要改进这个问题? Update the question所以它是on-topic用于堆栈溢出。 关闭 12 年前。 Improve thi
我有一个动态网格,其中的数据功能需要正常工作,这样我才能逐步复制网格中的数据。假设在第 5 行中,我输入 10,则从第 6 行开始的后续行应从 11 开始读取,依此类推。 如果我转到空白的第一行并输入
我有一个关于我的按钮消失的问题 我已经把一个图像作为我的按钮 用这个函数动画 function example_animate(px) { $('#cont
我有一个具有 Facebook 连接和经典用户名/密码登录的网站。目前,如果用户单击 facebook_connect 按钮,系统即可运行。但是,我想将现有帐户链接到 facebook,因为用户可以选
我有一个正在为 iOS 开发的应用程序,该应用程序执行以下操作 加载和设置注释并启动核心定位和缩放到位置。 map 上有很多注释,从数据加载不会花很长时间,但将它们实际渲染到 map 上需要一段时间。
我被推荐使用 Heroku for Ruby on Rails 托管,到目前为止,我认为我真的会喜欢它。只是想知道是否有人可以帮助我找出问题所在。 我按照那里的说明在该网站上创建应用程序,创建并提交
我看过很多关于 SSL 错误的帖子和信息,我自己也偶然发现了一个。 我正在尝试使用 GlobalSign CA BE 证书通过 Android WebView 访问网页,但出现了不可信错误。 对于大多
我想开始使用 OpenGL 3+ 和 4,但我在使用 Glew 时遇到了问题。我试图将 glew32.lib 包含在附加依赖项中,并且我已将库和 .dll 移动到主文件夹中,因此不应该有任何路径问题。
我已经盯着这两个下载页面的源代码看了一段时间,但我似乎找不到问题。 我有两个下载页面,一个 javascript 可以工作,一个没有。 工作:http://justupload.it/v/lfd7不是
我一直在使用 jQuery,只是尝试在单击链接时替换文本字段以及隐藏/显示内容项。它似乎在 IE 中工作得很好,但我似乎无法让它在 FF 中工作。 我的 jQuery: $(function() {
我正在尝试为 NDK 编译套接字库,但出现以下两个错误: error: 'close' was not declared in this scope 和 error: 'min' is not a m
我正在使用 Selenium 浏览器自动化框架测试网站。在测试过程中,我切换到特定的框架,我们将其称为“frame_1”。后来,我在 Select 类中使用了 deselectAll() 方法。不久之
我正在尝试通过 Python 创建到 Heroku PostgreSQL 数据库的连接。我将 Windows10 与 Python 3.6.8 和 PostgreSQL 9.6 一起使用。 我从“ht
我有一个包含 2 列的数据框,我想根据两列之间的比较创建第三列。 所以逻辑是:第 1 列 val = 3,第 2 列 val = 4,因此新列值什么都没有 第 1 列 val = 3,第 2 列 va
我想知道如何调试 iphone 5 中的 css 问题。 我尝试使用 firelite 插件。但是从纵向旋转到横向时,火石占据了整个屏幕。 有没有其他方法可以调试 iphone 5 中的 css 问题
所以我有点难以理解为什么这不起作用。我正在尝试替换我正在处理的示例站点上的类别复选框。我试图让它做以下事情:未选中时以一种方式出现,悬停时以另一种方式出现(选中或未选中)选中时以第三种方式出现(而不是
Javascript CSS 问题: 我正在使用一个文本框来写入一个 div。我使用以下 javascript 获取文本框来执行此操作: function process_input(){
你好,我很难理解 P、NP 和多项式时间缩减的主题。我试过在网上搜索它并问过我的一些 friend ,但我没有得到任何好的答案。 我想问一个关于这个话题的一般性问题: 设 A,B 为 P 中的语言(或
你好,我一直在研究 https://leetcode.com/problems/2-keys-keyboard/并想到了这个动态规划问题。 您从空白页上的“A”开始,完成后得到一个数字 n,页面上应该
我正在使用 Cocoapods 和 KIF 在 Xcode 服务器上运行持续集成。我已经成功地为一个项目设置了它来报告每次提交。我现在正在使用第二个项目并收到错误: Bot Issue: warnin
我是一名优秀的程序员,十分优秀!