消息队列与如何spring mvc 项目中加入消息队列

首先，我们知道消息中间件，它是相当于一台服务器程序那样，负责我们客户端的消息的传递，所以我们是要安装消息中间件程序的，而不是简单配置到我们的spring就可以完成事情的，我们spring 配置的只是客户端，这个可能很多人在刚刚接触的时候会有点模糊。

那么我们是如何安装RabbitMQ的

我们刚才介绍过RabbitMQ是有Erlang语音编写的，那么运行RabbitMQ是需要配置一下erlang的环境的。具体各个操作系统的安装方法不一样，我这里不做详细的解释，大家可以自行研究。

安装RabbitMQ

安装环境：Mac +rabbitmq

对于mac 系统，安装Rabbitmq非常简单，可以通过brew工具来安装，当然这个是自行安装了。直接输入如下指令就可以了。

brew install rabbitmq

过了一段时间后，安装完毕。

启动RabbitMq服务器

sudo /usr/local/sbin/rabbitmq-server

这个时候已经成功启动服务器了。我们可以输入http://localhost:15672/#/

看看我们的服务器上面的一些信息，账号和密码为：guest和guest

那么对于客户端的连接，我们可以使用127.0.0.1，端口5672，账号和密码guest

那么我们的spring mvc 项目是如何配置rabbitmq的。

maven管理

我这里是通过maven来关系项目，可以在pom.xml加入spring-rabbit和amqp-client，代码如下：

<!-- http://mvnrepository.com/artifact/org.springframework.amqp/spring-rabbit -->

<dependency>

<groupId>org.springframework.amqp</groupId>

<artifactId>spring-rabbit</artifactId>

<version>1.6.0.RELEASE</version>

</dependency>

<!-- rabbit -->

<dependency>

<groupId>com.rabbitmq</groupId>

<artifactId>amqp-client</artifactId>

<version>3.5.4</version>

</dependency>

下载好后，我们需要了解连接rabbit的一些步骤，

1、配置连接配置

2、声明template，可以通过注解中使用rabbit来收发信息

3、消息对象json转换类。

4、Queue队列的声明。

5、交换机的定义

配置信息

在这里我编写一个spring管理rabbitmq的xml,我这里只是以topic为例子，其他的几种比如是

direct和

这里我命名为：spring-amqp.xml,具体说明在xml文件里

<beansxmlns="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"

xsi:schemaLocation="http://www.springframework.org/schema/rabbit

http://www.springframework.org/schema/rabbit/spring-rabbit-1.4.xsd

http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring-context.xsd">

<!-- rabbit服务器连接的一些配置 -->

<rabbit:connection-factoryid="connectionFactory"

host="127.0.0.1"

port="5672"

username="guest"

password="guest" />

<!-- rabbit服务器连接的一些配置 -->

<rabbit:adminconnection-factory="connectionFactory"id="amqpAdmin"/>

<!-- rabbit模板的配置 -->

<rabbit:templateid="amqpTemplate"connection-factory="connectionFactory"channel-transacted="true"

message-converter="jsonMessageConverter"/>

<!--json消息转换-->

<beanid="jsonMessageConverter"class="org.springframework.amqp.support.converter.JsonMessageConverter">

<propertyname="classMapper">

<beanclass="org.springframework.amqp.support.converter.DefaultClassMapper">

</bean>

</property>

</bean>

<!--消息队列,id和name可以是名字一致的-->

<rabbit:queueid="com.yeehot.topic.queue"name="com.yeehot.topic.queue">

<rabbit:queue-arguments>

<entrykey="x-ha-policy"value="all"/>

</rabbit:queue-arguments>

</rabbit:queue>

<!-- 声明Exchange的类型为topic并设定Exchange的名称 -->

<rabbit:topic-exchangename="yeehot.topic">

<rabbit:bindings>

<!-- 这里的queue是<rabbit:queue 里的ID -->

<rabbit:bindingpattern="com.yeehot.topic"queue="com.yeehot.topic.queue"/>

</rabbit:bindings>

</rabbit:topic-exchange>

<!--消息的监听，如果有多个子系统的话，可以在子系统中定义，我这里只是同时让他把消息发送和接收放在同一个系统而已。-->

<rabbit:listener-containerconnection-factory="connectionFactory"message-converter="jsonMessageConverter"

channel-transacted="true"concurrency="10"

auto-startup="true">

<!-- queues是我们上面的消息的队列，这句话的意思就是监听上面名字的队列 -->

<rabbit:listenerqueues="com.yeehot.topic.queue"ref="testReceiveMessageListener"method="handleMessage"/>

</rabbit:listener-container>

</beans>

编写信息发送器的代码：

@Controller

public class MessageQueeController {

privatestaticfinal String EXCHANGE = "yeehot.topic";

@Resource(name="amqpTemplate")

private AmqpTemplate amqpTemplate;

@RequestMapping(value="/sendmsg", method=RequestMethod.GET, produces = "text/html;charset=UTF-8")

@ResponseBody

public String showInfo( String msg){

System.out.println("message="+msg);

amqpTemplate.convertAndSend(EXCHANGE, "com.yeehot.topic",msg);

return msg;

}

}

编写接收信息的代码：

@Component

public class TestReceiveMessageListener {

public void handleMessage(String result) {

if(result==null)

{

System.out.println("oh ,no");

return;

}

System.out.println("receive msg="+result);

//处理逻辑

}

}

运行：

我们在浏览器输入我们的项目地址

http://192.168.3.114:8080/Yeehot-Program-King/sendmsg?msg=ming，可以发现控制台会打印出如下信息，说明我们的消息监听已经成功了。

今天的消息队列就说到这里，更多关于技术的知识，订阅我的头条号：一点热。欢迎收藏与转发