AMQP 1.0 Qpid BytesMessage大负载

Question

我正在使用qpid客户端Java库（版本0.32）来集成AMQP 1.0。

我必须传输一个字节数组（小于5mb），但此消息从未传递给订阅者。我通过wireshark记录了帧，传输帧标记为[TCP窗口已满]。库可能没有划分负载。代码是否正确？我必须配置什么？

代理：Apache Apollo 1.7.1（默认配置）

pom。xml

    <dependency>
        <groupId>org.apache.geronimo.specs</groupId>
        <artifactId>geronimo-jms_1.1_spec</artifactId>
        <version>1.1</version>
    </dependency>
    <dependency>
        <groupId>org.apache.qpid</groupId>
        <artifactId>qpid-amqp-1-0-client-jms</artifactId>
        <version>0.32</version>
    </dependency>
    <dependency>
        <groupId>org.apache.qpid</groupId>
        <artifactId>qpid-amqp-1-0-client</artifactId>
        <version>0.32</version>
    </dependency>
    <dependency>
        <groupId>org.apache.qpid</groupId>
        <artifactId>qpid-amqp-1-0-common</artifactId>
        <version>0.32</version>
    </dependency>

Java代码

  ConnectionFactoryImpl amqpFactory = new ConnectionFactoryImpl(...);
  ConnectionImpl connection = amqpFactory.createConnection();
  connection.start();
  SessionImpl session = connection.createSession(...);

  MessageProducerImpl producer = session.createProducer(new TopicImpl("topic://test"));
  BytesMessageImpl bytesMessage = session.createBytesMessage();

  //generate sample data
  StringBuilder s = new StringBuilder();
  for (int i = 0; i < 10000; i++) {
       s.append(UUID.randomUUID().toString());
  }

  bytesMessage.writeBytes(s.toString().getBytes());
  producer.send(bytesMessage);

Answer 1

所以你基本上已经登陆了我所知道的AMQP软件的每一个弃用部分，所以我猜你的问题来自一个旧的和未维护的软件。

ActiveMQ Apollo已经被弃用了好几年，因为它没有维护，相反，您应该使用ActiveMQ Artemis，它是ActiveMQ项目中最活跃的代理。

对于AMQP 1.0 JMS客户端，应使用实现当前AMQP的Qpid JMS客户端-