RabbitMQjava参数
第⼀个参数:交换组名字,
第⼆个参数:队交换组类型:三种常⽤的Exchange(Direct、Fanout 、Topic),
a) 如果是Direct类型,则会将消息中的RoutingKey与该Exchange关联的所有Binding中的BindingKey进⾏⽐较,如果相等,则发送到该Binding对应的Queue 中;
b) 如果是 Fanout 类型,则会将消息发送给所有与该 Exchange 定义过 Binding 的所有 Queues 中去,其实是⼀种⼴播⾏为;
c)如果是Topic类型,则会按照正则表达式,对RoutingKey与BindingKey进⾏匹配,如果匹配成功,则发送到对应的Queue中;
channel.queueDeclare(queue, true, false, false, null);
第⼀个参数:队列名字,
第⼆个参数:队列是否可持久化即重启后该队列是否依然存在,
第三个参数:该队列是否时独占的即连接上来时它占⽤整个⽹络连接,
第四个参数:是否⾃动销毁即当这个队列不再被使⽤的时候即没有消费者对接上来时⾃动删除,
第五个参数:其他参数如TTL(队列存活时间)等。
channel.queueBind(queue, exchange, routingKey);
第⼀个参数:队列名字,
第⼆个参数:交换组名称;
时间正则表达式java第三个参数,路由key。
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。
发表评论