nio

    0热度

    1回答

    我必须在JBoss中构建一个JAVA NIO服务器应用程序以从10-200个传感器盒中读取数据。他们打开一个流,并始终向我发送数据。沟通是双向的。现在,有时会发生这些Box(或服务器)出现内部错误。为了检测这种问题,观察者线程每5秒检查一次数据块是否自上次检查后进入。如果我的盒子都没有发送数据,那么发生了一些不好的事情,我想重新启动整个套接字通信。 现在,很好地阐述了如何建立与NIO的套接字连接,

    1热度

    1回答

    正尝试通过Java使用Azure通知中心。当试图创建注册时,我得到一个java.net.ConnectException:连接超时:没有进一步的信息。有人能帮我理解为什么会出现这个问题吗?请让我知道你是否需要更多信息。谢谢。 我使用的代码是https://github.com/Azure/azure-notificationhubs-java-backend/blob/master/Notific

    0热度

    1回答

    我想使用MappedByteBuffer存储/加载一些数据到文件。假设我有长度为A的字段A,字符串的字段B在序列化时如下所示: A(long)| B(字符串) 现在我想写和读它。这里是一段示例代码: RandomAccessFile file = new RandomAccessFile(dataPath.toString(), "rw"); MappedByteBuffer mbb =

    0热度

    1回答

    我的工作目录中有不同种类的文件(.log,.xml,.opf等)。我需要复制他们的另一个文件夹。但只有一个文件被复制,据我所知这是因为在复制方法中使用StandardCopyOption.REPLACE_EXISTING。 这是我的Java代码 String currentDirectory = new File(new File("").getAbsolutePath()).getPath();

    2热度

    4回答

    虽然连接到Windows机器作为奴隶,我得到以下错误,我认为它的一些网络相关的问题,但需要一些帮助在哪里开始寻找或什么是一个为此可能的解决方案。 INFO: Terminated Aug 01, 2017 10:15:54 PM hudson.remoting.JarCacheSupport$1 run WARNING: Failed to resolve a jar 06bcb4519543

    1热度

    1回答

    我遇到了一些奇怪的行为,阅读Java 8中的文件,我想知道是否有人可以理解它。 场景: 读取格式错误的文本文件。通过格式不正确,我的意思是它包含的字节不映射到任何unicode代码点。 我使用创建这样的文件中的代码如下: byte[] text = new byte[1]; char k = (char) -60; text[0] = (byte) k; FileUtils.writeByt

    1热度

    1回答

    正如在http中我们可以实现多个url来执行不同的操作。我们如何用Netty Server实现同样的功能? 更明确地说,我必须根据请求(也是4种类型)从netty服务器输出四种类型的google protobuf。我应该为每个请求类型创建单独的Netty服务器,还是应该在同一个管道中使用不同的处理程序?在后面的情况下,我将不得不拥有至少4 * 3 = 12个处理程序(对于每个请求类型,一个入站pr

    1热度

    3回答

    好吧,所以我正在尝试做一些看起来应该相当简单的事情,但是使用这些新的NIO接口,事情让我感到困惑!这就是我想要做的事情,我需要以字节为单位扫描文件,直到遇到特定的字节!当我遇到那些特定的字节时,需要获取数据段并对其进行处理,然后再继续操作。我会认为,通过ByteBuffer中的所有这些标记和位置和限制,我可以做到这一点,但我似乎无法使它工作!只有 import java.io.IOExceptio

    0热度

    1回答

    我正试图实施NIO服务器并且有一个关于SelectionKey的问题。假设我们提取了一些准备好读取的密钥。就像这样: SelectionKey key; //... SocketChannel c = (SocketChannel) key.channel; //read from c 但是我们从通道读取的是不足以使一个完整的Packet。所以我附加了一些对象到key。 问:什么时候应该

    0热度

    1回答

    我试图运行最简单的NIO服务器,它只接受连接。 public static void main(String[] args) throws IOException{ Selector selector = Selector.open(); ServerSocketChannel serverChannel = ServerSocketChannel.open(); s