将消息从Kafka路由到连接到应用服务器群集的web套接字客户端
我想找出将消息从Kafka路由到连接到负载平衡应用服务器集群的web套接字客户端的最佳方法。我知道spring-kafka有助于消费和发布消息到kafka主题，但是当连接到分布式kafka主题时，这在负载平衡的应用服务器场景中如何工作。以下是我希望满足的需求，其总体目标是在具有非常非常大的用户量的应用程序中促进对等消息传递：
-
null
我认为，应用服务器负载平衡可以通过将具有特定路由密钥的用户（用户以'a'等开头）记录到特定的应用服务器上来工作，然后只为该应用服务器上以'a'开头的用户使用消息。但这似乎很难维护，并使自动伸缩变得非常困难。这似乎应该是一个常见的场景来实现，但我找不到任何适合这种场景的工具或方法。
共有1个答案
听起来每个消费者都应该生活在自己的消费群体中。这样，所有可用的使用者都将使用发送到该主题的所有消息。因此，所有连接的websocket客户机都将收到这些消息。
如果您在使用这些消息后需要更复杂的逻辑，例如过滤、路由、转换、聚合等，您应该考虑在项目中涉及Spring集成：https://Spring.io/projects/spring-integration
-
首先我要感谢你花时间... 我在macbook中用C++创建了一个服务器套接字，在运行windows XP的不同机器中用Java创建了一个客户机/套接字。我已将端口指定为5000，但无法指定正确的主机，因此无法进行连接。当我在windows xp中使用WinSock2创建一个C++服务器/套接字时，当我使用本地主机时，连接是完美的...有什么想法吗？？？ 提前Thnx int main（int a
-
Java： 在C#中-它停止在“receiver=listener.accept（）；”在java（android）中-它停止于“sender_socket=new Socket(serverAddr,SERVERPORT）；”这应该是java套接字函数的问题--需要另一个函数连接到C#-server。
-
当我尝试使用套接字将物理设备连接到服务器时，我遇到了一个问题。在服务器端，它似乎不接受任何连接，而在客户端，套接字超时。你知道为什么会这样吗？ 我在下面提供我的代码 服务器代码： 客户端: 11-16 23:32:11.016:W/系统。错误（24213）：java.net。ConnectException:无法连接到/192.168.1.116（端口9090）：连接失败：ETIMEDOUT（连接
-
如何使用套接字将Swift客户端连接到Java服务器？如何在客户端和服务器之间发送不同的数据类型？
-
我正试图从套接字服务器（Java）向套接字客户端（Python）发送一个映像，但客户端中接收到的映像大小不正确，无法打开。我不知道我做错了什么。有什么建议吗？
-
我想在由安全kafka集群的kafka主题支持的Flink SQL表上执行一个查询。我能够以编程方式执行查询，但无法通过Flink SQL客户端执行。我不知道如何通过Flink SQL客户端传递JAAS配置（）和其他系统属性。 FlinkSQL以编程方式查询 这很好。 通过SQL客户端Flink SQL查询 运行此命令将导致以下错误。 中没有任何内容，除了以下注释 SQL客户端运行命令 Flink