rabbitmq

架构

rabbitmq 基本架构

一个queue下可以连多个consumer；
consumer从queue中取消息；
queue中的一个消息，可以发送给与queue相连的其中一个consumer。

queue到consumer这个流程段，是不做匹配的（虽然有queuename和consumername，但是仅仅用做标识而已）。
queue类似于组，多个consumer并发处理queue中的消息。

producer的消息回带exchangename和routerkey。
消息到了rabbitmq服务器，会选择一个exchange。
exchange会根据routerkey来选择queue。

exchange和queue会通过queuekey来绑定操作;
exchange收到消息之后，会根据消息中的routerkey来选择queue;
具体匹配规则，根据exchange类型相关：

direct：完全匹配——必须routerkey和queuekey完全相同，才会选择匹配到这个queue。
- 如果queue1和queue2都以相同的queuekey 'test_12'绑定到exchange1，
- 如果queue3以queuekey 'test_3'绑定到exchange1，
- exchange1下面没有绑定其它任何队列。
- 那么exchange收到routerkey为'test_12'的消息，那么会放到queue1,queue2;
- 那么exchange收到routerkey为'test_3'的消息，那么会放到queue3;
- 如果收到routerkey为其它字串，那么就匹配不到。
fanout：不做任何匹配，只要在exchange下面的queue就发。
- 还是上面的例子,exchange1下面有三个队列queue1,queue2,queue3: bind(exchang1,queue1,test_12);bind(exchang1,queue2,test_12);bind(exchang1,queue3,test_3);
- exchange1收到任何消息，都会同时发到queue1,queue2,queue3。
  - 注意，即不会对routerkey和queuekey做匹配。
topic：这种跟redict类似，需要做匹配，但是，可以进行通配符匹配。
- queue1假设queuekey为test.*
- queue1假设queuekey为test.#
- 假设routekey是test，匹配不到任何队列
- 假设routekey是test.test1，同时匹配到queue1,queeu2
- 假设routekey是test.test1.test2，只能匹配到queue2

注意，.之间的整个串进行匹配，不会支持部分匹配(比如：test*/test.t#)

producer生成一个消息msg，发送到rabbitmq服务器；
rabbitmq服务器根据msg的exchange名字，选择一个exchange（如果为空，那么选择默认的exchange）
exchange根据routekey来匹配exchange下面的队列
- 匹配成功，就放进队列；
- 如果匹配失败，就做对应处理（属性设置，可以选择丢弃，可以选择等待队列创建）
queue从下面连接的consumer中选择一个，将msg发送过去。
- 一般情况下，会等待ack确认。