RocketMQ消息和消息队列

一、Message

1.1 成员属性和构造器

private static final long serialVersionUID = 8445773977080406428L;
    private String topic;
    private int flag;
    private Map<String, String> properties;
    private byte[] body;
    private String transactionId;
    
    //获取成员属性的get和set方法，其他方法下面详细说明
   
    public Message() ；

    public Message(String topic, byte[] body)；

    public Message(String topic, String tags, String keys, int flag, byte[] body, boolean waitStoreMsgOK)；

    public Message(String topic, String tags, byte[] body) ；

    public Message(String topic, String tags, String keys, byte[] body) ；

1.2 keys

public void setKeys(String keys) ；
public String getKeys() ；
public void setKeys(Collection<String> keys)；

1.3 buyerId

public String getBuyerId() ；
public void setBuyerId(String buyerId)；

1.4 properties

public void putUserProperty(final String name, final String value) ；
public String getUserProperty(final String name)；
public String getProperty(final String name)；

1.5 Tags

public String getTags() ；
public void setTags(String tags) ；

1.6 instanceId

 public void setInstanceId(String instanceId)；

1.7 waitStoreMsgOK

public boolean isWaitStoreMsgOK()；
public void setWaitStoreMsgOK(boolean waitStoreMsgOK)；

1.8 设置延时消息

现在RocketMq并不支持任意时间的延时，需要设置几个固定的延时等级，从1s到2h分别对应着等级1到18 消息消费失败会进入延时消息队列，具体延时等级如下："1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h"

public int getDelayTimeLevel() ；
public void setDelayTimeLevel(int level)；//单位秒

二、MessageQueue

2.1 成员属性和构造器

public class MessageQueue implements Comparable<MessageQueue>, Serializable {
    private static final long serialVersionUID = 6191200464116433425L;
    private String topic;//主题名字
    private String brokerName;//broker名字
    private int queueId;//队列id

    public MessageQueue();

    public MessageQueue(String topic, String brokerName, int queueId); 
    
    //其方法就是其属性的get和set方法
}