RabbitMQ的使用与分析

2021-11-08 15:53:19

1、简介

对于系统间的解耦合，无非是采用MQ（消息系统）的方式，而在众多的MQ方案中，使用的比较广泛且性能较高的开源项目则是RabbitMQ了。

RabbitMQ是采用Erlang语言编写，天生的支持高并发，而且内部有不同其它MQ的独特设计。

2、安装

为了学习与使用rabbitMQ，我们首先需要在我们的机器上安装它的服务。这里我们以windows下32系统为例，需要otp_win32_R16B02.exe和rabbitmq-server-3.2.1.exe两个安装文件，很容易就能下载到，官网上也有。这两个的安装是按常规下一步直到结束。安装完成后到rabbitMQ的根目录下的sbin目录下，执行

rabbitmq-plugins enable rabbitmq_management安装web插件，然后到计算机管理里找到rabbitmq的service，选择并启动，再执行下安装的sbin目录里的rabbitmqctl.bat文件，等服务都启动好后就可以进入web控制台了，在浏览器中输入http://127.0.0.1/55672，用户名和密码默认都是guest。如果进不去，那只

有两种可能，一是服务没启起来，二是插件没安装生效。多试上面几步就可以了。

RabbitMQ的使用与分析

图1--控制台安装web插件

RabbitMQ的使用与分析

图2-web插件控制台

3、RabbitMQ的独特设计

RabbitMQ里不仅仅有Queue，还有其他一些概念，像Vhost，exchange。MQ的生产者直接连的是exchange，exchange就像一个路由器，通过一定的规则和Queue进行绑定，消费者直接连接的是Queue。ecchange与Queue有多种绑定规则，具体如下：

Fanout Exchange：

图3--扇出型路由

Topic Exchange：

图4--主题式路由

DirectExchange：

图5--直连型路由

HeadersExchange。

如果要像其他MQ一样用，只要选择directExchange就可以了，由于复杂的场景，我在项目中运用的是topicExchange，可以根据不同的routekey路由到不同的队列里，从而

能达到负载均衡的作用。

RabbitMQ对权限也做了很好的设计，具体的权限粒度如图所示：

图6--权限控制粒度

4、RabbitMQ的使用

为了使用的简单，先说明结合spring的使用方式，利用spring的IOC自动管理Bean。

需要引入以下的配置：

<?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:rabbit="http://www.springframework.org/schema/rabbit"
	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/rabbit
                http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd">
                
 	<bean id="mqPropertyConfig"
		class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
		<property name="order" value="2" />
        <property name="ignoreUnresolvablePlaceholders" value="true" />		
		<property name="locations">
			<list>
				<value>classpath:conf/mq/mq_$[envName].properties
				</value>
			</list>
		</property>
		<property name="placeholderPrefix" value="${" />
		<property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_OVERRIDE" />
	</bean>
	
	<!-- 连接服务配置 -->
 	<rabbit:connection-factory id="connectionFactory" host="${apns.mq.Host}" username="${apns.mq.username}" password="${apns.mq.password}" virtual-host="${apns.mq.vhost}" port="${apns.mq.Port}" channel-cache-size="${apns.mq.cachesize}"/>
 	
	<rabbit:admin id="amqpadmin" connection-factory="connectionFactory"/>
	
	<rabbit:template id="amqpTemplate" connection-factory="connectionFactory"/>

</beans>

在java代码中的引用示例如下：

<pre name="code" class="java">private AmqpTemplate amqpTemplate = context.getBean("amqpTemplate", AmqpTemplate.class);

amqpTemplate.convertAndSend(exchange, routeKey, message);

当然，exchange和Queue以及他们的绑定也可以直接用代码实现，具体例子如下：

        AmqpAdmin amqpAdmin = context.getBean(AmqpAdmin.class);
        amqpAdmin.declareExchange(new TopicExchange(ENT_EXCHANGE, true, false));
        amqpAdmin.declareExchange(new TopicExchange(DEV_EXCHANGE, true, false));
        Map<Integer, String> map = RouteKeyUtil.getAllQueues();
        for(String name : map.values()){
            /**申明企业证书的队列并绑定至对应的exchange*/
            amqpAdmin.declareQueue(new Queue(ENTERPRISE + name, true, false, false));
            amqpAdmin.declareBinding(new Binding(ENTERPRISE + name, DestinationType.QUEUE, ENT_EXCHANGE, name, null));
            /**申明开发者证书的队列并绑定至对应的exchange*/
            amqpAdmin.declareQueue(new Queue(DEVELOPER + name, true, false, false));
            amqpAdmin.declareBinding(new Binding(DEVELOPER + name, DestinationType.QUEUE, DEV_EXCHANGE, name, null));
        }

我在项目中只引入了两个JAR文件：Maven的*仓库里就能下载到（http://search.maven.org）

也可以直接用API而不需要spring。感兴趣的可以到官网上查看相关文档。

最后推荐一本RabbitMQ的相关书《RabbitMQ in Action》，不过这本书是英文的，网上也有电子版的。

码农公寓

相关文章