RabbitMQ消息队列服务器在Windows下的安装和部署->
一、Erlang语言环境的搭建
RabbitMQ开源消息队列服务是使用Erlang语言开发的，因此我们要使用他就必须先进行Erlang语言环境的搭建，其实是非常简单的。
登录Erlang官网，进入下载页，官网地址->http://www.erlang.org/downloads
然后按照自己的系统环境来选择需要下载的安装文件。

 
我选择 64-bit下载包，因为我的操作系统是64位的

接下来我们需要对Erlang语言的环境变量的配置

这里使用安装时候的目录地址！
一定要记得重启计算机，这里不重启是不会生效的！！！
这样，我们的Erlang运行环境就已经搭建完毕！
 
 
二、RabbitMQ服务环境的搭建
打开RabbitMQ官网，然后找到下载链接->http://www.rabbitmq.com/download.html 

直接下载最新版本的RabbitMQ安装包，我这里下载的是3.6.10

这里直接运行安装程序进行安装，安装完成后进行服务的启动。

从系统服务可以看到，我们的RabbitMQ服务已经启动了。

到这里，RabbitMQ的服务已经搭建完毕。
三、RabbitMQ服务的查看及常用命令
1、GUI管理工具（web）
执行代码可以启动GUI管理工具集，也只有启动了这个管理工具才可以在Web页面看到RabbitMQ的监控信息


启动以后，我们打开浏览器输入地址-> http://localhost:15672/

账号密码都是guest，然后点击login进行登录操作。
 
2、查看所有队列信息 rabbitmqctl list_queues
3、查看服务状态信息 rabbitmqctl -q status
这里我就不一一列举所有的命令了，在使用的时候我们可以随时查询使用。
 

本文为七小站主原创作品，转载请注明出处：http://www.cnblogs.com/qixiaoyizhan/ 且在文章页面明显位置给出原文链接，否则保留追究法律责任的权利。 


作者信息：

QiXiao_柒小(東)

Microsoft ARD Technical Support

QX(qixiao)Team

天津市西青經濟開發區 Xiqing Economic Development Area Tianjin 300387,P.R.China

郵箱Email : dong@qixiao.me , wd8622088@foxmail.com

網址Http: http://qixiao.me

 
Best Regard ~

分类: Installation and Publish
标签: RabbitMQ

好文要顶 关注我 收藏该文  


柒小栈主
关注 - 1
粉丝 - 16

+加关注


4
0


« 上一篇：.Net
 Core 图片文件上传下载

消息队列
一、作用
1.解耦
1.消峰
二、rabbitmq的启动和控制台登录
1.服务器启动rabbtimq
2.登录控制台
三、rabbitmq五种模式
1.简单模式
2.争抢模式
3.交换机----3种
(1).交换机的运行机制
(2).三种类型
第一种：发布订阅:fanout
第二种：路由模式:direct
第三种：主题模式:topic

一、作用
1.解耦
代码,或者系统通信都可能存在强耦合的关系,可以通过消息队列第三方技术处理强耦合,解耦 。
1.消峰
请求到达系统的方法上限,超过上限的请求不丢失不拒绝.。
二、rabbitmq的启动和控制台登录
1.服务器启动rabbtimq
#service rabbitmq-server start

start启动

stop停止

restart重启
2.登录控制台
控制台是web应用,可以通过http协议访问

ip:15672

登录名密码：guest/guest
三、rabbitmq五种模式
1.简单模式
当生产端发送消息到交换机,交换机根据消息属性发送到队列,消费者监听绑定队列实现消息的接收和消费逻辑编写.简单模式下,强调的一个队列queue只被一个消费者监听消费.

1.1结构



生产者:生成消息,发送到交换机
交换机:根据消息属性,将消息发送给队列
消费者:监听这个队列,发现消息后,获取消息执行消费逻辑
1.2应用场景

常见的应用场景就是一发,一接的结构

例如:

手机短信,邮件单发
2.争抢模式
强调的也是后端队列与消费者绑定的结构（一对多）

1.1结构



生产者:发送消息到交换机

交换机:根据消息属性将消息发送给队列

消费者:多个消费者,同时绑定监听一个队列,之间形成了争抢消息的效果

1.2应用场景

抢红包

资源分配系统
3.交换机----3种
(1).交换机的运行机制
生产端要发送消息,永远不会将消息发送给队列,而是发送给交换机。

消息本身除了数据以外,携带一个路由key值。

交换机根据自身的类型不同,采用不同的方式处理这些消息(计算路由key方式不同) 。
(2).三种类型
第一种：发布订阅:fanout


生产端:发送消息到交换机
交换机:由于是发布订阅模式,会将这个消息发送同步到后端所有与其绑定的队列
消息端:简单模式 1个队列绑定一个消费者 争抢模式 1个队列绑定多个消费者
应用场景

邮件的群发,广告的群发
第二种：路由模式:direct


生产端:发送的消息携带具体的路由key值
交换机:接收路由key值,判断和当前交换机绑定后端队列哪个满足路由的匹配
将消息发送给这个队列
应用场景

处理一些特殊的消息逻辑,可以经过路由的筛选
第三种：主题模式:topic


交换机绑定队列,不在使用具体的路由key,可以使用符号代替路由key值的规则
#:表示任意多级的任意长度的字符串
*:任意长度字符串,但是只有一级
应用场景

实现多级传递的路由筛选工作,记录trace过程.

                    
Postfix 队列清理
 
今天有同事反映发邮件速度慢，登录了邮件服务器的后台看一下(我们的邮件服务器是postfix+dovecot+mysql+extmail+extman
搭建的基于mysql的虚拟用户)，如图

邮件队列已经达到了80000封，然后我看了一下负载，已经达到20多了…….
大家都清楚负载一旦达到这个数值，服务器的性能肯定已经相当差了。这里就有问题了，队列这么多如何清理呢？
如果是把队列全部清除的话很简单：postsuper –d ALL 就ok了。但是这样操作会产生很多问题，有的正常的还没有发送的队列也会被清掉；
假如一个一个的清理，那太要命了，怎么办呢？我用postqueue –p查看了一下，发现队列里的日期的两个特点，一是日期排列不规律，
第二个特点是日期只有最近5天的。Ok，有办法了。
这是我写的一个脚本：
#!/bin/bash
/usr/sbin/postqueue -p|egrep '(Nov 8|Nov 9)' > queue1.txt
/usr/sbin/postqueue -p|egrep '(Nov 8|Nov 9)'|awk '{print $1}' > queue2.txt
for i in `cat /root/queue2.txt`
do
/usr/sbin/postsuper -d $i
done
这个脚本的作用是把队列当中日期为8号和9号的的队列写到一个文件queue1.txt(包含日期等信息)，queue2.txt(只包含队列号)；
然后用一个for循环来把queue2.txt里面的所有的队列都清除掉。执行完脚本，过几分钟再看监控图：

Ok，队列少了很多，而且服务器的负载也已经小于5了。
希望这个脚本对广大管理员有用，也希望大家有好的意见多提一下，欢迎大家跟我留言交流。




本文转自 gehailong 51CTO博客，原文链接：http://blog.51cto.com/gehailong/710076，如需转载请自行联系原作者


        
        
                
    

一 ，es 与 solr 的区别
1 ，相同点 ：

es 和 solr 都是基于 lucene 的搜索服务器。
高性能 ： 他们都基于分词技术构建的倒排索引。
开发语言 ： 都是 java 开发的。

2 ，不同点 ：

建立实时索引时 ：

1 ，solr 会产生 io 阻塞

2 ，es 不会，es 性能好
不断的动态添加数据的时候 ：

1 ，solr 效率低下

2 ，es 不会有波动
分布式管理 ：

1 ，solr 用 zookeeper 管理分布式

2 ，es 自身就可以
部署 ：solr 需要部署在 web 服务器上 ( 例如 tomcat )，solr 的本质是一个动态的 web 项目
支持的数据格式 ：

1 ，solr 支持 ： xml ，json ，csv …

2 ，es 支持 ： json
应用

1 ，solr 是传统的搜索应用，对已有数据检索的时候，效率更好。

2 ，适合实时搜索，实时变化的时候，es 更好。
官网提供功能 ：

1 ，solr 功能多。

2 ，es 只关注核心功能，如果想要更多功能，需要第三方插件。

二 ，购物车实现过程 ：
1 ，购物车跟用户的关系 ：

一个用户必须对应一个购物车

孙 ： 一个用户不管买多少商品，都会存在属于自己的购物车中。
开发过程中 ：

单点登录一定在购物车之前。

2 ，跟购物车有关的操作有哪些 ：

添加商品到购物车。
展示购物车

3 ，添加商品到购物车 ：用户未登录状态

添加到什么地方 ：

1 ，redis

2 ，cookie
例子 ：

1 ，京东 ： 保存在 redis 。

2 ，很多其他的小商城 ： 保存在 cookie 中
如果用户禁用了 cookie

可以保存在 localStorage 中

4 ，添加商品到购物车 ：用户已登录状态

存储在哪里 ： redis 中
为了保证数据的安全性 ： mysql 中也存储一份

5 ，展示购物车 ：未登录状态

直接从 cookie 中取数据

6 ，展示购物车 ：已登录状态

cookie 数据 + redis 数据
如果 redis 出问题了，就 = cookie 数据 + mysql 数据

三 ，单点登录
1 ，什么是单点登录 ：

一处登录，多出使用
孙 ： 一个系统，由多个项目组成，多个项目之间，都共有一个用户系统

2 ，应用 ：
分布式系统
3 ，架构图 ：

4 ，例子 ：
参观动物园流程：

检票员=认证中心模块

1.我直接带着大家进动物园，则会被检票员拦住【看我们是否有门票】，没有[售票处买票]

登录=买票

2.我去买票【带着票，带着大家一起准备进入动物园】检票员check【有票】

Token=piao

3.我们手中有票就可以任意观赏动物的每处景点。

京东：单点登录，是将token放入到cookie中的。

案例：将浏览器的 cookie 禁用，则在登录京东则失败！无论如何登录不了！
5 ，智慧的地方 ：
如果 cookie 不好用，就用 localStorage
四 ，消息队列 ：
1 ，技术产生背景 ：
在高并发的环境下，来不及同步处理用户发送的请求，则会导致请求发生阻塞。比如说，大量的insert，update之类的请求同时到达数据库MYSQL，直接导致无数的行锁表锁，甚至会导致请求堆积很多。从而触发 too many connections 错误。
2 ，消息队列的弊端：
消息的不确定性
3 ，解决 ：
延迟队列，轮询技术
4 ，推荐使用 ：
activemq
5 ，功能 ： 异步 ( 快速响应 )

6 ，功能 ：  并行 ( 快速处理 )

7 ，功能 ： 排队 ( 业务需要 ：有序 )

8 ，例子： ( 快速响应 )