~~~ public class Send { private final static String QUEUE_NAME = "simple_queue"; public static void main(String[] args) throws Exception { //獲取連接 Connection connection = ConnectionUtil.getConn(); // 創建通道 Channel channel = connection.createChannel(); // 聲明隊列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 向指定的隊列中發送消息 String message = "hello rabbitmq"; channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); System.out.println("send message " +message); // 關閉通道和連接 channel.close(); connection.close(); } } ~~~