spring-rabbitMQ
“消息队列”是在消息的传输过程中保存消息的容器。消息队列管理器在将消息从它的源中继到它的目标时充当中间人。
队列的主要目的是提供路由并保证消息的传递;如果发送消息时接收者不可用,消息队列会保留消息,直到可以成功地传递它。
队列定义?
队列是一个“先进先出”容器。你放东西的顺序也取东西的顺序。LinkedList有支持队列功能的方法,所以它也能当作队列来使用。
队列(Queue)是只允许在一端进行插入,而在另一端进行删除的运算受限的线性表
优点:解耦 冗余 扩展性 灵活性 & 峰值处理能力 可恢复性 送达保证 排序保证 缓冲 理解数据流 异步通信
消息传递:
为了实现负载均衡,可以
在消费者端通知RabbitMQ,一个消息处理完之后才会接受下一个消息。
RabbitMQ与SpringMVC集成 实现发送消息队列
RabbitMQ是消息代理——一个消息传递的中介。它给您的应用程序中一个共同的平台来发送和接收消息,和一个安全的地方住,
直到收到你的消息。
Broker:简单来说就是消息队列服务器实体。
Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列。
Queue:消息队列载体,每个消息都会被投入到一个或多个队列。
Binding:绑定,它的作用就是把exchange和queue按照路由规则绑定起来。
Routing Key:路由关键字,exchange根据这个关键字进行消息投递。
vhost:虚拟主机,一个broker里可以开设多个vhost,用作不同用户的权限分离。
producer:消息生产者,就是投递消息的程序。
consumer:消息消费者,就是接受消息的程序。
channel:消息通道,在客户端的每个连接里,可建立多个channel,每个channel代表一个会话任务。
消息队列的使用过程大概如下:
(1)客户端连接到消息队列服务器,打开一个channel。
(2)客户端声明一个exchange,并设置相关属性。
(3)客户端声明一个queue,并设置相关属性。
(4)客户端使用routing key,在exchange和queue之间建立好绑定关系。
(5)客户端投递消息到exchange。
工作流程:
当客户端启动时,它创建了匿名的exclusive callback queue.
客户端的RPC请求时将同时设置两个properties: reply_to设置为 callback queue; correlation_id 设置为每个request一个独一无二的值.
请求将被发送到an rpc_queue queue.
RPC端或者说server一直在等待那个queue的请求。当请求到达时,它将通过在reply_to指定的queue回复一个message给client。
client一直等待callback queue的数据。当message到达时,它将检查 correlation_id 的值,如果值和它request发送时的一致那么就将返回响应。
安装 RabbitMq 消息队列:
1, 下载 安装 Erlang 【Erlang运行时环境是一个虚拟机,有点像Java虚拟机,这样代码一经编译,同样可以随处运行。】
运行直接安装,更换安装目录, 配置环境变量 ERLANG_HOME C:Program Files (x86)erl5.9 添加到PATH %ERLANG_HOME%bin;
2, 下载 安装 RabbitMQ
运行直接安装,更换安装目录, 配置环境变量 D:Program FilesRabbitMQ Serverrabbitmq_server-2.8.0
添加到PATH %RABBITMQ_SERVER%sbin;
到 D:Program FilesRabbitMQ Serverrabbitmq_server-2.8.0sbin 运行 rabbitmq-service.bat
运行:
找到sbin/目录,运行程序:
/usr/local/sbin/rabbitmq-server –detached
停止程序:
/usr/local/sbin/rabbitmqctl stop
rabbitmq-plugins.bat list查看已安装的插件列表
rabbitmq-plugins.bat enable rabbitmq_management 命令开启网页版控制台。
分享标题:spring-rabbitMQ
标题网址:http://cdiso.cn/article/chopih.html