MQ的发布订阅模式（fanout）_mq fanout

//创建临时队列

String queueName = channel.queueDeclare().getQueue();

直接执行肯定报错的：明显告诉我们队列名不要用amq来命名，所以可以将代码稍微改造下

channel.queueDeclare(“dy”+queueName,false,false,false,null);

了解了交换机之后，我们就可以正式开始发布订阅模式啦~

一、生产者

=====

尽量在生产者指定交换机，毕竟按照正常逻辑来看，肯定是先发送，才能接受。否则的话接受了个寂寞哦~

public static void publishMessageIndividually() throws Exception {

//工具类获取通道

Channel channel = RabbitMqUtils.getChannel();

/**

• 指定交换机和模式

• 参数一：指定的交换机名称

• 参数二：指定的交换机模式

*/

channel.exchangeDeclare(ChangeNameConstant.FANOUT_MODEL,“fanout”);

Scanner sc = new Scanner(System.in);

System.out.println(“请输入信息”);

while (sc.hasNext()) {

String mes