zoukankan      html  css  js  c++  java
  • rabbitmq学习——routingkey

    public class Send {

    public static final String exchange = "direct_log_son";

    public static void main(String[] args) throws Exception{
    Connection conn = ChanncelFactory.getChanncelFactory();
    Channel channel = conn.createChannel();
    //这里采用了直连 之前的扇形 是对所有接收者进行发送
    channel.exchangeDeclare(exchange, "direct");

    String body = "获取子集";

    //这里与之前的增加了 routingkey 获取的时候 可以根据这个进行区分
    channel.basicPublish(exchange, "abcde", null, body.getBytes());

    ChanncelFactory.close(channel, conn);
    }
    }

    public class Receive {
    public static void main(String[] args) throws Exception{
    Connection conn = ChanncelFactory.getChanncelFactory();
    Channel channel = conn.createChannel();
    channel.exchangeDeclare(Send.exchange, "direct");

    String queuename = channel.queueDeclare().getQueue();
    //这里的abcde 也可是 defg 就是获取的不同而已
    channel.queueBind(queuename, Send.exchange, "abcde");
    System.out.println(queuename);
    Consumer callback = new DefaultConsumer(channel){
    @Override
    public void handleDelivery(String consumerTag, Envelope envelope,
    BasicProperties properties, byte[] body) throws IOException {
    System.out.println("内容: "+new String(body, "utf-8"));
    }
    };
    for(int i=1; i<6; i++){
    Thread.sleep(2000);
    channel.basicConsume(queuename, true, callback);
    }

    ChanncelFactory.close(channel, conn);
    }
    }

  • 相关阅读:
    redis主从配置
    mysql被动模式下的主主配置
    centos7 重启网卡报错
    mysql innodb_data_file_path配置增加
    sql语句偶记录
    nginx 做前端代理时proxy参数配置
    firewalld实现网关功能
    mysql负载飙高原因分析
    nginx 直接返回状态码
    (转)Yale CAS + .net Client 实现 SSO(6)
  • 原文地址:https://www.cnblogs.com/core404/p/7645264.html
Copyright © 2011-2022 走看看