zoukankan      html  css  js  c++  java
  • rabbitmq+topic+java

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

    1. 新建maven项目

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

    <dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>2.8.2</version>
    </dependency>

    3. 在pom.xml中添加junit

    <dependency>
    <groupId>junit</groupId>
    <artifactId>junit</artifactId>
    <version>4.11</version>
    <scope>test</scope>
    </dependency>

    4. 新建send_msg类,发送消息:

    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 = "osc_topic";

    public static void main(String[] argv){
    Connection connection = null;
    Channel channel = null;

    try {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("vpcb-talaris-mq-1.vm.elenet.me");
    factory.setVirtualHost("talaris");
    factory.setPort(5672);
    factory.setUsername("talaris");
    factory.setPassword("talaris");

    connection = factory.newConnection();
    channel = connection.createChannel();

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

    String routingkey = "action.order.online_pay_make"; //getRouting(argv);
    String message = "Hello World!"; //getMessage(argv);

    channel.basicPublish(EXCHANGE_NAME, routingkey, null, message.getBytes("UTF-8"));
    System.out.println(" [x] Sent '" + routingkey + "':'" + message + "'");

    }
    catch (Exception e) {
    e.printStackTrace();
    }
    finally {
    if (connection != null) {
    try {
    connection.close();
    } catch (Exception ignore) {}
    }
    }
    }

    }


  • 相关阅读:
    Java正则表达式教程及示例
    MySQL 事务
    MySQL 正则表达式
    常用函数 __MySQL必知必会
    使用MySQL正则表达式 __MySQL必知必会
    首先使用flex制作table
    javascript原生调用摄像头
    网页背景图片随机
    网页背景视频的实现
    网站无法显示logo?
  • 原文地址:https://www.cnblogs.com/sunshine2016/p/5985071.html
Copyright © 2011-2022 走看看