生产者
1.创建connectfactory对象
setHost("192.222.21")
setPort
setVirtureHost("/")
创建connection连接
3.connection创建channel
4.通过channel发送数据
channel.basicPublic(exchange,routingket,props ,body) ,props body消息组成部分
5.关闭相应的连接
消费端
前三点可以复用
4.声明创建一个队列
channel.queueDeclare(queuename,dura是否持久化,是否独占exclusive,自动删除脱离exchangeautodelete ,描述auguments)
独占保证顺序消费 负载均衡不能保证消费进度,
网友评论