13518219792
rabbitMQ是AMQP的实现，相关语义如下
Broker：提供一种传输服务，它的角色就是维护一条从生产者到消费者的路线，保证数据能按照指定的方式进行传输
Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列
Queue：消息的载体，每个消息都会被投到一个或多个队列
Bingding：绑定，它的作用就是把exchange和queue按照路由规则绑定起来
Routing Key：路由关键字，exchange根据这个关键字进行消息投递
vhost：虚拟主机，一个broker里可以有多个vhost，用作不同用户的权限分离
Producer：消息生产者，就是投递消息的程序
Consumer：消息消费者，就是接受消息的程序
Channel：消息通道，在客户端的每个连接里，可建立多个channel
核心概念
1：在mq领域中，producer将msg发送到queue，然后consumer通过消费queue完成P.C解耦
2：kafka是由producer决定msg发送到哪个queue
3：rabbitmq是由Exchange决定msg应该怎么样发送到目标queue，这就是binding及对应的策略
Exchange
Direct Exchange：直接匹配，通过Exchange名称+RoutingKey来发送与接收消息
Fanout Exchange：广播订阅，向所有消费者发布消息，但只有消费者将队列绑定到该路由才能接收到消息，忽略RoutingKey
Topic Exchange：主题匹配订阅，这里的主题指的是RoutingKey，RoutingKey可以采用通配符，如：*或#，RoutingKye命名采用" . " 来分割多个词，只有消息这将队列绑定到该路由且指定RoutingKey符合匹配规则时才能收到消息
Headers Exchange：消息头订阅，消息发布前为消息定义一个或多个键值对的消息头，然后消费者接收消息同时需要定义类似的键值对请求头(如：x-match=all 或 x-match=any)，只有请求头与消息头匹配，才能接收消息，忽略RoutingKey
默认的Exchange：如果用空字符串去声明一个exchange，那么系统就会使用"amq.direct"这个exchange，我们创建一个queue时，默认的都会有一个和新建queue同名的routingKey绑定到这个默认的exchange上
RabbitMQ如何确保消息发送和消息接收
消息发送确认
1：ConfirmCallback
ConfirmCallback是一个回调接口，消息发送到Broker后触发回调，确认消息是否到达Broker服务器，也就是只确认是否正确到达Exchange中
2：ReturnCallback
通过实现ReturnCallback接口，启动消息失败返回，此接口是在交换器路由不到队列时触发回调，该方法可以不使用，因为交换器和队列是在代码里绑定的，如果消息成功投递到Broker后几乎不存在绑定队列失败，除非代码写错
消息接收确认
RabbitMQ消息确认机制(ACK)默认是自动确认的，自动确认会在消息发送给消费者后立即确认，但存在丢失消息的可能，如果消费端消费逻辑抛出异常，假如你用回滚了也只是保证了数据的一致性，但是消息还是丢了，也就是消费端没有处理成功这条消息，那么就相当于丢失了消息
消息确认模式
AcknowledgeMode.NODE：自动确认
AcknowledgeMode.AUTO：根据情况确认
AcknowledgeMode.MANUAL：手动确认
消费者收到消息后，手动调动Basic.Ack或Basic.Nack或Basic.Reject后，RabbitMQ收到这些消息后，才认为本次投递完成
Basic.Ack：用于确认当前消息
Basic.Nack：用于否定当前消息
Basic.Reject：用于拒绝当前消息
Nack,Reject后有能力要求是否requeue消息或者进入死信队列
RabbitMQ死信队列，延时队列
死信队列：DLX(Dead Letter Exchange)死信交换器
当队列中的消息被拒绝，或者过期会变成死信，死信可以被重新发布到另一个交换器，这个交换器就是DLX，与DLX绑定的队列称为死信队列。
造成死信的原因：
1：信息被拒绝
2：信息超时
3：超过了队列的大长度
过期消息：在rabbitmq中存在2种可设置的过期时间，第一种通过对队列进行设置，该队列中的所有消息都存在相同的过期时间，第二中通过对消息本身进行设置，那么每条消息的过期时间都不一样。如果同时使用这2种方法，那么以过期时间小的那个数值为准。当消息达到过期时间还没有被消费，那么那个消息就成为了一个死信消息。
队列设置：在队列声明的时候使用x-message-ttl参数，单位为毫秒
单个消息设置：设置消息属性的expiration参数，单位为毫秒
延迟队列：延迟队列存储的是延迟消息
1：延迟消息指的是，当消息被发布出去之后，并不立即投递给消费者，而是在指定时间之后投递。如：订单系统中，订单有30秒的付款时间，在订单超时之后再投递给消费者处理超时订单。
:2：rabbitMq没有直接支持延迟队列，可以通过死信队列实现。
在死信队列中，可以为普通交换器绑定多个消息队列，假设绑定过期时间为5分钟，10分钟和30分钟，3个消息队列，然后为每个消息队列设置DLX，为每个DLX关联一个死信队列。当消息过期之后，被转存到对应的死信队列中，然后投递给指定的消费者消费
你是否还在寻找稳定的海外服务器提供商？创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源，准确流量调度确保服务器高可用性，企业级服务器适合批量采购，新人活动首月15元起，快前往官网查看详情吧
