RabbitMQ 概念
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了RabbitMQ 概念相关的知识，希望对你有一定的参考价值。
本文适有一定消息队列基础的,但没有接触过RabbitMQ的快速理解RabbitMQ.
如果从来没接触过RabbitMQ，那么让我们来设想一个基础的消息队列是怎样的呢？
//发送方，给一个队列名，就可以将消息发出
发送(QueueName,msg)
//接收方，给一个队列名就可以收到消息
while(true)
msg=接收(QueueName)
当然这是基础的点对点的队列,一个消息只被一个接收方消费一次。
还可以引入订阅机制，每个订阅者将收到一个订阅的完整内容。
//接收方
订阅(QueueName)
//订阅之后，系统会为这个订阅者保留一份消息副本，直到他消费。
//然后就可以象上面一样开始消息消息
while(true)
msg=接收(QueueName)
每个消息被所有订阅者都消费一次。
而RabbitMQ则比较复杂，多了大量概念，比如Exchange，Queue，Binding，
Connection，Channel，broker，virtual host...
初次接触会觉得很乱，我只是发个消息，为什么要了解这么多呢？
其实简单梳理一下，就会发现rabbitMQ并没有想象的那么复杂。
为了快速理解rabbitMQ的基本概念，你只需要关注Exchange，Queue，Binding。
其它概念都是具体编程时的细节，都可以放一放。
Exchange主要有三种类型direct,fanout,topic。也只要关注topic就可以了，
因为另外两类其实是topic的特例。
Queue，有一个唯一的名字，是一个标准的先进先出队列，而且每个队列中的消息只会被消费一次。
Binding则是描述exchange和queue之间的关系，之所以消息不直接发送到queue而是通过
exchange中转，并再由exchange和queue之间关系来决定最终消息投放到一个或多个队列，
甚至包括直接丢弃消息，仅仅是为了更方便的适合各种使用场景而已。
exchange和queue可以Bingding一个key，也就是首先连接了两者并且再定义了连接的类型（关系）。
而每个消息发送时也可以指定一个消息的routing_key。
比如我们可以让一个exchange和如下三个queue绑定
1.queue1，绑定key=#，所有exchange收到的消息都将转发给这个queue
2.queue2，绑定key=abc.def，只有routing_key=abc.def的消息才会转发到此queue。
3.queue3，绑定key=abc.*，转发所有routing_key为abc开头，且有两个字的消息。
可以想象，如果没有这样的绑定机制，要实现这三个队列，
就要求消息发送方根据情况多次发送同一个消息到对应的队列。
这正是RabbitMQ引入exchange来解决此类问题的方式。
关于绑定key通配符的进一步说明：
1.字是用.分隔的；a.b.c包含三个字，abc包含一个字
2.*代表任意一个字；a.*匹配a.b和a.c和a.d但不匹配a和a.b.c
3.#代表任意多个字；a.#匹配a和a.b和a.b.c。
Exchange direct类型是topic的一种特例，绑定关系只能是明确的不包含通配符的key，
而fanout类型则是忽略key，将所有消息转发给与他连接的queue。
一般情况下，发送时要指定一个exchange和消息的routing_key，
特例是，不指定exchange时，就用全局默认的direct类型exchange，
这样消息就只通过routing_key来决定投递到那个队列
（可以认为每个queue实际都是和全局direct exchage通过queue名字绑定的），
这实际就是我们最开始假想的标准消息队列。
通过增加更多其他exchange，在rabbitMQ内可以规划相互隔离或者相互交织的转发网络。
并且还可通过增加vhost，让用户感觉面对多个独立的rabbitMQ，来实现强隔离。
broker则指整个rabbitMQ，他可以包含多个vhost，客户端首先通过Connection连接到其中一个vhost，
比如IP+端口，为了复用连接，rabbitMQ再增加了Channel概念，在一个连接上可以同时并发多个Channel（类似会话），
channel仅仅是实现细节并不涉及具体概念，比如没有channel的话，rabbitMQ大可直接用连接与客户端交互
（这样可能要打开大量连接），类似mysql这种方式。
所以即便你从来没接触过rabbitMQ，现在也能大概知道如何用了。
伪码如下：
//发送
//打开连接
con=rabbitMQ.getConn(ip=,port=)
//打开channel
ch=con.getChannel()
//delivery_mode=2消息需要持久，不持久的话性能高，但是一旦崩溃会丢消息
ch.send(exchange=,routing_key=,msg=,delivery_mode=)
//关闭连接，实际可以只关闭channel而始终保持长连接
con.close()
//接收
con=rabbitMQ.getConn(ip=,port=)
ch=con.getChannel()
//接收时只需要指定queue，可选的是是否需要明确确认消息，
//不需要确认的话，消息一读，rabbitMQ就删除了，处理错误也不会再有机会了，
//当然这样性能更高
msg=ch.recive(queue=,no_ack=)
//处理消息
...
//确认处理完消息，确认后rabbitMQ就会删除对应消息
ch.ack(msg.id)
con.close()
好了，增加了消息是否需要持久，以及消息的确认，
每种语言有不同的API客户端，总体处理方式都是类似的。
上述代码没有包括建立exchange和queue，以及他们之间绑定的代码，
我们可以简单认为，这部分是通过其他方式另外定义的，对于收发客户端，
实际就只要提供上面这些参数就足够了。
这样看来RabbitMQ是不是很清晰简单？
当然rabbitMQ还包括一些其他的功能，比如RPC等，这类无非就是发送时指定更多参数罢了。
以上是关于RabbitMQ 概念的主要内容，如果未能解决你的问题，请参考以下文章