RabbitMQ之Exchange交换机

迷南。 2022-04-22 06:08 282阅读 0赞

##### RabbitMQ中的Exchange的作用 #####

**消息队列，消息通过发送和Exchange之后最终到达的地方，到达Queue的消息及进入了等待消费的状态。每个消息都会被发送到一个或多个队列。**

###### 队列的常用属性 ######

Name: 队列的名称
    Durability: 是否需要持久化，true为持久化
    Auto Delete: 当最后一个绑定到Exchange上的队列删除后，自动删除该Exchange

#### Message-消息 ####

**服务器和应用程序之间传送的数据**

**本质上就是一段数据，由Properties和Payload(Body)组成**

###### Messsage中的常用属性 ######

Delivery Mode: 送达模式
    headers:消息的头信息
    content_type: 内容的类型
    content_encoding: 内容的编码格式
    priority: 消息的优先级 
    
    correlation_id: 一般用作消息的唯一Id来做
    reply_to: 消息失败后可以返回到对应的哪个队列中
    expiration: 消息的过期时间
    message_id: 消息的Id
    
    # 自定义的数据类型
    timestamp: 时间戳
    type: 类型
    user_id:
    app_id:
    cluster_id:

###### Message实际代码上手 ######

ConnectionFactory connectionFactory = new ConnectionFactory();
            connectionFactory.setHost("114.67.224.231");
            connectionFactory.setUsername("guest");
            connectionFactory.setPassword("guest");
            connectionFactory.setVirtualHost("/");
            Connection connection = connectionFactory.newConnection();
            Channel channel = connection.createChannel();
            Map<String, Object> headers = new HashMap<>();
            headers.put("ocean0","1");
            headers.put("ocean1","2");
            AMQP.BasicProperties properties = new AMQP.BasicProperties.Builder()
                    .deliveryMode(2)//设置消息是否持久化 2：持久化 1：非持久化
                    .contentEncoding("UTF-8")
                    .expiration("15000") //过期时间 单位：毫秒
                    .headers(headers) //headers中保存的是自定义属性
                    .build();
            //通过channel通道来发送消息
            String msg = "hello rabbitmq!";
            //注意：此时如果不指定交换机名称，则默认走Default AMQP交换机进行路由
            channel.basicPublish("","test001",properties,msg.getBytes());
            //关闭连接
            channel.close();
            connection.close();

![Message代码实现][Message]

Message中的Arguments属性说明：

*  x-message-ttl: 发布到队列的消息在丢弃之前可以存活多长时间（单位：毫秒）
 *  x-expires: 在自动删除队列之前可以使用多长时间（单位：毫秒）
 *  x-max-length: 在队列开始从队列中删除之前，队列可以包含多少（就绪）消息（单位：个）
 *  x-max-length-bytes: 队列在开始从头部删除之前可以包含的就绪消息的总体大小。）
 *  x-overflow: 设置队列溢出行为。这个决定了在达到队列的最大长度是消息会发生什么。有效值为`drop-head`或`reject-publish`。
 *  x-dead-lettler-exchange:如果发送的消息被拒绝或过期，将重新发布消息的交换机的可选名称。
 *  x-dead-letter-routing-key: 当发送的消息无效时可选替换的路由密钥。如果未设置，将使用消息的原始Routing-key
 *  x-max-priority: 设置队列的最大优先级数；如果未设置，则队列将不支持消息优先级
 *  x-queue-mode: 将队列设置为延迟模式，在磁盘上保留尽可能多的消息已减少RPM使用。如果未设置，队列将保留内存缓存已尽快传递消息。 延迟模式。
 *  x-queue-master-locator: 将队列设置为主位置模式，确定在节点集群上声明时队列主机所在的规则。

[Message]: http://static.happygiraffeisfun.com/rabbitmq/Message%E4%BB%A3%E7%A0%81%E5%AE%9E%E7%8E%B0.png