消息的创建由AMQPMessage对象来创建$message = new AMQPMessage("消息内容");
是不是很简单.
后边是一个数组.可以对消息进行一些特殊配置$message = new AMQPMessage("消息内容",['配置项'=>'配置值']);
配置项分析表
content_type | 短文本 | MIME类型表示消息是一种什么类型的格式,参考MIME类型 |
content_encoding | 短文本 | 正文传输编码,比如内容是gzip压缩的.值就是gzip,参考 |
application_headers | 数组 | 请求的headers信息 |
delivery_mode | 数字 | 表示是否持久化,1为否,2为是 参考 |
priority | 数字 | 发送权重,也就是优先级 |
correlation_id | 短文本 | 相关性ID 参考 |
reply_to | 短文本 | 消息被发送者处理完后,返回回复时执行的回调 |
expiration | 短文本 | 存活时间,毫秒数 |
message_id | 短文本 | 扩展属性 |
timestamp | 数字 | 时间戳 |
type | 短文本 | 扩展属性 |
user_id | 短文本 | 扩展属性 |
app_id | 短文本 | 扩展属性 |
cluster_id | 短文本 | 扩展属性 |
如需转载请注明: 转载自26点的博客
本文链接地址: rabbitMQ消息队列 – Message方法解析
转载请注明:26点的博客 » rabbitMQ消息队列 – Message方法解析