首页
登录 | 注册

web项目中spring如何整合RabbitMQ?

如何在Windows下安装rabbitMQ?这个问题已在我的上一篇文章中讲解清楚,不清楚的同学可以看看我的上一篇文章。 

Windows下安装及配置RabbitMQ


接下来讲解如何在web项目中配合spring来使用rabbitMQ?


一、若是maven工程,在pom.xml文件中添加依赖: 若不是maven工程,需自己找jar包加入工程。
<!-- RabbitMQ -->
<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>3.5.1</version>
</dependency>
<dependency>
    <groupId>org.springframework.amqp</groupId>
    <artifactId>spring-rabbit</artifactId>
    <version>1.4.5.RELEASE</version>
</dependency>

二、项目中新建配置文件 spring-rabbit.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:rabbit="http://www.springframework.org/schema/rabbit"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:util="http://www.springframework.org/schema/util"
       xsi:schemaLocation="http://www.springframework.org/schema/rabbit
       http://www.springframework.org/schema/rabbit/spring-rabbit-1.5.xsd
       http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
       http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <context:property-placeholder location="classpath*:/META-INF/env/*.properties" />

    <!--<util:properties id="appConfig" location="classpath:/META-INF/env/rabbit.properties"></util:properties>-->

    <!--配置connection-factory,指定连接rabbit server参数-->
    <rabbit:connection-factory id="connectionFactory" username="guest" password="guest"
                               host="localhost"
                               port="5672"
                               virtual-host="/"/> <!-- virtual-host="/"是默认的虚拟机路径-->

    <!--通过指定下面的admin信息,当前producer中的exchange和queue会在rabbitmq服务器上自动生成-->
    <rabbit:admin connection-factory="connectionFactory"/>

    <!--定义queue-->
    <rabbit:queue id="com.mj.test" name="com.mj.test" durable="true" auto-delete="false" exclusive="false"/>

    <!-- 定义direct exchange,绑定com.mj.test queue -->
    <rabbit:direct-exchange name="myChange" durable="true" auto-delete="false">
        <rabbit:bindings>
            <rabbit:binding queue="com.mj.test" key="testKey"></rabbit:binding>
        </rabbit:bindings>
    </rabbit:direct-exchange>

    <!--定义rabbit template用于数据的接收和发送-->
    <rabbit:template id="amqpTemplate" connection-factory="connectionFactory" exchange="myChange" />

    <bean id="messageReceiver" class="com.hp.netpro.rf.web.utils.RabbitMQConsumer"/>

    <rabbit:listener-container connection-factory="connectionFactory">
        <rabbit:listener queues="com.mj.test" ref="messageReceiver"/>
    </rabbit:listener-container>

</beans>
   

三、在工程的配置文件applicationContext.xml中增加配置如下:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://www.springframework.org/schema/context
       http://www.springframework.org/schema/context/spring-context.xsd
       http://www.springframework.org/schema/aop
       http://www.springframework.org/schema/aop/spring-aop.xsd">

    <import resource="classpath*:/META-INF/spring/spring-api-mybatis.xml" />
    <import resource="classpath*:/META-INF/spring/spring-rabbit.xml" />
    <!--<import resource="/META-INF/spring/spring-rabbit.xml"/>-->
    <!-- 使能AOP-->
    <aop:aspectj-autoproxy/>
    <!-- 自动装载bean使能-->
    <context:component-scan base-package="com.hp.netpro.rf.web.utils"/>
    <context:annotation-config/>

    <context:property-placeholder location="classpath*:/META-INF/env/*.properties" />
    <!--<util:properties id="appConfig" location="classpath:/META-INF/env/rabbit.properties"></util:properties>-->

    <!-- 激活annotation功能 -->
    <context:spring-configured />

</beans>

四、新建消息生产者类 RabbitMQProducer.java

packagecom.hp.netpro.rf.web.utils;
importorg.springframework.amqp.core.AmqpTemplate;
importorg.springframework.stereotype.Service;
importjavax.annotation.Resource;
/**
 *
@Description:消息生产
 *
@Author:
 
*@CreateTime:
 
*/
@Service
public classRabbitMQProducer {

    @Resource
    privateAmqpTemplateamqpTemplate;

    public voidsendMessage(Object message){
        amqpTemplate.convertAndSend("testKey",message);//testKey为配置文件中queue对应的key,指明发送给哪个queue。
    }
}

 
五、新建消息消费者 RabbitMQConsumer.java 

package com.hp.netpro.rf.web.utils;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
import org.springframework.stereotype.Service;
/**
 *
@Description:消息队列接收者
 *
@Author:
 
*@CreateTime:
 
*/
@Service
public class RabbitMQConsumerimplementsMessageListener {
    
public voidonMessage(Message message) {
       System.out.println("消息!");
       System.out.println(message);
       System.out.println("消息getMessageProperties!");
       System.out.println(message.getMessageProperties());
       System.out.println("消息getBody");
       System.out.println(message.getBody());

    }
}


六、编写测试方法

/**
 *
@Description:消息队列
 *
@Author:
 
*@CreateTime:

 */

@Resource
private RabbitMQProducer rabbitMQProducer; //注意:这里必须以这种注入的方式 不能使用new来创建对象,


@ResponseBody
@RequestMapping("/sendMessage")
publicString testQueue() {
    try{
        rabbitMQProducer.sendMessage("I am amq sender");
        return"发送完毕";
    }catch(Exception e){
        e.printStackTrace();
        return"发送失败!!";
    }
}



接下来启动RabbitMQ-Server,启动工程,浏览器访问对应测试方法的RequestMapping。
结果:

web项目中spring如何整合RabbitMQ?



相关文章

  • 像数据科学家一样思考:12步指南(下)
    第三阶段-完成 一旦产品构建完成,你仍然需要做一些事情来使项目更加成功并使你的未来生活更轻松.那么我们如何完成数据科学项目呢? 10-交付产品 完成阶段的第一步是产品交付.为了创建可以交付给客户的有效产品,首先必须了解客户的观点.其次,你需 ...
  • 简单的SSM-Shiro安全框架搭建
    首先需要导jar包! 配置你自己的web.xml CharacterEncodingFilter org.springframework.web.filter.CharacterEncodingFilter encoding utf-8 f ...
  • 微软发布人工智能教育与学习共建社区
    步入2019,人工智能(Artificial Intelligence)的浪潮依然汹涌,各国对于AI人才的需求进一步加大:2月,美国总统特朗普签署行政命令,正式启动美国人工智能计划:加拿大正通过"全球技能战略签证"吸引国 ...
  • 源码|详解分布式事务之 Seata-Client 原理及流程
    前言 在分布式系统中,分布式事务是一个必须要解决的问题,目前使用较多的是最终一致性方案.自年初阿里开源了Fescar(四月初更名为Seata)后,该项目受到了极大的关注,目前已接近 8000 Star.Seata 以高性能和零侵入的特性为目 ...
  • 贾扬清:我对人工智能方向的一点浅见
    阿里妹导读:作为 AI 大神,贾扬清让人印象深刻的可能是他写的AI框架Caffe ,那已经是六年前的事了.经过多年的沉淀,成为"阿里新人"的他,对人工智能又有何看法?最近,贾扬清在阿里内部分享了他的思考与洞察,欢迎共同探 ...
  • 字符串: 字符串用单引号(')或双引号(")括起来,不可变 1,find通过元素找索引,可切片,找不到返回-1 2,index,找不到报错. 3,split 由字符串分割成列表,默认按空格. 4,captalize 首字母大写,其 ...

2019 jeepshoe.net webmaster#jeepshoe.net
13 q. 0.409 s.
京ICP备10005923号