问题标签 [akka-tcp]

问问题

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

4 问题
Newest
Active
Bountied
318
Unanswered
0 投票
1 回答
218 浏览

java - AKKA TCP：由于队列已满而丢弃写入

我使用 akka-tcp 连接到 TCP 服务在非常并发的请求中，服务崩溃并出现以下异常：

我尝试根据这篇文章增加我的服务器读写套接字缓冲区：

https://www.cyberciti.biz/faq/linux-tcp-tuning/

但我的问题仍然存在

0 投票
0 回答
103 浏览

scala - akka tcp server-client heartbeat message block by scheduler 处理

我正在使用 Akka 集群（服务器）并每 5 秒使用 Akka TCP 与客户端交换 HeartBeat 消息。

HeartBeat 工作正常，直到我不使用调度程序。但是当我启动 4-5 个调度程序时，服务器没有从客户端（tcp 连接）接收到心跳缓冲区消息。调度程序处理后，我同时收到 4-5 条心跳消息。

Akka 调度程序正在阻止 Actor 的其他处理（缓冲区读取等）。

我已经在下面尝试过，但仍然面临同样的问题。

  1. 不同的 2 调度程序
  2. 创建了新的演员并在单独的演员中添加了调度程序调用。
  3. 使用8核机
  4. 试过fork-join-executor了thread-pool-executor
  5. 已经尝试更改Tcp-SO-ReceivedBufferSize为Tcp-SO-SendBufferSize1024 或 2048，但没有成功。
  6. 已经尝试过Tcp-SO-TcpNoDelay

请帮忙。

0 投票
1 回答
24 浏览

java - Akka-streams TCP - 使用不同的接收器消费

如何将连接的 Sink 切换tcp.bind()到 TCP Source？例如，假设我有：

目前，它将传入的字节保存到destination文件中。我想动态更改目标文件。如何使用 akka-streams 实现这一目标？

0 投票
0 回答
17 浏览

akka - AKKA 经典多接口连接

我正在使用 AKKA classic，但在某些机器上仍然必须使用 java 6，所以我的选择有限。我正在使用 Netty TCP。

我们的许多机器都是多接口机器，有时我需要一次连接多个机器。

根据我所知道的，我想我必须在第二个界面上创建第二个 ActorSystem 。在这方面，UDP 的工作方式似乎与 TCP 不同，因为您没有指定接口并且它会监听所有接口，据我所知。

执行此操作的预期方法是什么？


12345678910