首页
学习
活动
专区
圈层
工具
发布
    • 综合排序
    • 最热优先
    • 最新优先
    时间不限
  • 来自专栏不止dotNET

    使用RabbitMQ实现接口补偿

    arguments); channel.ExchangeDeclare("exchange-2", "direct"); channel.QueueDeclare("queue -2", false, false, false, null); channel.QueueBind("queue-2", "exchange-2", "rk-2", null) factory.CreateConnection()) using (var channel = connection.CreateModel()) { channel.QueueDeclare("queue Console.WriteLine("已接收: {0}", message); }; channel.BasicConsume("queue

    1.6K22发布于 2019-10-14
  • 来自专栏Throwable's Blog

    RabbitMQ扩展之交换器间的绑定

    exchange-source -> exchange-destination-2 -> queue-2

    1.1K30发布于 2020-06-23
  • 来自专栏Java工程师成长之路

    rabbitmq系统学习(二)

    deliveryTag, false); } /** * * spring.rabbitmq.listener.order.queue.name=queue spring.rabbitmq.listener.simple.concurrency=5 spring.rabbitmq.listener.simple.max-concurrency=10 spring.rabbitmq.listener.order.queue.name=queue

    92820发布于 2019-09-10
  • 来自专栏山海散人技术

    026. RabbitMQ 入门及消息分发机制

    .* --> queue-2 // 消息内容 String message = "Hello A"; // 发送消息到 topic_test main(String[] args) { new Thread(receive, "queue-1").start(); new Thread(receive, "queue

    80410发布于 2021-03-03
  • 来自专栏别先生

    RabbitMQ与Spring的框架整合之Spring Boot实战

    channel.basicAck(deliveryTag, false); 55 } 56 57 /** 58 * 59 * order.queue.name=queue

    66710发布于 2019-12-02
  • 来自专栏vivo互联网技术

    vivo鲁班RocketMQ平台的消息灰度方案

    在进行消费分配时,最终Queue的分配结果如下: [图片] (表2.1  消息费者的Queue分配结果表) 因为clientB没有订阅TOPIC_A,clientA也没有订阅TOPIC_B,所以TOPIA_A中的Queue

    2K20编辑于 2022-03-21
  • 来自专栏JokerDJ

    消息队列-RabbitMQ

    // 启动三个线程去执行 new Thread(runnable, "queue-1").start(); new Thread(runnable, "queue // 启动三个线程去执行 new Thread(runnable, "queue-1").start(); new Thread(runnable, "queue exchangeName = "topic-exchange"; String routingKey1 = "com.course.order";//都可以收到 queue-1 queue // 启动三个线程去执行 new Thread(runnable, "queue-1").start(); new Thread(runnable, "queue

    1.5K10编辑于 2023-11-27
领券