标签: multiplexing

我正在使用HttpClientJava 11 将请求发布到 HTTP2 服务器。HttpClient 对象被创建为一个 Singleton Spring bean，如下所示。

@Bean
    public HttpClient getClient() {
                return HttpClient.newBuilder().version(Version.HTTP_2).executor(Executors.newFixedThreadPool(20)).followRedirects(Redirect.NORMAL)
                .connectTimeout(Duration.ofSeconds(20)).build();
    }

I am using the sendAsync method to send the requests asynchronously.

When I try to hit the server continuously, I am receiving the error after certain time "java.io.IOException: too many concurrent streams". I used Fixed threadpool in the Client building to try to overcome this error, but it is still giving the same error.

The Exception stack is..

java.util.concurrent.CompletionException: java.io.IOException: …

我一直在谷歌上搜索，似乎找不到这个问题的直接答案，有些人提供了矛盾的答案。

大多数浏览器对每个域有 6 个连接限制。例如，如果您的网站是 example.com，并且它在页面加载时初始化持久的服务器发送事件连接，那么最终用户可以再打开该选项卡五次，但第六个选项卡根本不会加载，因为 6已达到该域的持久 TCP 连接。

现在，我看到有些人说这只是 SSE 的一个长期存在的问题，唯一的替代方案是黑客解决方法，涉及检测此连接限制，然后关闭隐藏选项卡中的连接或关闭这些选项卡中的连接并切换到长轮询。

然而，有些人声称 HTTP2 通过多路复用解决了这个问题，这样您就可以在该网站上打开任意多个选项卡，因为所有选项卡都多路复用到同一个 TCP 连接上。我找不到这种说法的主要来源，也找不到任何具有重要权威的人。

那么，这是真的吗？HTTP2复用是否解决了网站域名常见的6个连接限制问题？或者，如果他们想支持其网站的许多打开选项卡，那么基本上需要使用 websockets 吗？

我有一个使用JMF的项目,并在短时间内(几秒到几分钟)记录网络摄像头和音频输入,然后将结果写入文件.

我的项目的问题是该文件永远不会正确生成,无法播放.

虽然我已经找到了很多关于如何通过RTP进行音频和视频多路传输,或者将输入文件从一种格式转换为另一种格式的例子,但我还没有看到一个捕获音频和视频的工作示例,并将其写入到一个文件.

有没有人有一个功能代码的例子来做到这一点？

当多路调用多个子对象时,什么是阻止循环样板代码的优雅方法？

问题描述示例:

struct Foo {
  void Boo();
  void Hoo();
  bool IsActivated();
};

struct FooAggregator {
  ...
  void Boo();
  void Hoo();
  ...
  std::vector<Foo> m_foos;
};

FooAggregator::Boo() {
  for(size_t i=0, e=m_foos.size(); i!=e; ++i) {
    if(m_foos[i].IsActivated()) {
      m_foos[i].Boo();
    }
  }
}

FooAggregator::Hoo() {
  for(size_t i=0, e=m_foos.size(); i!=e; ++i) {
    if(m_foos[i].IsActivated()) {
      m_foos[i].Hoo();
    }
  }
}

如您所见,FooAggregator实现与单个Foo相同(相似)的接口,迭代调用其各自成员函数的所有Foo对象.

正如您所看到的,迭代循环是完整的样板,为FooAggregator的每个成员函数重复.

从FooAggregators成员函数的实现中删除样板的优雅方法是什么

我正在实现一个 fastcgi 应用程序，在阅读 fastCGI 规范后，我发现了一个名为“请求多路复用”的功能。它让我想起 Adob​​e RTMP 多路复用协议在协议是专有的和封闭的时代。

据我所知，多路复用允许减少创建到 FCGI 客户端的新连接的开销，有效地交织请求块，同时启用“保持活动”模型连接。后者允许通过单个连接发送多个请求。

第一个问题是我做对了吗？

接下来是 - 经过一些谷歌搜索后，我发现没有实现 FCGI 多路复用的服务器，我首先对“流行”服务器感兴趣，我的意思是 nginx 和 lighttpd。我什至发现了一些关于弃用 FCGI 请求多路复用的讨论。

所以问题是 - 是否有任何服务器支持此功能？

我正在寻找一种将 mjpeg（压缩）视频数据混合到 mp4 或 avi 等视频容器中的方法。（将来我还需要添加音频）。由于我也在项目的其他部分使用 FFMPEG，如果可能的话，我想使用这些库来完成它。我不是在寻找命令行 FFMPEG 使用！我尝试使用 ffmpeg 中的多路复用示例，但我只能创建一个包含视频信息的（非常大的）.mjpeg 文件。这不是我要找的。

示例将非常受欢迎，但指向正确方向的指针也有效！

编辑：我已将 yuvj422p 流输出到 jpeg 图像，我想将其放入 mp4 容器中。使用 ffmpeg 命令行可以正常工作：

ffmpeg -i yuvy%01d.jpg -vcodec mjpeg out.mp4 

我想直接在我的代码中执行此操作（当然不首先创建 jpeg 图像）

我对Netty很陌生,但是当一些协议(例如P1和P2)封装在另一个协议中时,如何在Netty 4.x中实现一个案例呢？

              +-------------+
              |   decoder   |
              +-------------+
              |   encoder   |
              +-------------+
              |    muxer    |
              +-------------+
              |   demuxer   |
              +---+------+--+
                  |      |
                  |      |
           +------+      +------+
           |                    |
           |                    |
           v                    v
    +-------------+      +-------------+
    | P1 decoder  |      | P2 decoder  |
    +-------------+      +-------------+
    | P1 encoder  |      | P2 encoder  |
    +-------------+      +-------------+
    | P1 handler  |      | P2 handler  |
    +-------------+      +-------------+

有没有办法创建嵌套管道,因此decoder<->encoder<->muxer<->demuxer作为主管道将根据分路器的决定沿P1或P2管道发送数据？

或者也许有一种方法以某种方式创建(为了清晰起见)"subchannels"与自己的管道？

我正在开发一个需要实时通信和文件上传的应用程序。我最好是通过多路复用通道的单个连接来完成。我看到websocket协议有一个扩展，以允许多路复用，但是我认为还没有浏览器支持（如果有）。我不知道如何使用它。

我想用Java开发服务器。用于socketio的节点服务器在名称空间上出现了一个奇怪的错误，而Java服务器在名称空间上无法正常工作。

我想要一个简单的多路复用系统，以便可以同时发送一些json和二进制文件。为此是否存在某些东西，或者我需要自己创建一些东西，如果有的话..我应该从哪里开始？

我正在构建一个webapp，并通过http2进行服务。但是，当我在Google Chrome浏览器（版本59.0.3071.115（正式版本）（64位））的开发人员工具中分析网络时，很明显，多路复用不起作用，因为只有6个活动连接（例如http1.1）其余的连接排队。

为什么是这样？还是我的期望不正确？

屏幕截图（您可以看到该协议为http2）：

更新＃1：

• 后端在nginx 1.13上运行；
• 我正在使用自定义模块加载器，该加载器一次加载所有脚本（通过async在循环中创建带有属性的脚本标签）；
• 屏幕截图显示，对于第8行及以后的浏览器，浏览器已收到开始下载资源的请求，但是该行的白色部分显示此脚本已排队，并且仅在插槽可用时才开始实际下载（请参见第8、7和9行）一旦完成第2、3和4行，便开始加载；第11、12、13和5、6、7行也是如此。

服务器代码：

            TMultiplexedProcessor processor = new TMultiplexedProcessor();

            processor.registerProcessor(
                "AddService",
                new AddService.Processor(new AddHandler()));

            processor.registerProcessor(
                "MultiplyService",
                new MultiplyService.Processor(new MultiplyHandler()));

            TServerTransport serverTransport = new TServerSocket(7911);



            TSimpleServer server = new TSimpleServer(new TSimpleServer.Args(serverTransport).
                   processor(processor));

            System.out.println("Starting server on port 7911 ...");
            server.serve();

客户代码：

    TFramedTransport transport;

   transport = new TFramedTransport(new TSocket("localhost", 7911));  
   transport.open();  


   TProtocol protocol = new TBinaryProtocol(transport);

   System.out.println("1");
   TMultiplexedProtocol mp = new TMultiplexedProtocol(protocol, "AddService");
   AddService.Client service = new AddService.Client(mp);

   System.out.println("2");
   TMultiplexedProtocol mp2 = new TMultiplexedProtocol(protocol, "MultiplyService");
   MultiplyService.Client service2 = new MultiplyService.Client(mp2);

   System.out.println("3");

   System.out.println(service.add(2,2));
   System.out.println(service2.multiply(2000,200));

但是当我运行服务器（侦听端口 7911）和客户端时，客户端不会处理对加/乘函数的最后两次调用。

我可以调试参数已发送到服务器，但服务器无法处理它们。 …