Netty 框架 - 多端口监听

Question

我有以下问题。我为自己修改了这个例子： Webcam Capture Live Streaming Example

目前，通信看起来像 client1 将图像发送到服务器，然后将服务器的图像发送到 client2。如果我用一台相机工作就没有问题。如果我从两个不同的摄像机流式传输，就会出现问题。我希望 client1 将图像发送到特定端口上的服务器，并且仅在该端口上服务器将图像发送到 client.2 目前（我不知道为什么）服务器得到的情况，例如在端口 2000 上它发送到所有端口，而不仅仅是端口 2000。你能帮帮我吗？

来自服务器的一些代码：

@Override
public void start(SocketAddress streamAddress) {
    logger.info("server started:{}", streamAddress);
    Channel channel = serverBootstrap.bind(streamAddress);
    channelGroup.add(channel);
}

.

    this.serverBootstrap = new ServerBootstrap();
    this.serverBootstrap.setFactory(new NioServerSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()));
    this.serverBootstrap.setPipelineFactory(new StreamServerChannelPipelineFactory(new StreamServerListenerIMPL(), streamFrameListener));

.

public static void send(BufferedImage image) throws Exception {
    Object msg = h264StreamEncoder.encode(image);
    channelGroup.write(msg);
}

来自客户端 1 的代码：

public static void init(String host, int port) {
    Webcam webcam = Webcam.getWebcams().get(0);

    Dimension sizeVideo = WebcamResolution.QVGA.getSize();
    webcam.setViewSize(sizeVideo);

    StreamAtmAgent atmAgent = new StreamAtmAgent(webcam, sizeVideo);
    atmAgent.connect(new InetSocketAddress(host, port));
}

。 来自客户端 2 的代码：

public static void init(String host, int port, ImageListener il) {
    displayWindow.setVisible(true);
    logger.info("Ustawione wymiary :{}", dimension);
    StreamClientAgent clientAgent = new StreamClientAgent(il, dimension);
    clientAgent.connect(new InetSocketAddress(host, port));
}

你能帮帮我吗？如果您需要更多代码，请告诉我。

P.S 当我在启动服务器中做这样的事情时：

init("localhost",2000)
init("localhost",2001)

然后我将客户端 1 连接到端口 2000 的服务器，并将客户端 2 连接到端口 2001。我仍然可以看到来自端口 2000 的图像。

Answer 1

我的猜测是您的 channelGroup 在所有客户端的所有线程之间共享？在该 SET 中，您添加所有通道 - 无论他们正在监听哪个端口：

 Channel channel = serverBootstrap.bind(streamAddress);
 channelGroup.add(channel); //I guess all channels are added here

来自netty文档herewrite方法的答案：

将指定的消息写入该组中的所有通道。如果 指定的消息是 ByteBuf 的一个实例，它是自动 复制以避免竞争条件。对于 字节缓冲区。请注意，此操作是异步的，因为 Channel.write(Object) 是。

所以你基本上在这里channelGroup.write(msg); 你向所有频道发送相同的消息（图像）。您需要将端口 2000 的通道与端口 2001 上的通道分开。我认为您甚至不需要通道组。只需将端口 2000 的图像发送到为端口 2000 创建的通道。