记录一次rabbitmq无法消费问题_php rabbitmq 没有consume

一、创建管道链接

public class ConnectionUtil {
   
    public static Connection getConnection() throws IOException, TimeoutException {
   
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("192.168.2.9");
        factory.setPort(5672);
        factory.setUsername("admin");
        factory.setPassword("123456");
        factory.setVirtualHost("/");
        return factory.newConnection();
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13

二、创建生产者，消费者

  private static final String QUEUE_NAME = "hello,rabbitmq";
    public void customer()
1