我正在使用RabbitMQ Java API连接到RabbitMQ服务器。我想使用ConnectionFactory.setUri(...)
配置要使用的服务器。它似乎在破坏虚拟主机。
有一个默认的虚拟主机名为/
。
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import java.net.URI;
public class Worker {
public static void main(String[] argv) throws Exception {
ConnectionFactory factory = new ConnectionFactory();
final URI uri = URI.create("amqp://guest:guest@localhost:5672/");
factory.setUri(uri);
final Connection connection = factory.newConnection();
final Channel channel = connection.createChannel();
}
}
使用上面的代码,配置的虚拟主机为空。似乎没有使用URI的方式将虚拟主机配置为/
。
有没有办法做到这一点?
我最终通过不使用setUri
来解决此问题,而是设置了各个URI组件。
您需要使用%2F对'/'进行URL编码
对于来自Google的人,使用/
和/
编码的URL的组合%2f
,对我有用。
ConnectionFactory factory = new ConnectionFactory();
factory.setUri("amqp://guest:guest@localhost:5672/%2F");