/** 發(fā)消息 交換機(jī)* */public class Emitlog {// 交換機(jī)的名稱public static final String EXCHANGE_NAME = "logs";public static void main(String[] args) throws Exception{Channel channel = RabbitMqUtils.getChannel();channel.exchangeDeclare(EXCHANGE_NAME,"fauout");Scanner scanner = new Scanner(System.in);while (scanner.hasNext()){String message = scanner.next();channel.basicPublish(EXCHANGE_NAME,"",null,message.getBytes(StandardCharsets.UTF_8));System.out.println("生產(chǎn)者發(fā)出的消息："+ message);}} }

總結(jié)

以上是生活随笔為你收集整理的RabbitMQ fanout交换机（生产者）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。