RabbitMq之AMQP.BasicProperties

本是古典何须时尚 2023-06-17 07:56 2阅读 0赞

RabbitMQ发布消息的方法为

void basicPublish(String exchange, String routingKey, BasicProperties props, byte[] body) throws IOException;

其中 props 参数可为消息体赋予多种的功能特性。

BasicProperties的属性有以下

String contentType, //消息内容的类型
    String contentEncoding, //消息内容的编码格式
    Map<String,Object> headers,//header类型的交换机可以用到
    Integer deliveryMode,//消息持久化 1 不持久化 2 持久化
    Integer priority,//优先级
    String correlationId, //关联id
    String replyTo,//通常用于命名回调队列
    String expiration,//设置过期消息过期时间
    String messageId, //消息id
    Date timestamp, //消息的时间戳
    String type,  //类型
    String userId, //用户ID
    String appId, //应用程序id
    String clusterId //集群id

参考示例

Map<String, Object> headers = new HashMap<String, Object>();
                headers.put("arg1", "aaa");
     AMQP.BasicProperties properties = new AMQP.BasicProperties().builder()
                        .deliveryMode(2) // 传送方式
                        .contentEncoding("UTF-8") // 编码方式
                        .expiration("10000") // 过期时间
                        .headers(headers) //自定义属性
                        .build();

RabbitMQ内部封装的几个方法：

public class MessageProperties { 
    
        /** Empty basic properties, with no fields set */
        public static final BasicProperties MINIMAL_BASIC =
            new BasicProperties(null, null, null, null,
                                null, null, null, null,
                                null, null, null, null,
                                null, null);
        /** Empty basic properties, with only deliveryMode set to 2 (persistent) */
        public static final BasicProperties MINIMAL_PERSISTENT_BASIC =
            new BasicProperties(null, null, null, 2,
                                null, null, null, null,
                                null, null, null, null,
                                null, null);
    
        /** Content-type "application/octet-stream", deliveryMode 1 (nonpersistent), priority zero */
        public static final BasicProperties BASIC =
            new BasicProperties("application/octet-stream",
                                null,
                                null,
                                1,
                                0, null, null, null,
                                null, null, null, null,
                                null, null);
    
        /** Content-type "application/octet-stream", deliveryMode 2 (persistent), priority zero */
        public static final BasicProperties PERSISTENT_BASIC =
            new BasicProperties("application/octet-stream",
                                null,
                                null,
                                2,
                                0, null, null, null,
                                null, null, null, null,
                                null, null);
    
        /** Content-type "text/plain", deliveryMode 1 (nonpersistent), priority zero */
        public static final BasicProperties TEXT_PLAIN =
            new BasicProperties("text/plain",
                                null,
                                null,
                                1,
                                0, null, null, null,
                                null, null, null, null,
                                null, null);
    
        /** Content-type "text/plain", deliveryMode 2 (persistent), priority zero */
        public static final BasicProperties PERSISTENT_TEXT_PLAIN =
            new BasicProperties("text/plain",
                                null,
                                null,
                                2,
                                0, null, null, null,
                                null, null, null, null,
                                null, null);
    }

API参考

> https://www.rabbitmq.com/releases/rabbitmq-java-client/v3.1.3/rabbitmq-java-client-javadoc-3.1.3/com/rabbitmq/client/AMQP.BasicProperties.html