代码实现整个消息投递过程

    1. public class Producer {
    2.     private static Logger log = LoggerFactory.getLogger(Producer.class);
    4.     public static void main(String[] args) {
    6.         //    步骤
    7.         //    1. 创建连接工厂
    8.         log.info("1. 创建连接工厂");
    9.         ConnectionFactory connectionFactory = new ConnectionFactory();
    10.         //配置相关配置项
    11.         connectionFactory.setHost("112.74.175.76");
    12.         connectionFactory.setPort(5672);
    13.         connectionFactory.setUsername("admin");
    14.         connectionFactory.setPassword("admin");
    15.         connectionFactory.setVirtualHost("/");
    17.         //声明连接和通道
    18.         Connection connection = null;
    19.         Channel channel = null;
    20.         try {
    21.             //     2. 创建连接 Connection
    22.             log.info("2. 创建连接 Connection");
    23.             connection = connectionFactory.newConnection("生产者");
    25.             //    3. 通过连接获取通道Chanel
    26.             log.info("3. 通过连接获取通道Chanel");
    27.             channel = connection.createChannel();
    29.             //    5. 准备消息
    30.             log.info("5. 准备消息");
    31.             String msg = "投递消息到 direct-message-exchange "+System.currentTimeMillis();
    33.             //    6. 准备新的交换机
    34.             log.info("6. 准备新的交换机");
    35.             String exchangeName = "direct-message-exchange";
    37.             //    7. 定义路由key
    38.             // log.info("7. 定义路由key");
    39.             // String routingKey = "message";
    41.             //    8. 定义交换机类型
    42.             log.info("8. 定义交换机类型");
    43.             String exchangeType = "direct";
    45.             //如果交换机不存在需要先声明交换机 1. 代码声明 2. web界面
    46.             /**
    47.              * @param 交换机名称
    48.              * @param 交换机类型
    49.              * @param 是否持久化
    50.              */
    51.             channel.exchangeDeclare(exchangeName, exchangeType, true);
    53.             //声明队列
    54.             /**
    55.              * @param 队列名称
    56.              * @param 是否持久化
    57.              * @param 是否独占队列（排他性，一般不设置为排他）
    58.              * @param 是否自动删除（最后一个消费者消费结束是否自动删除，一般不会自动删除）
    59.              * @param 附加参数map
    60.              *
    61.              */
    62.             channel.queueDeclare("q5",true,false,false,null);
    63.             channel.queueDeclare("q6",true,false,false,null);
    64.             channel.queueDeclare("q7",true,false,false,null);
    66.             //交换机绑定队列
    67.             /**
    68.              * @param 队列名称
    69.              * @param 交换机名称
    70.              * @param 路由key
    71.              */
    72.             channel.queueBind("q5", exchangeName, "order");
    73.             channel.queueBind("q6", exchangeName, "order");
    74.             channel.queueBind("q7", exchangeName, "course");
    76.             //发送消息
    77.             /**
    78.              * @param 交换机
    79.              * @param 队列名称/路由key
    80.              * @param 属性配置
    81.              * @param 发送消息内容
    82.              */
    83.             channel.basicPublish(exchangeName,"course",null,msg.getBytes());
    84.             log.info("消息发送成功：{}",msg);
    85.         } catch (Exception e) {
    86.             log.info("消息发送异常");
    87.             e.printStackTrace();
    88.         } finally {
    89.             log.info("关闭连接");
    90.             //    7. 关闭通道
    92.             if (ObjectUtil.isNotEmpty(channel) && channel.isOpen()) {
    94.                 try {
    95.                     channel.close();
    96.                 } catch (IOException | TimeoutException e) {
    97.                     e.printStackTrace();
    98.                 }
    99.             }
    101.             //    8. 关闭连接
    102.             if (ObjectUtil.isNotEmpty(connection) && connection.isOpen()) {
    103.                 try {
    104.                     connection.close();
    105.                 } catch (IOException e) {
    106.                     e.printStackTrace();
    107.                 }
    108.             }
    109.         }
    110.     }
    111. }