依赖包：

1 
     
       2     
      
        3       
       
        junit
        4       
       
        junit
        5       
       
        4.12
        6       
       
        test
        7     
       8  9     
      10     
      
       11       
       
        com.rabbitmq
       12       
       
        amqp-client
       13       
       
        5.1.2
       14     
      15     
      16     
      
       17       
       
        org.slf4j
       18       
       
        slf4j-nop
       19       
       
        1.7.25
       20     
      21 22   
     

 

源码：

1 package org.study.utils; 2  3 import com.rabbitmq.client.Connection; 4 import com.rabbitmq.client.ConnectionFactory; 5  6 import java.io.IOException; 7 import java.util.concurrent.TimeoutException; 8  9 /**10  * 获取rabbitmq连接11  */12 public class ConnectionUtils {13     public static Connection getConnection() throws IOException, TimeoutException {14         ConnectionFactory factory = new ConnectionFactory();15         factory.setHost("10.15.1.26");16         factory.setPort(5672);17         factory.setVirtualHost("/test_host");18         factory.setUsername("admin");19         factory.setPassword("admin");20         Connection connection = factory.newConnection();21         return connection;22     }23 }