zoukankan      html  css  js  c++  java
  • Java使用RabbitMQ之整合Spring(生产者)

     依赖包

            <!--RabbitMQ集成spring-->
            <!-- https://mvnrepository.com/artifact/org.springframework.amqp/spring-rabbit -->
            <dependency>
                <groupId>org.springframework.amqp</groupId>
                <artifactId>spring-rabbit</artifactId>
                <version>2.0.6.RELEASE</version>
            </dependency>

    生产者Spring配置文件:

     1 <?xml version="1.0" encoding="UTF-8"?>
     2 <beans xmlns="http://www.springframework.org/schema/beans"
     3        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     4        xmlns:context="http://www.springframework.org/schema/context"
     5        xmlns:rabbit="http://www.springframework.org/schema/rabbit"
     6        xsi:schemaLocation="
     7             http://www.springframework.org/schema/beans
     8                 http://www.springframework.org/schema/beans/spring-beans.xsd
     9             http://www.springframework.org/schema/context
    10                 http://www.springframework.org/schema/context/spring-context.xsd
    11             http://www.springframework.org/schema/rabbit
    12                 http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd">
    13 
    14     <!-- 连接服务配置 -->
    15     <rabbit:connection-factory id="connectionFactory"
    16                                host="10.15.1.26" username="admin" password="admin" port="5672"
    17                                virtual-host="/test_host" channel-cache-size="5"/>
    18 
    19     <!--MQ的管理,包括队列、交换器的声明等-->
    20     <rabbit:admin connection-factory="connectionFactory"/>
    21 
    22     <!-- queue 队列声明 -->
    23     <rabbit:queue durable="true"
    24                   auto-delete="false" exclusive="false" name="test.spring.queue"/>
    25 
    26     <!-- exchange queue binging key 绑定 -->
    27     <rabbit:direct-exchange name="spring.exchange"
    28                             durable="true" auto-delete="false">
    29         <rabbit:bindings>
    30             <rabbit:binding queue="test.spring.queue" key="spring.queue.key"/>
    31         </rabbit:bindings>
    32     </rabbit:direct-exchange>
    33 
    34     <!-- spring template声明 -->
    35     <rabbit:template id="amqpTemplate" exchange="spring.exchange" routing-key="spring.queue.key"
    36                      connection-factory="connectionFactory"/>
    37 
    38 </beans>

    生产者源码:

     1 package org.study.spring5;
     2 
     3 import org.springframework.amqp.core.AmqpTemplate;
     4 import org.springframework.context.ApplicationContext;
     5 import org.springframework.context.support.ClassPathXmlApplicationContext;
     6 
     7 /**
     8  * RabbitMQ与Spring整合
     9  * 生产者
    10  */
    11 public class SpringProducer {
    12 
    13     public static void main(String args[]) {
    14         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring/producer-spring-config.xml");
    15         //获取RabbitMQ模板
    16         AmqpTemplate template = applicationContext.getBean(AmqpTemplate.class);
    17         //发送消息
    18         String msg = "Hello !";
    19         template.convertAndSend(msg);
    20         System.out.println("发送:" + msg);
    21     }
    22 }

      

  • 相关阅读:
    Android WebView常见问题及解决方案汇总【很全很实用】
    adb shell dumpsys meminfo [packagename] 输出内容的含义
    Android关于RAM、ROM、SD卡以及各种内存的区别
    每天5分钟玩转容器技术 整理目录
    ubuntu16.04基本设置
    ubuntu镜像快速下载
    vSphere 5.5.0 U1配置问题:主机的快速统计信息不是最新的(转载)
    Vcenter server 5.5安装部署
    SQL Server 2008 R2 数据库安装
    Centos7.3搭建DNS服务器--BIND
  • 原文地址:https://www.cnblogs.com/gongxr/p/9648156.html
Copyright © 2011-2022 走看看