如何在Netty的mina中重现IoSession
在Netty中重现IoSession的过程可以通过使用ChannelHandlerContext来实现。Netty是一个基于事件驱动的网络应用框架，它提供了一种异步的、事件驱动的网络编程模型，而不是像传统的阻塞I/O模型那样使用线程池来处理连接。
要在Netty中重现IoSession，可以按照以下步骤进行操作：
- 创建一个ChannelHandler类，继承自ChannelInboundHandlerAdapter。这个类将负责处理接收到的事件和消息。
- 在ChannelHandler类中，重写channelActive()方法。这个方法在连接建立时被调用，可以在这里进行一些初始化操作。
- 在channelActive()方法中，创建一个新的ChannelHandlerContext对象，并将其保存起来。ChannelHandlerContext是Netty中的上下文对象，它包含了当前处理器的信息和状态。
- 在channelActive()方法中，使用保存的ChannelHandlerContext对象创建一个新的ChannelPipeline，并将其设置为当前连接的Pipeline。ChannelPipeline是Netty中的事件处理链，它负责处理和转发事件。
- 在channelActive()方法中，使用保存的ChannelHandlerContext对象创建一个新的Channel，并将其设置为当前连接的Channel。Channel是Netty中的通道，它代表了一个网络连接。
- 在channelActive()方法中，使用保存的ChannelHandlerContext对象创建一个新的ChannelFuture，并将其设置为当前连接的Future。ChannelFuture是Netty中的异步操作结果，它可以用来获取操作的状态和结果。
- 在channelActive()方法中，使用保存的ChannelHandlerContext对象创建一个新的ChannelPromise，并将其设置为当前连接的Promise。ChannelPromise是Netty中的异步操作承诺，它可以用来设置操作的结果。
- 在channelActive()方法中，使用保存的ChannelHandlerContext对象创建一个新的ChannelId，并将其设置为当前连接的Id。ChannelId是Netty中的通道标识符，它可以用来唯一标识一个连接。
- 在channelActive()方法中，使用保存的ChannelHandlerContext对象创建一个新的ChannelConfig，并将其设置为当前连接的Config。ChannelConfig是Netty中的通道配置，它可以用来设置通道的参数和属性。
- 在channelActive()方法中，使用保存的ChannelHandlerContext对象创建一个新的ChannelHandler，并将其添加到当前连接的Pipeline中。ChannelHandler是Netty中的事件处理器，它负责处理和转发事件。
- 在channelActive()方法中，使用保存的ChannelHandlerContext对象创建一个新的ChannelHandlerContext，并将其设置为当前连接的上下文。这样就完成了IoSession的重现。
通过以上步骤，我们可以在Netty中重现IoSession的功能。在实际应用中，可以根据具体需求来处理接收到的事件和消息，实现自定义的业务逻辑。
关于Netty的更多信息和使用方法，可以参考腾讯云的相关产品和文档：
- 腾讯云产品：云服务器 CVM（https://cloud.tencent.com/product/cvm）
- 腾讯云产品：云原生容器服务 TKE（https://cloud.tencent.com/product/tke）
- 腾讯云产品：云数据库 MySQL（https://cloud.tencent.com/product/cdb_mysql）
- 腾讯云产品：云存储 COS（https://cloud.tencent.com/product/cos）
- 腾讯云产品：人工智能 AI（https://cloud.tencent.com/product/ai）
- 腾讯云产品：物联网 IoT（https://cloud.tencent.com/product/iot）
- 腾讯云产品：移动开发 MSDK（https://cloud.tencent.com/product/msdk）
- 腾讯云产品：区块链 BaaS（https://cloud.tencent.com/product/baas）
- 腾讯云产品：元宇宙 TCG（https://cloud.tencent.com/product/tcg）
以上链接提供了腾讯云相关产品的介绍和文档，可以帮助您更深入地了解和使用Netty以及其他云计算领域的技术。
相关·内容
有一个项目想要从mina过渡到netty，但涉及到IoSession作为本地会话。那么如何在Netty中实现类似的会话以供使用。 private IoSession _session;
if (immediately) {
_session.closeNow();
}else{
_session.closeOnFlush();
} 如何更好地实现此功能
浏览 55提问于2020-12-26得票数 0
回答已采纳
我在使用apache mina连接套接字服务器时遇到了一个奇怪的问题。即使套接字服务器关闭，我也没有收到任何错误或回调。但如果在连接尝试成功后失去了到服务器的连接，我会收到通知。其他人有没有遇到过这种行为？
浏览 0提问于2014-05-20得票数 1
3回答
我刚开始使用米娜。我有一个使用MINA NIOconnector连接主机的程序。我可以发送数据也可以接收。从下面我附加的log4j日志中可以清楚地看到这一点。
E:\>java TC4HostClient
[12:21:46] NioProcessor-1 INFO [] [] [org.apache.mina.filter.logging.LoggingFil
ter] - CREATED
[12:21:46] NioProcessor-1 INFO [] [] [org.apache.mina.filter.logging.LoggingFil
ter] - OPENED
Ope
浏览 6提问于2010-04-29得票数 2
回答已采纳
3回答
我正在使用Apache Mina创建一个服务器来接受UDP客户端请求。我已经阅读了Apache Mina提供的关于的官方文档。但是，我想知道当服务器收到消息时，我是否可以使用相同的会话(我知道UDP在网络层是无连接的，但我可以在应用层获得远程主机的IP和端口)来写回UDP客户端，以便UDP客户端接收消息。我知道这是可能的是TCP，但我对UDP有点困惑。我知道这可能不完全是基于Java的问题，但更多的是基于网络层的问题。如果有人能帮我清理一下会很感激。
浏览 0提问于2011-04-27得票数 0
回答已采纳
1回答
package com.buscontrol.site.message;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;
import net.sf.json.JSONObject;
import net.sf.json.JSONSerializer;
import org.apache.mina.core.RuntimeIoException;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.se
浏览 17提问于2017-02-15得票数 0
1回答
在使用apache的示例程序中，我遵循了这个。
这些是我在代码中使用的lib文件。
mina-core-2.0.7.jar
slf4j-api-1.7.5.jar
slf4j-jdk14-1.7.5.jar
我得到了以下错误：
Exception in thread "main" java.lang.ClassCastException: org.slf4j.impl.JDK14LoggerAdapter cannot be cast to java.util.logging.Logger
at minafiletrans.MinaServerHan
浏览 1提问于2013-04-09得票数 0
回答已采纳
当我试图运行我的服务器代码..。
服务器代码
package Socket;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;
import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.a
浏览 1提问于2017-01-03得票数 2
回答已采纳
我有一个Spring应用程序，我需要用Apache库实现非常简单的通信通道。
我的Spring应用程序正在运行，但是MINA服务器没有运行，在netstat中没有使用这个端口。
我遵循了本教程：
我做错什么了？
这是一个处理程序类：
public class ServerHandler extends IoHandlerAdapter {
@Override
public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
cause.printStackTra
浏览 3提问于2013-06-28得票数 0
回答已采纳
1回答
我不确定这个问题是与Mina相关的，还是更多的Azure相关的，但它与网络有关。自从Mina和Netty分享了许多网络原则以来，我还添加了Netty标记。
我希望能得到一个建议，深入到哪里去。
我已经在本地网络中使用了相当长时间的Mina应用程序，现在我正在尝试将它迁移到云中。我在Azure中部署Linux虚拟机(每个虚拟机都有公共IP，但这真的很重要吗？)
他们连接(使用Mina)到Azure外面的一台机器，这台机器也有自己的公共IP。通常的事情：
SocketConnector connector = new NioSocketConnector(numberOfConnectors);
浏览 2提问于2017-01-18得票数 0
回答已采纳
我开始使用mina对套接字进行异步写入，但现在似乎无法关闭会话。有没有办法强制mina关闭所有托管会话或进行清理？这就是我现在要说的：
if(this.acceptor.isActive()) {
for(IoSession session : this.acceptor.getManagedSessions().values()) {
session.close(true);
}
this.acceptor.unbind();
this.acceptor.dispose();
}
谢谢
浏览 3提问于2011-03-19得票数 3
我正在尝试使用Apache Mina编写一个Http服务器。 根据Mina的体系结构，此任务应该有两个过滤器，一个用于Http请求传递，另一个用于处理请求和生成响应。因此，使用Mina示例代码，我编写了以下代码，其中包含一个接受器、日志过滤器、Http过滤器和一个用于处理请求的过滤器。 服务器的初始化运行正常，但请求未到达DummyHttpSever筛选器。我尝试调试，但找不到问题所在。这里出了什么问题？ import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.util.ArrayList;
imp
浏览 20提问于2019-04-17得票数 0
回答已采纳
1回答
我正在制作一个需要客户端-服务器消息传递的应用程序。我决定使用MINA。服务器运行良好(读取消息、激发事件和写入响应，就像在日志中一样)，但客户端似乎不会激发任何事件。它记录发送的消息、接收的字节数，但从不使用处理程序。未打印处理程序内部的任何调试消息。如何让messageReceived事件触发？ 我使用Linux服务器和1.8.0_212 java，MINA版本2.1.2，Kotlin版本1.3.30 val connector = NioSocketConnector()
connector.filterChain.addLast("logger", LoggingF
浏览 26提问于2019-05-06得票数 1
2回答
我正在使用带有SslFilter的Mina，配置为“所需的客户端身份验证”。
一旦建立了连接并进行了握手，如何从服务器上的IoHandler子类获取连接另一端对等方的证书(或主体)？
编辑：，换句话说，在握手和调用IoHandler.sessionOpened()之后，如何获得IoSession和主体之间的关系。
浏览 1提问于2011-07-25得票数 0
回答已采纳
我只是想创建一个简单的MINA服务器和客户端来进行评估。这是我的代码。
public class Server {
private static final int PORT = 8080;
static class ServerHandler extends IoHandlerAdapter {
@Override
public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
cause.printStackTrace();
}
@Ov
浏览 2提问于2011-06-21得票数 0
我和apache mina玩了几天，我想问你，我如何通过扩展(或实现) IoSession来创建像MyIoSession这样的东西。
我之所以要这样做，是因为在Handler类中，我想要这样的东西：
public class MyHandler extends IoHandlerAdapter{
public void messageReceived( MyIoSession session, Object message ) throws Exception
{
// here I have MyIoSession instead of IoSession w
浏览 3提问于2011-08-03得票数 2
回答已采纳
2回答
今天早上，我问了一个与插座有关的问题，但这是另一种动物，所以我决定做一个单独的帖子。
我现在很清楚什么是套接字，以及它们的用途。我试图了解它们与Java、Java以及所谓的Netty或MINA之类的网络API之间的关系。
套接字是所有基于Java的网络的基础吗? NIO是否是基于Java的网络的基础(也就是说，是API为更高的框架(如Netty或MINA)提供套接字结构)？如果不是，那么Java网络功能的基础是什么？
是否可以使用套接字(据我理解，或网络层构造)发送(按字节计算)符合较高协议的消息，如TCP或UDP、HTTP、FTP等？如果是这样的话，我可以想象开发团队可能会创建自己的
浏览 7提问于2011-01-24得票数 2
回答已采纳
2回答
我在我的开源项目中使用Apache MINA。然而，我遇到了一个性能障碍，它无法处理从移动设备上传到服务器的大量有效负载。出现内存不足错误。我从来没有使用过Netty，并且希望用Netty交换MINA。
我对Netty团队的问题是，Netty在大容量传入有效负载下的性能如何。在我的性能测试中，我使用1000个并发设备生成负载，每个设备发送1MB大小的有效负载。它倾向于在5分钟内产生1GIG的上传数据。这种负载往往会破坏MINA。
Netty能否支持这种负载以及更多负载。非常感谢您在这方面的投入。
顺便说一句，我确实使用JProfiler分析了应用程序。它确实指出了MINA堆栈是罪魁祸首。我甚至
浏览 3提问于2012-10-23得票数 12
1回答
我一直在使用Apache MINA，正在学习Netty。我过去使用过MINA累积编码器/解码器，我很有兴趣看看Netty是否有类似的功能。我看了看API，什么也没看到。
浏览 1提问于2012-03-27得票数 1
在中，MINA和netty之间有一个非常丰富的比较，我想知道当平台是Android时，您的偏好！
我有一个主机，它可以接受来自android设备的连接，也可以建立到android设备的连接。
此主机为其操作实现Boost.ASIO。我需要为android端选择一个简单的框架。
基于几个小时的谷歌搜索，我对java相当陌生，仅限于MINA和netty。两者似乎都很好，尽管网络似乎更容易。
当我读到一些关于在android中使用netty的bug报告时，我感到很困惑。
连接到主机的android模拟器的数量可以增长到大量。
所以问题很简单：哪一种更适合使用: netty
浏览 2提问于2013-04-22得票数 7
2回答
我有一个主Mina处理程序线程正在处理，在这个线程中，我创建了另一个线程，并将其设置为休眠指定的时间。现在我想让这个内部线程独立休眠，而不阻塞Handler线程。以下是示例代码。
public void messageReceived(IoSession session, Object message) throws Exception {
Integer tts = 5000;
Thread sleepThread = new Thread(obj);
sleepThread.sleep(tts);
}
当前它正在阻塞主处理程序线程。
浏览 2提问于2013-04-23得票数 0
2回答
我对新的java套接字NIO做了一些研究。我正在使用MINA构建一个模拟服务器，它接受来自许多客户端(大约1000个)的连接，并处理从它们接收的数据。我还设置了客户端模拟器，它创建了大约300个客户端连接，并使用线程将数据发送到服务器。并且结果是一些连接被服务器中止。代码如下
try {
listener = new NioSocketAcceptor(ioThread);
listener.getFilterChain().addLast("codec", new ProtocolCodecFilter(new MessageCodecFactory()));
浏览 0提问于2010-11-22得票数 1
2回答
这里我正在读取二进制数据，但这给了我"java.lang.ClassCastException: java.lang.String不能转换为org.apache.mina.core.buffer.IoBuffer“
IoBuffer buffer = (IoBuffer)消息；该行中的 //异常
IoAcceptor acceptor = new NioSocketAcceptor();
acceptor.getFilterChain().addLast("logger", new LoggingFilter());
a
浏览 0提问于2015-12-30得票数 0
1回答
我尝试使用Apache Mina进行TCP/IP通信。在我的例子中，我必须发送长文本消息，如下所示：
0400F23A40010881800200000040000000001623334444555566665000990000005670000725090909999999090909072507306011040001ab9999999999ab9999999999999028000008389999999900000056700036003110000002001000010725090909000000000000000000
但当我尝试发送它时，我的TCP服务器无法在控制台中显示该
浏览 1提问于2016-02-16得票数 0
想法是将apache vysper集成到现有的netty应用程序中。有没有可能从客户端以mina ChannelBuffer的身份连接到netty，这样它就可以脱离到vysper了？
想法是为apache vysper制作自定义的基于netty的端点，获取ChanellBuffer并将其传递给vysper。
浏览 6提问于2012-08-20得票数 0
回答已采纳
我正在写一个基于quickfixj的修复买方GUI。虽然性能对GUI来说不是问题，但我正在考虑将quickfixj从Mina迁移到Netty，因为我想把它开发成一个买方引擎。quickfixj的性能对我并不满意。据说Netty的表现比Mina好。
有没有人知道Java平台上还有其他开源修复引擎(因为quickfixj中有很多bug)？我想知道哪个是更好的选择，迁移还是其他修复引擎？
浏览 2提问于2010-09-30得票数 1
回答已采纳
我需要在我的应用程序中运行两个服务。一个是基于文本协议的套接字服务器，另一个是基于http协议的服务器。对于套接字服务器，我使用Apache MINA作为NIO框架，而对于http协议，我希望使用Netty HTTP实现。
我考虑过合并到一个框架( Netty )中，但是当涉及到处理大负载时，我发现Netty有一些性能问题。MINA (2.0.7)在处理套接字服务器上的负载方面做得很好。我还研究了HTTP服务器上的MINA AsyncWeb，但这个项目似乎已经失败了。
我的问题是，有没有人遇到过这种架构困境。是否可以在不同的套接字上运行同一个JVM中的两个框架，或者是否有一些我不知道的问题。
浏览 1提问于2012-12-22得票数 0
回答已采纳
我有一个基于Apache Mina 2.0.4的应用程序，其中我使用ExecutorFilter在message_received事件上创建线程。
我发现在生产环境中，在某些时候，ExecutorFilter不会创建线程。相反，它会阻止请求消息。
谁能指导一下如何正确使用ExecutorFilter？我希望有100个同时连接到我的应用程序。
这是我的类，它覆盖了ExecutorFilter类
public class OneIExecutorFilter extends ExecutorFilter {
public OneIExecutorFilter(IoEventType...
浏览 0提问于2011-06-28得票数 1
回答已采纳
2回答
是否有基于Java NIO或某些Java NIO框架(Netty、MINA等)的Java RTP/RTCP库？
浏览 2提问于2010-07-07得票数 3
回答已采纳
我正在尝试在fuse esb上使用apache mina和camel。我正面临一个部署问题。
这是我的路线：
<beans xmlns...
<bean id="myCodec" class="test.net.mina.codec.MyMinaCodec" />
<camelContext xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="mina:tc
浏览 1提问于2012-03-14得票数 0
回答已采纳
我正在为一个网络应用程序使用Mina V2.1.3；特别是我有一个Udp会话问题:我想通过udp将消息发布到某些接收者的特定"ips“和”端口“。但是我不知道(我也不关心)这些接收器是否真的在监听它们的端口，并且真的收到了包。 如果没有接收器在监听它的端口，Mina将收到一个ICMP-Package返回，这意味着该端口是无法到达的。米娜注意到这个包并抛出了一个UnreachablePortException。然后Mina关闭session对象并停止发送。我的目标是忽略“无法到达目的地”的数据包，因此我仍然希望发送udp数据包(“即发即忘原则”)。 这是我的方法(某种伪代码)：
浏览 19提问于2020-10-16得票数 0
我正在开发一个基于Java的FTP服务器，可以嵌入到另一个项目中。我正在为FTP服务器使用Apache库。我可以启动服务器，但是当我试图连接到它时，我会得到以下错误：
Exception in thread "pool-1-thread-1" java. lang.IncompatibleClassChangeError
at org.apache.mina.core.filterchain.DefaultIoFilterChain.register(DefaultIoFilterChain.java:276)
at org.apache.mina.core.filtercha
浏览 0提问于2018-06-18得票数 1
1回答
我在测试中使用mina，服务器和客户端都在同一台计算机上运行，客户机和服务器运行时不会抛出异常，但是服务器不能接收消息。代码是
public class SmsClient extends IoHandlerAdapter {
private final static Logger logger = LoggerFactory.getLogger("sms");
private IoSession session;
private IoConnector connector;
public SmsClient(final String p
浏览 2提问于2014-11-20得票数 0
回答已采纳
1回答
使用Java重写二进制流
、、、
我一直在研究Netty和Mina，但对于重写二进制流的最佳方法感到困惑。例如，我想创建一个代理，它将允许XML的替换和转发。
我很欣赏这些例子。
浏览 1提问于2009-06-24得票数 0
回答已采纳
我想知道，我们有没有让开发变得更容易的框架/库？例如，Apache Mina或Netty使NIO编程变得更容易。
我听说过Spring JMX，MX4J，它们很容易使用吗？
浏览 4提问于2012-02-25得票数 3
1回答
我在我的一个项目中使用Apache mina。每次接收到数据块时都会调用CumulativeProtocolDecoder的CumulativeProtocolDecoder()。我将这些块连接在一起，直到在字符串的末尾得到一个特殊的字符。因此，当我收到$作为第一个字符时，我开始连接，当我收到另一个$字符时，我开始连接。
我希望使连接部分同步，以避免任何潜在的非预期的连接。
通过用同步()子句封装连接块，我可以使这个操作线程安全，但我的问题是，当一个线程忙于连接，另一个线程用新数据调用doDecode()时，作为doDecode()参数提供的新信息会因为同步块繁忙而丢失，还是等待并保持参数缓存
浏览 0提问于2018-08-28得票数 0
我在和Netty和ant一起做一个应用。当我编译它时，没有错误。但是当我尝试运行jar文件时，它得到以下消息：
Exception in thread "main" java.lang.NoClassDefFoundError: org/jboss/netty/channel/ChannelFactory
Caused by: java.lang.ClassNotFoundException: org.jboss.netty.channel.ChannelFactory
at java.net.URLClassLoader$1.run(URLClassLoade
浏览 6提问于2012-07-02得票数 1
2回答
关于@具有接口的重写的有趣问题
、、、、
在实现接口方法的方法上，用@Override注释编译类文件得到了一个有趣的问题。
我试图在eclipse中设置并获得编译错误。
Description Resource Path Location Type
The method decodable(IoSession, IoBuffer) of type PubAckDecoder must override a superclass method PubAckDecoder.java /moquette-parser/src/main/java/org/dna/mqtt/moquette/proto line 22
浏览 4提问于2013-04-11得票数 1
1回答
STOMP协议的突变？
、、、
我正在尝试使用Java客户端库连接到RabbitMQ。
斯坦比示例有两个参考实现-- Mina和Netty。
这些在RabbitMQ中使用是正确的，还是我必须为RabbitMQ实现另一个RI？
浏览 1提问于2015-07-25得票数 0
回答已采纳
2回答
为什么需要处理消息的碎片
、、、、
消息的分段是在IP上完成的，所以我必须在应用层处理它。比如mina或者netty？
消息的碎片将是正确的顺序，对吗？
所以任何解码器都不需要处理任何顺序问题，对吗？
浏览 0提问于2012-10-21得票数 1
2回答
我对Apache mina和websocket通信有问题。
握手工作正常，我与服务器建立了有效的连接，但是如果我的客户端向服务器发送一个字符串，字符串就会收到，但我不能在控制台中显示它们。
public void messageReceived(IoSession session, Object message) throws Exception {
System.out.println(message.toString());
if(message.toString().length() > 20 && message.toString().substring(0, 1
浏览 1提问于2013-07-18得票数 0
1回答
我目前正在编写一个测试/模拟软件，该软件将模拟使用专有TCP/IP协议的通信客户端的特定行为。为了模拟断开的连接，我只想将一个打开的客户端套接字踢出列表。经过一些研究后，我发现iphlpapi中的SetTcpEntry方法可以实现这一点。我已经使用JNA在Java中成功地实现了这种方法。但是，即使我以管理员身份运行我的模拟软件，SetTcpEntry调用也会返回317。从它的文档中，我发现这表明程序正在以非提升的方式运行。但是从其他一些解释如何手动检查UAC提升的doc中读取，我知道程序正在运行提升。有没有人在这种电话中遇到过类似的问题？我该如何解决这个问题呢？也许还有其他方法可以摆脱我的插
浏览 44提问于2021-09-15得票数 1
1回答
-编辑下面
我实际上正在实现ProtocolCodecFilter的Mina，以便接收来自串行设备的消息。
编解码器指定了多个不同的消息(以及它们的pojos)，即使您的实现在99%的情况下正确工作，我也遇到了一种消息类型的问题:没有固定长度的专用消息。我知道最小长度，但永远不知道最大长度。
这是我收到的异常消息(只是重要的部分)：
org.apache.mina.filter.codec.ProtocolDecoderException: org.apache.mina.core.buffer.BufferDataException: dataLength: -2143812863 (Hex
浏览 4提问于2014-11-07得票数 1
回答已采纳
我想要将soap tcp服务连接到tcp端点。tcp端点必须是接受客户端的tcp套接字服务器。
现在我有一个例子，例如这条路线
<from uri="cxf:bean:myendpoint" />
<to uri="netty:tcp://localhost:port" />
这不管用，因为我发现
<from uri="netty:tcp://localhost:port" />这会将其配置为客户端可以连接的服务器套接字
<to uri="netty:tcp://localhost:port&#
浏览 0提问于2013-12-06得票数 1
1回答
您好，我是开放的决定，选择Netty或Mina为我的TCP/UDP服务器，我是两个框架的新手，不知道他们中的任何一个支持(S) P2P转换，以便一些海量的数据处理可以更有效地处理？
如果有，有没有关于这两个框架的这个主题的教程或材料？
谢谢
浏览 5提问于2015-06-15得票数 0
2回答
有几个高质量的框架隐藏了基于NIO的网络编程的复杂性(mina、netty、grizzly等)。是否有类似的框架可以简化基于NIO的文件系统编程？
例如，作为一个学习练习，我想在此基础上实现一个磁盘支持的Map (太棒了！)文章：。
浏览 1提问于2009-07-15得票数 2
回答已采纳
我有一个应用程序，它由服务器和客户机两部分组成。
它的工作方式如下：
客户端连接到服务器并发送一个字符串；服务器接收该字符串并返回包含10000个元素的ArrayList (通过转换字符串)。
我编写了一个类(ClientConnector.java)，它模拟许多客户机，使用一个连接从服务器获取这10000个元素。
当我运行这两个程序时，服务器端是可以的。但是在客户端，使用的堆总是在增加！我试图用"null“来释放使用过的对象，但是使用的内存仍然越来越大。
我的服务器端代码: Client.java
公共类客户端{
private static final int PORT = 75
浏览 2提问于2012-12-04得票数 0
1回答
对Netty有些奇怪的行为。我正在尝试连接到一个后端，该后端讨论自定义协议，并且是用Mina1.1.7编写的(关于它的价值)。
我有这样的代码：
ChannelFuture cFuture = client.connect(new InetSocketAddress("localhost", 8081));
cFuture.awaitUninterruptibly(5000);
if(!cFuture.isSuccess()) {
return;
}
到服务器的连接失败。我试着打电话到同一个位置，然后连接就建立起来了。
我还有同样
浏览 6提问于2012-03-12得票数 0
2回答
我有一个定义如下的ANT任务：
<javac source="1.5" target="1.5" srcdir="${src.dir}" destdir="${classes.dir}" deprecation="on" debug="on" classpathref="classpath" fork="true" memoryMaximumSize="512m" encoding="UTF-8">
<
浏览 1提问于2011-10-14得票数 0
1回答
集群中两个节点之间的通信
、、、、
我想弄清楚这是怎么回事：
通过NIO/BIO进行客户端服务器通信
通过JGroups进行服务器-服务器通信(复制、成员身份等)(数据复制会很痛苦吗？)
您的建议是什么，使用这种架构的利弊，为什么选择jgroup，任何替代方案？
我应该使用本地NIO，还是使用Mina或Netty之类的库？
更新
不休息，这不是一个网络服务器。我正在建立一个像分布式数据库一样的发电机。
activeMQ就像我想的那样，在这里我会有一个单一的故障点。JGroups解决了这个问题，对吗？
浏览 0提问于2011-02-12得票数 2
我正在使用Apache Mina (Mina2 - Netty不可用-不要问为什么:P)来创建一个TCP客户端，它通过TLS连接到TCP服务器。
下面是SSLContext：
下面是我的blueprint xml路由：
<route id="ReadMQ">
<from uri="jmsep://topic:test/014/data" />
<process ref="readIt"></process>
<to
浏览 2提问于2015-12-10得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
