我们能否通过队列发送 Java.net.Socket 对象并接收它,然后在将数据发送到客户端后进行一些操作并关闭 Socket 对象。
我尝试了序列化和反序列化,但我不确定序列化和反序列化是否支持套接字。
谢谢, 赫鲁什
最佳答案
由于 Java.net.Socket 类没有实现 Serializable,Producer 无法将其写入 Kafka 供 Consumer 使用。它不是 Serializable 的原因与你可能不想这样做的原因相同:一旦你构造了一个 Socket,你真的不能将对象本身传递到 JVM 之外并且仍然能够调用套接字.
话虽如此,您可以编写用于构造套接字的参数(例如,编写包含主机和端口的 Kafka 消息),然后让消费者使用该信息构造自己的套接字,然后与套接字交互.
关于java - 我们可以序列化 java 套接字对象以通过 Kafka 队列发送吗,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57657503/