ConnectionFactory connectionFactory = new ConnectionFactory();
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("xxxx");
connectionFactory.setUsername("xxx");
connectionFactory.setPassword("xxx");
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare("three",false,false,false,null);
String message="第3次发送消息";
channel.basicPublish("","first",null,message.getBytes());
System.out.println("消息发送完毕");
一开始消费者也是能获取到消息的,但是后来突然就不行了,查看web控制台,如下,这个应该是生产者都没把消息送到mq上?为啥这样啊