~~~ public class Send { private final static String EXCHANGE_NAME = "direct_exchange_test"; public static void main(String[] argv) throws Exception { // 獲取到連接 Connection connection = ConnectionUtil.getConn(); // 獲取通道 Channel channel = connection.createChannel(); // 聲明exchange，指定類型為direct channel.exchangeDeclare(EXCHANGE_NAME, "direct"); // 消息內容 String message = "商品新增了， id = 1001"; // 發送消息，并且指定routing key 為：insert ,代表新增商品 channel.basicPublish(EXCHANGE_NAME, "insert", null, message.getBytes()); System.out.println(" [商品服務：] Sent '" + message + "'"); channel.close(); connection.close(); } } ~~~