Blob消息的ActiveMQ连接Url

Question

我的应用程序有一个远程ActiveMQ服务器和嵌入式ActiveMQ服务器。当我发送文本消息时，它正在工作。但是当我尝试发送Blob消息时，它会抛出一个javax.jms.JMSException，由java.net.MalformedURLException和java.lang.NumberFormatException引起。

我的经纪商网址

String broker1 = "tcp://localhost:7005?jms.blobTransferPolicy.defaultUploadUrl=http://localhost:61617";

其中< code > TCP://localhost:7005 是嵌入式代理，而< code > http://localhost:61617 是远程代理。

我的生产者代码

File file=new File("C:/Users/xxx/Downloads/1234.txt");

ActiveMQConnection connection = ActiveMQConnection.makeConnection(broker);
connection.start();
ActiveMQSession session = (ActiveMQSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// Create the destination (Topic or Queue)
Destination destination = session.createQueue("test");
MessageProducer producer = session.createProducer(destination);

BlobMessage message = session.createBlobMessage(file);
System.out.println("upload started");
producer.send(message);
System.out.println("upload finished");
session.close();
connection.close();

Answer 1

URL应该是这样的< code > embededbroker？JMS . blobtransferpolicy . defaultuploadurl = external URL

如果嵌入式URL失败，则外部URL将used.By默认的Activemq在此链接中提供文件服务器超文本传输协议：//（Activemq服务器ip）： portnumber/fileserver

例如，如果在本地主机网址上运行的 activemq 服务器应 http://localhost:8161/fileserver/ 它

它支持HTTP或FTP或SCP或其他点对点协议。