String.class, s -> { /*fails*/ //"akka.tcpvoid main(String[] args) { ConfigFactory
.parseString("akka.remote.netty.tcp.port= 2500"
浏览 1提问于2019-01-28得票数 1
回答已采纳
1回答
2017 17:28:05.543] [run-main-0] [akka.remote.Remoting] Remoting started; listening on addresses :[akka.tcp31/2017 17:28:05.556] [run-main-0] [akka.tcp31/2017 17:28:05.648] [run-main-0]
[akka.cluster.Cl
浏览 4提问于2017-10-31得票数 1
回答已采纳
Process 1具有以下app.hocon： actor{ }
dot-netty.tcp.port = 1111}Process 2具有以下app.hocon： actor{ }
dot-netty.tcp.port= 2222
dot-netty.tcp.hostname = "l
浏览 1提问于2020-03-06得票数 2
回答已采纳
">tcp://localhost:61616</connector> </connectors> <acceptor name="
浏览 19提问于2021-10-11得票数 2
回答已采纳
1回答
Akka中的聚类
、、
actor { } log-remote-lifecycle-events = off port = 0 }
seed-nodes = [
"akka.tcp://ClusterSystem@127.0
浏览 0提问于2019-01-21得票数 0
我收到了udp数据，使用netty4.0作为flume源，使用本地传输，替换为Epoll*类。Error writting to channel", ex); }
// class to handle incoming Netty
浏览 0提问于2016-06-14得票数 0
xmlns="http://camel.apache.org/schema/spring"> </get> <from uri="direct:fooService"/
浏览 0提问于2016-02-29得票数 1
1回答
我是Java套接字编程和Netty的初学者。目前，我们有一个应用程序，它使用纯Java套接字连接，通过自己管理套接字的健康状况。
我想了解netty是如何管理套接字的？港口将开放多长时间？Netty是如何维护tcp会话的？
浏览 0提问于2014-03-19得票数 1
回答已采纳
示例路由：
from("netty:tcp://localhost:7000?:tcp://localhost:7001?:tcp://localhost:7002?:tcp://localhost:7003?:tcp://localhost:7004?
浏览 0提问于2013-06-12得票数 1
回答已采纳
1回答
provider = "akka.cluster.ClusterActorRefProvider" remote { netty.tcp { port = 0 } seed-nodes= [
"akka
浏览 3提问于2016-07-04得票数 1
我从客户端得到一个get压缩的内容，我需要在它到达控制器之前解压它，否则我会得到一个jackson解析异常。 @Override return request.getBody().map(requestDataBuffer -> { GZIPInputStream gzipInputStream = new GZIPInputStream(req
浏览 0提问于2019-12-12得票数 1
我在生产者模式下使用Apache Camel netty4组件，端点配置如下： <...><to></to>
当有消息要发送时，这里的netty端点充当TCP客户端，懒惰地启动到指定套接字的连
浏览 145提问于2018-05-31得票数 2
3回答
如何在一台pc上运行多个akka节点？目前，我在我的application.conf文件中如下所示。对于每个系统，我添加了不同的端口号，但是，我不能启动多个实例。错误显示，Address already in use failed to bind。remotelookup { remote.server.port = 2500 }更新:多个akka节点意味着，我有不同的独立服务器应用程序，它将
浏览 0提问于2013-07-11得票数 4
回答已采纳
= new NettyJaxrsServer();
netty.setPort(port); netty.setSecurityDomain(null);
netty.setIoWorkerCount(16be identified, non-owne
浏览 2提问于2016-05-17得票数 0
回答已采纳
1回答
我有以下路线：我正在使用akka-camel模块，其中：netty4:tcp://localhost:8000?textline=trueCaused by
浏览 3提问于2016-11-07得票数 0
Caused by: org.jboss.netty.channel.ChannelException: Failed to bind to: /127.0.0.1:2552 } } enabled-transports = ["akka.remote.netty.tcp"]
浏览 1提问于2016-05-25得票数 0
actor { } transport = "akka.remote.netty.NettyRemoteTransport"
netty.tcp {
port =2552://kC
浏览 0提问于2018-07-04得票数 1
回答已采纳
日志还显示客户端发送了多条相同的消息： 14:25:04.394 [reactor-tcp-nio-2] DEBUG reactor.netty.tcp.TcpClient - [id: 0x3d2ab8be14:25:04.529 [reactor-tcp-nio-3] DEBUG reactor.netty.tcp.TcpServer - [id: 0xf6dd2f6d, L:/127.0.0.1:4059- R:/127.0.0.1:52044] READ CO
浏览 84提问于2019-12-20得票数 3
回答已采纳
步骤1:在服务器关闭时启动客户端16:02:35.560 [reactor-tcp-nio-2] DEBUG reactor.netty.resources.DefaultPooledConnectionProvider重新连接工作
16:08:31.359 [reactor
浏览 29提问于2020-12-13得票数 1
actor {}enabled-transport = ["akka.remote.netty.tcp"]hostname = "127.0.0.1"}}class LocalActor extendsprovider = "
浏览 2提问于2014-11-04得票数 0
回答已采纳
云服务器
ICP备案
对象存储
腾讯会议
云直播
腾讯云开发者
