javarabbitmqtopic_rabbitmq+topic+java

可参照github代码&＃xff1a;https://github.com/rabbitmq/rabbitmq-tutorials/blob/master/java/EmitLogTopic.java

1. 新建maven项目

2. 在pom.xml中添加rabbitmq依赖

com.rabbitmq

amqp-client

2.8.2

3. 在pom.xml中添加junit

junit

junit

4.11

test

4. 新建send_msg类&＃xff0c;发送消息&＃xff1a;

package stream.rabbitmq.client;

import com.rabbitmq.client.Channel;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.ConnectionFactory;

/**

* Created by sarah on 16/10/21.

*/

public class send_msg {

private static final String EXCHANGE_NAME &＃61; "osc_topic";

public static void main(String[] argv){

Connection connection &＃61; null;

Channel channel &＃61; null;

try {

ConnectionFactory factory &＃61; new ConnectionFactory();

factory.setHost("vpcb-talaris-mq-1.vm.elenet.me");

factory.setVirtualHost("talaris");

factory.setPort(5672);

factory.setUsername("talaris");

factory.setPassword("talaris");

connection &＃61; factory.newConnection();

channel &＃61; connection.createChannel();

// channel.exchangeDeclare(EXCHANGE_NAME, "topic"); &＃xff0d;&＃xff0d; 若exchange已经定义&＃xff0c;就不能再重复定义了

String routingkey &＃61; "action.order.online_pay_make"; //getRouting(argv);

String message &＃61; "Hello World!"; //getMessage(argv);

channel.basicPublish(EXCHANGE_NAME, routingkey, null, message.getBytes("UTF-8"));

System.out.println(" [x] Sent &＃39;" &＃43; routingkey &＃43; "&＃39;:&＃39;" &＃43; message &＃43; "&＃39;");

}

catch (Exception e) {

e.printStackTrace();

}

finally {

if (connection !&＃61; null) {

try {

connection.close();

} catch (Exception ignore) {}

}

}

}

}