{"id":4238,"date":"2024-04-20T14:16:42","date_gmt":"2024-04-20T06:16:42","guid":{"rendered":"https:\/\/xinchewhd.com.cn\/index.php\/spring-boot\/spring-boot%e6%95%b4%e5%90%88rabbitmq\/"},"modified":"2024-04-20T14:16:42","modified_gmt":"2024-04-20T06:16:42","slug":"spring-boot%e6%95%b4%e5%90%88rabbitmq","status":"publish","type":"post","link":"https:\/\/xinchewhd.com.cn\/index.php\/spring-boot\/spring-boot%e6%95%b4%e5%90%88rabbitmq\/","title":{"rendered":"Spring Boot\u6574\u5408RabbitMQ"},"content":{"rendered":"
\n

\u5982\u679c\u6587\u7ae0\u4e2d\u4ee3\u7801\u4e0d\u4fbf\u4e8e\u9605\u8bfb\uff0c\u8bf7\u4f7f\u7528\u7535\u8111\u67e5\u770b\u6216\u70b9\u51fb\u9605\u8bfb\u539f\u6587\u3002\u6e90\u7801\u8be6\u89c1\uff1a<\/span><\/h1>\n

GitHub\uff1ahttps:\/\/github.com\/dkbnull\/SpringBootDemo<\/span>Gitee\uff1ahttps:\/\/gitee.com\/dkbnull\/SpringBootDemo<\/span><\/span><\/p>\n

0 \u5f00\u53d1\u73af\u5883<\/span><\/h1>\n
    \n
  • \n

    JDK\uff1a1.8<\/span><\/p>\n<\/li>\n

  • \n

    Spring Boot\uff1a2.7.18<\/span><\/p>\n<\/li>\n

  • \n

    RabbitMQ\uff1a3.13.1<\/span><\/p>\n<\/li>\n

  • \n

    Erlang\uff1a26.2.4<\/span><\/p>\n<\/li>\n<\/ul>\n

    1 \u5b89\u88c5RabbitMQ<\/span><\/h1>\n

    1.1 \u5b89\u88c5RabbitMQ<\/span><\/h2>\n

    \u4e0b\u8f7d\u5730\u5740\uff1a<\/span>https:\/\/www.rabbitmq.com\/docs\/download<\/span><\/span><\/p>\n

    Windows\u4e0b\u8f7d\u5730\u5740\uff1a<\/span>https:\/\/github.com\/rabbitmq\/rabbitmq-server\/releases\/download\/v3.13.1\/rabbitmq-server-3.13.1.exe<\/span><\/span><\/p>\n

    \u56e0\u4e3aRabbitMQ\u4f9d\u8d56Erlang\uff0c\u6240\u4ee5\u4e0b\u8f7d\u5b8c\u6210\u540e\u5148\u4e0d\u8981\u5b89\u88c5\uff0c\u5148\u5728 <\/span>https:\/\/www.rabbitmq.com\/docs\/which-erlang<\/span><\/span> \u67e5\u770b\u6240\u9700\u7684Erlang\u7248\u672c\uff0c\u4e0b\u8f7d\u5bf9\u5e94Erlang\u5b89\u88c5\u5305<\/span><\/p>\n

    1.2 \u5b89\u88c5Erlang<\/span><\/h2>\n

    Erlang\u4e0b\u8f7d\u5730\u5740\uff1a<\/span>https:\/\/www.erlang.org\/downloads<\/span><\/span><\/p>\n

    \u4f9d\u6b21\u5b89\u88c5Erlang\u3001RabbitMQ<\/span><\/p>\n

    \u8ba1\u7b97\u673a\u670d\u52a1\u4e2d\u4f1a\u51fa\u73b0RabbitMQ\u670d\u52a1\uff0c\u76f4\u63a5\u53f3\u952e\u542f\u52a8\u5373\u53ef\u3002<\/span><\/p>\n

    \u4e5f\u53ef\u5728\u5f00\u59cb\u83dc\u5355\u4e2d\u627e\u5230<\/span>RabbitMQ Server\u76ee\u5f55<\/strong><\/span>\uff0c\u70b9\u51fb<\/span>RabbitMQ Service - start<\/strong><\/span>\u542f\u52a8<\/span><\/p>\n

    1.3 \u542f\u7528RabbitMQ\u7ba1\u7406\u754c\u9762<\/span><\/h2>\n

    \u9ed8\u8ba4\u60c5\u51b5\u4e0b\uff0cRabbitMQ\u6ca1\u6709\u542f\u7528web\u7aef\u5ba2\u6237\u7aef\u63d2\u4ef6\uff0c\u9700\u8981\u542f\u7528\u624d\u53ef\u4ee5\u751f\u6548<\/span><\/p>\n

    \u53c2\u8003\u6587\u6863\uff1a<\/span>https:\/\/www.rabbitmq.com\/docs\/management<\/span><\/span><\/p>\n

    \u8fdb\u5165\u5230RabbitMQ\u5b89\u88c5\u76ee\u5f55\u4e0b <\/span>RabbitMQ Serverrabbitmq_server-3.13.1sbin<\/strong><\/span> \u6267\u884c\u547d\u4ee4<\/span><\/p>\n

    rabbitmq-plugins enable rabbitmq_management<\/span><\/pre>\n
    \u5b89\u88c5\u6210\u529f\uff0c<\/span>\u91cd\u542fRabbitMQ\u670d\u52a1<\/strong><\/span>\uff0c\u6d4f\u89c8\u5668\u8bbf\u95ee <\/span>127.0.0.1:15672<\/strong><\/span><\/p>\n
    \u9ed8\u8ba4\u8d26\u53f7\u5bc6\u7801\u90fd\u662f<\/span>guest<\/strong><\/span>\uff0c\u767b\u5f55\u6210\u529f\u540e\u754c\u9762\u5982\u4e0b<\/span><\/p>\n
    2 \u5e7f\u64ad\u6a21\u5f0fFanout<\/span><\/h1>\n
    Fanout\uff0c\u53d1\u5e03\u8ba2\u9605\u6a21\u5f0f\uff0c\u662f\u4e00\u79cd\u5e7f\u64ad\u673a\u5236\uff0c\u662f\u6ca1\u6709\u8def\u7531key\u7684\u6a21\u5f0f\u3002<\/span><\/p>\n
    2.1 \u65b0\u5efa\u751f\u4ea7\u8005<\/span><\/h2>\n
    \u65b0\u5efamodule <\/span>spring-boot-rabbitmq-producer<\/strong><\/span><\/p>\n
    2.1.1 \u5f15\u5165\u4f9d\u8d56<\/span><\/h3>\n
    <<\/span>dependency<\/span>><\/span><\/span>  <<\/span>groupId<\/span>><\/span>org.springframework.boot<\/<\/span>groupId<\/span>><\/span><\/span>  <<\/span>artifactId<\/span>><\/span>spring-boot-starter-amqp<\/<\/span>artifactId<\/span>><\/span><\/span><\/<\/span>dependency<\/span>><\/span><\/span><\/pre>\n
    2.1.2 \u914d\u7f6eRabbitMQ<\/span><\/h3>\n
    server<\/span>:<\/span><\/span>  port<\/span>: <\/span>8090<\/span><\/span>#<\/span><\/span>#\u914d\u7f6eRabbitMQ\u670d\u52a1<\/span><\/span>spring<\/span>:<\/span><\/span>  rabbitmq<\/span>:<\/span><\/span>   username<\/span>: <\/span>guest<\/span>   password<\/span>: <\/span>guest<\/span>   virtual-host<\/span>: <\/span>\/<\/span>   host<\/span>: <\/span>127.0.0.1<\/span><\/span>   port<\/span>: <\/span>5672<\/span><\/span><\/pre>\n
    2.1.3 \u65b0\u5efa\u914d\u7f6e\u7c7b<\/span><\/h3>\n
    @Configuration<\/span><\/span>public<\/span> class<\/span> RabbitMqFanoutConfig<\/span> {<\/span><\/span><\/span>  \/**<\/span><\/span>   * Fanout \u4ea4\u6362\u673a<\/span><\/span>   *<\/span><\/span>   * @return<\/span><\/span>   *\/<\/span><\/span>  @Bean<\/span><\/span>  public<\/span> FanoutExchange<\/span> fanoutExchange<\/span>() {<\/span>    return<\/span> new<\/span> FanoutExchange<\/span>(\"fanout_user_exchange\"<\/span>, true<\/span>, false<\/span>);<\/span>   }<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u53d1\u9001\u77ed\u4fe1\u961f\u5217<\/span><\/span>   *<\/span><\/span>   * @return<\/span><\/span>   *\/<\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Queue<\/span> smsQueue<\/span>() {<\/span>    \/\/durable    \u662f\u5426\u6301\u4e45\u5316\uff0c\u9ed8\u8ba4\u4e3afalse<\/span><\/span>    \/\/exclusive   \u662f\u5426\u53ea\u80fd\u88ab\u5f53\u524d\u521b\u5efa\u7684\u8fde\u63a5\u4f7f\u7528\uff0c\u9ed8\u8ba4\u4e3afalse<\/span><\/span>    \/\/autoDelete   \u662f\u5426\u81ea\u52a8\u5220\u9664\uff0c\u9ed8\u8ba4\u4e3afalse<\/span><\/span><\/span><\/span>    \/\/\u4e00\u822c\u8bbe\u7f6e\u961f\u5217\u7684\u6301\u4e45\u5316\uff0c\u5176\u4f59\u4e24\u4e2a\u9ed8\u8ba4false<\/span><\/span>    return<\/span> new<\/span> Queue<\/span>(\"sms.fanout.queue\"<\/span>, true<\/span>);<\/span>   }<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u53d1\u9001\u90ae\u4ef6\u961f\u5217<\/span><\/span>   *<\/span><\/span>   * @return<\/span><\/span>   *\/<\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Queue<\/span> emailQueue<\/span>() {<\/span>    return<\/span> new<\/span> Queue<\/span>(\"email.fanout.queue\"<\/span>, true<\/span>);<\/span>   }<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u53d1\u9001\u5fae\u4fe1\u961f\u5217<\/span><\/span>   *<\/span><\/span>   * @return<\/span><\/span>   *\/<\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Queue<\/span> wechatQueue<\/span>() {<\/span>    return<\/span> new<\/span> Queue<\/span>(\"wechat.fanout.queue\"<\/span>, true<\/span>);<\/span>   }<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u5c06\u961f\u5217\u548c\u4ea4\u6362\u673a\u7ed1\u5b9a<\/span><\/span>   *<\/span><\/span>   * @return<\/span><\/span>   *\/<\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Binding<\/span> smsBindingFanout<\/span>() {<\/span>    return<\/span> BindingBuilder<\/span>.bind<\/span>(smsQueue<\/span>()).to<\/span>(fanoutExchange<\/span>());<\/span>   }<\/span><\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Binding<\/span> emailBindingFanout<\/span>() {<\/span>    return<\/span> BindingBuilder<\/span>.bind<\/span>(emailQueue<\/span>()).to<\/span>(fanoutExchange<\/span>());<\/span>   }<\/span><\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Binding<\/span> wechatBindingFanout<\/span>() {<\/span>    return<\/span> BindingBuilder<\/span>.bind<\/span>(wechatQueue<\/span>()).to<\/span>(fanoutExchange<\/span>());<\/span>   }<\/span>}<\/span><\/pre>\n
    2.1.4 \u65b0\u5efa\u751f\u4ea7\u8005\u670d\u52a1<\/span><\/h3>\n
    @Service<\/span><\/span>public<\/span> class<\/span> UserService<\/span> {<\/span><\/span><\/span>  @Autowired<\/span><\/span>  private<\/span> RabbitTemplate<\/span> rabbitTemplate<\/span>;<\/span><\/span><\/span>  public<\/span> void<\/span> register<\/span>(String<\/span> username<\/span>, String<\/span> password<\/span>) {<\/span>    \/\/\u6a21\u62df\u7528\u6237\u6ce8\u518c<\/span><\/span>    String<\/span> userId<\/span> =<\/span> UUID<\/span>.randomUUID<\/span>().toString<\/span>();<\/span><\/span><\/span>    \/\/saveUser(user);<\/span><\/span><\/span><\/span>    \/\/\u53d1\u9001\u7528\u6237\u4fe1\u606f\u7ed9RabbitMQ fanout<\/span><\/span>    rabbitTemplate<\/span>.convertAndSend<\/span>(\"fanout_user_exchange\"<\/span>, \"\"<\/span>, userId<\/span> +<\/span> username<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
    2.1.5 \u65b0\u5efa\u6d4b\u8bd5\u7c7b<\/span><\/h3>\n
    @SpringBootTest<\/span>(classes<\/span> =<\/span> RabbitMqProducerApplication<\/span>.class<\/span>, webEnvironment<\/span> =<\/span> SpringBootTest<\/span>.WebEnvironment<\/span>.DEFINED_PORT<\/span>)<\/span>public<\/span> class<\/span> RabbitMqProducerApplicationTest<\/span> {<\/span><\/span><\/span>  @Autowired<\/span><\/span>  private<\/span> UserService<\/span> userService<\/span>;<\/span><\/span><\/span>  @Test<\/span><\/span>  public<\/span> void<\/span> contextLoads<\/span>() {<\/span>    userService<\/span>.register<\/span>(\"\u5f20\u4e09\"<\/span>, \"zhangsan\"<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
    \u542f\u52a8\u6d4b\u8bd5\u7c7b\uff0c\u6267\u884c\u6210\u529f\uff0c\u67e5\u770bRabbitMQ Web\u9875\u9762\uff0c\u6210\u529f\u7ed1\u5b9a\uff0c\u4e14\u5404\u5b58\u5728\u4e00\u6761\u6d88\u606f<\/span><\/p>\n
    2.2 \u65b0\u5efa\u6d88\u8d39\u8005<\/span><\/h2>\n
    \u65b0\u5efamodule <\/span>spring-boot-rabbitmq-consumer<\/strong><\/span><\/p>\n
    2.2.1 \u5f15\u5165\u4f9d\u8d56<\/span><\/h3>\n
    <<\/span>dependency<\/span>><\/span><\/span>  <<\/span>groupId<\/span>><\/span>org.springframework.boot<\/<\/span>groupId<\/span>><\/span><\/span>  <<\/span>artifactId<\/span>><\/span>spring-boot-starter-amqp<\/<\/span>artifactId<\/span>><\/span><\/span><\/<\/span>dependency<\/span>><\/span><\/span><\/pre>\n
    2.2.2 \u914d\u7f6eRabbitMQ<\/span><\/h3>\n
    server<\/span>:<\/span><\/span>  port<\/span>: <\/span>8090<\/span><\/span>#<\/span><\/span>#\u914d\u7f6eRabbitMQ\u670d\u52a1<\/span><\/span>spring<\/span>:<\/span><\/span>  rabbitmq<\/span>:<\/span><\/span>   username<\/span>: <\/span>guest<\/span>   password<\/span>: <\/span>guest<\/span>   virtual-host<\/span>: <\/span>\/<\/span>   host<\/span>: <\/span>127.0.0.1<\/span><\/span>   port<\/span>: <\/span>5672<\/span><\/span><\/pre>\n
    2.2.3 \u65b0\u5efa\u77ed\u4fe1\u6d88\u8d39\u670d\u52a1<\/span><\/h3>\n
    @RabbitListener<\/span>(queues<\/span> =<\/span> \"sms.fanout.queue\"<\/span>)<\/span>@Service<\/span><\/span>public<\/span> class<\/span> FanoutSmsService<\/span> {<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u6d88\u606f\u63a5\u6536\u7684\u65b9\u6cd5<\/span><\/span>   *<\/span><\/span>   * @param message<\/span><\/span>   *\/<\/span><\/span>  @RabbitHandler<\/span><\/span>  public<\/span> void<\/span> receiveMessage<\/span>(String<\/span> message<\/span>) {<\/span>    \/\/\u53d1\u9001\u77ed\u4fe1<\/span><\/span><\/span><\/span>    System<\/span>.out<\/span>.println<\/span>(\"sms.fanout\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
    2.2.4 \u65b0\u5efa\u90ae\u4ef6\u6d88\u8d39\u670d\u52a1<\/span><\/h3>\n
    @RabbitListener<\/span>(queues<\/span> =<\/span> \"email.fanout.queue\"<\/span>)<\/span>@Service<\/span><\/span>public<\/span> class<\/span> FanoutEmailService<\/span> {<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u6d88\u606f\u63a5\u6536\u7684\u65b9\u6cd5<\/span><\/span>   *<\/span><\/span>   * @param message<\/span><\/span>   *\/<\/span><\/span>  @RabbitHandler<\/span><\/span>  public<\/span> void<\/span> receiveMessage<\/span>(String<\/span> message<\/span>) {<\/span>    \/\/\u53d1\u9001\u90ae\u4ef6<\/span><\/span><\/span><\/span>    System<\/span>.out<\/span>.println<\/span>(\"email.fanout\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
    2.2.5 \u65b0\u5efa\u5fae\u4fe1\u6d88\u8d39\u670d\u52a1<\/span><\/h3>\n
    @RabbitListener<\/span>(queues<\/span> =<\/span> \"wechat.fanout.queue\"<\/span>)<\/span>@Service<\/span><\/span>public<\/span> class<\/span> FanoutWechatService<\/span> {<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u6d88\u606f\u63a5\u6536\u7684\u65b9\u6cd5<\/span><\/span>   *<\/span><\/span>   * @param message<\/span><\/span>   *\/<\/span><\/span>  @RabbitHandler<\/span><\/span>  public<\/span> void<\/span> receiveMessage<\/span>(String<\/span> message<\/span>) {<\/span>    \/\/\u63a8\u9001\u5fae\u4fe1\u6d88\u606f<\/span><\/span><\/span><\/span>    System<\/span>.out<\/span>.println<\/span>(\"wechat.fanout\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
    2.3 \u6d4b\u8bd5<\/span><\/h2>\n
    \u65b0\u5efa\u542f\u52a8\u7c7b\uff0c\u542f\u52a8\u670d\u52a1\uff0c\u63a7\u5236\u53f0\u8f93\u51fa\u5982\u4e0b\uff0c\u6d88\u8d39\u8005\u6210\u529f\u63a5\u6536\u5230\u6d88\u606f<\/span><\/p>\n
    RabitMQ\u4e2d\u6d88\u606f\u4e3a0<\/span><\/p>\n
    \u518d\u6b21\u6267\u884c\u751f\u4ea7\u8005\u6d4b\u8bd5\u7c7b\u53d1\u9001\u65b0\u7684\u6d88\u606f\uff0c\u6d88\u8d39\u8005\u6210\u529f\u63a5\u6536\u5e76\u6253\u5370<\/span><\/p>\n
    3 \u8def\u7531\u6a21\u5f0fDirect<\/span><\/h1>\n
    \u6709routing-key\u7684\u5339\u914d\u6a21\u5f0f\uff0cDirect\u6a21\u5f0f\u662fFanout\u6a21\u5f0f\u4e0a\u7684\u4e00\u79cd\u53e0\u52a0\uff0c\u589e\u52a0\u4e86\u8def\u7531RoutingKey\u7684\u6a21\u5f0f\u3002<\/span><\/p>\n
    3.1 \u6d88\u8d39\u8005<\/span><\/h2>\n
    3.1.1 \u65b0\u5efa\u77ed\u4fe1\u6d88\u8d39\u670d\u52a1<\/span><\/h3>\n
    \u8fd9\u91cc\uff0c\u6211\u4eec\u4e0d\u5728\u751f\u4ea7\u8005\u4e2d\u4f7f\u7528\u914d\u7f6e\u7c7b\u6765\u7ed1\u5b9a\u4ea4\u6362\u673a\u548c\u961f\u5217\u4e86\uff0c\u76f4\u63a5\u5728\u6d88\u8d39\u8005\u4e2d\u4f7f\u7528\u6ce8\u89e3\u6765\u7ed1\u5b9a<\/span><\/p>\n
    \u4f7f\u7528 <\/span>@RabbitListener(bindings = @QueueBinding())<\/strong><\/span> \u6ce8\u89e3\u6765\u7ed1\u5b9a\u4ea4\u6362\u673a\u548c\u961f\u5217<\/span><\/p>\n
      \n
    • \n
      bindings \u7528\u6765\u786e\u5b9a\u961f\u5217\u548c\u4ea4\u6362\u673a\u7684\u7ed1\u5b9a\u5173\u7cfb<\/span><\/p>\n<\/li>\n
    • \n
      value  \u961f\u5217\u540d\u79f0\uff0c\u4e0e\u751f\u4ea7\u8005\u5bf9\u5e94<\/span><\/p>\n<\/li>\n
    • \n
      exchange \u4ea4\u6362\u673a\u540d\u79f0\uff0c\u4e0e\u751f\u4ea7\u8005\u5bf9\u5e94\uff1btype\u8bbe\u7f6eRabbitMQ\u6a21\u5f0f\uff0c\u9ed8\u8ba4\u4e3adirect<\/span><\/p>\n<\/li>\n
    • \n
      key   \u8def\u7531key<\/span><\/p>\n<\/li>\n<\/ul>\n
      \u4f46\u6709\u4e9b\u9ad8\u7ea7\u7528\u6cd5\uff0c\u8fd8\u662f\u63a8\u8350\u4f7f\u7528\u914d\u7f6e\u7c7b<\/span><\/p>\n
      @RabbitListener<\/span>(bindings<\/span> =<\/span> @QueueBinding<\/span>(<\/span>    value<\/span> =<\/span> @Queue<\/span>(value<\/span> =<\/span> \"sms.direct.queue\"<\/span>, durable<\/span> =<\/span> \"true\"<\/span>, autoDelete<\/span> =<\/span> \"false\"<\/span>),<\/span>    exchange<\/span> =<\/span> @Exchange<\/span>(value<\/span> =<\/span> \"direct_user_exchange\"<\/span>, type<\/span> =<\/span> ExchangeTypes<\/span>.DIRECT<\/span>),<\/span>    key<\/span> =<\/span> \"sms\"<\/span>))<\/span>@Service<\/span><\/span>public<\/span> class<\/span> DirectSmsService<\/span> {<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u6d88\u606f\u63a5\u6536\u7684\u65b9\u6cd5<\/span><\/span>   *<\/span><\/span>   * @param message<\/span><\/span>   *\/<\/span><\/span>  @RabbitHandler<\/span><\/span>  public<\/span> void<\/span> receiveMessage<\/span>(String<\/span> message<\/span>) {<\/span>    \/\/\u53d1\u9001\u77ed\u4fe1<\/span><\/span><\/span><\/span>    System<\/span>.out<\/span>.println<\/span>(\"sms.direct\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
      3.1.2 \u65b0\u5efa\u90ae\u4ef6\u6d88\u8d39\u670d\u52a1<\/span><\/h3>\n
      @RabbitListener<\/span>(bindings<\/span> =<\/span> @QueueBinding<\/span>(<\/span>    value<\/span> =<\/span> @Queue<\/span>(value<\/span> =<\/span> \"email.direct.queue\"<\/span>, durable<\/span> =<\/span> \"true\"<\/span>, autoDelete<\/span> =<\/span> \"false\"<\/span>),<\/span>    exchange<\/span> =<\/span> @Exchange<\/span>(value<\/span> =<\/span> \"direct_user_exchange\"<\/span>),<\/span>    key<\/span> =<\/span> \"email\"<\/span>))<\/span>@Service<\/span><\/span>public<\/span> class<\/span> DirectEmailService<\/span> {<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u6d88\u606f\u63a5\u6536\u7684\u65b9\u6cd5<\/span><\/span>   *<\/span><\/span>   * @param message<\/span><\/span>   *\/<\/span><\/span>  @RabbitHandler<\/span><\/span>  public<\/span> void<\/span> receiveMessage<\/span>(String<\/span> message<\/span>) {<\/span>    \/\/\u53d1\u9001\u90ae\u4ef6<\/span><\/span><\/span><\/span>    System<\/span>.out<\/span>.println<\/span>(\"email.direct\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
      3.1.3 \u65b0\u5efa\u5fae\u4fe1\u6d88\u8d39\u670d\u52a1<\/span><\/h3>\n
      @RabbitListener<\/span>(bindings<\/span> =<\/span> @QueueBinding<\/span>(<\/span>    value<\/span> =<\/span> @Queue<\/span>(value<\/span> =<\/span> \"wechat.direct.queue\"<\/span>, durable<\/span> =<\/span> \"true\"<\/span>, autoDelete<\/span> =<\/span> \"false\"<\/span>),<\/span>    exchange<\/span> =<\/span> @Exchange<\/span>(value<\/span> =<\/span> \"direct_user_exchange\"<\/span>),<\/span>    key<\/span> =<\/span> \"wechat\"<\/span>))<\/span>@Service<\/span><\/span>public<\/span> class<\/span> DirectWechatService<\/span> {<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u6d88\u606f\u63a5\u6536\u7684\u65b9\u6cd5<\/span><\/span>   *<\/span><\/span>   * @param message<\/span><\/span>   *\/<\/span><\/span>  @RabbitHandler<\/span><\/span>  public<\/span> void<\/span> receiveMessage<\/span>(String<\/span> message<\/span>) {<\/span>    \/\/\u63a8\u9001\u5fae\u4fe1\u6d88\u606f<\/span><\/span><\/span><\/span>    System<\/span>.out<\/span>.println<\/span>(\"wechat.direct\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
      3.2 \u751f\u4ea7\u8005<\/span><\/h2>\n
      3.2.1 \u8c03\u6574\u670d\u52a1\u7c7b<\/span><\/h3>\n
      @Service<\/span><\/span>public<\/span> class<\/span> UserService<\/span> {<\/span><\/span><\/span>  @Autowired<\/span><\/span>  private<\/span> RabbitTemplate<\/span> rabbitTemplate<\/span>;<\/span><\/span><\/span>    <\/span>\/\/...<\/span><\/span><\/span><\/span>  public<\/span> void<\/span> registerDirect<\/span>(String<\/span> username<\/span>, String<\/span> password<\/span>) {<\/span>    \/\/\u6a21\u62df\u7528\u6237\u6ce8\u518c<\/span><\/span>    String<\/span> userId<\/span> =<\/span> UUID<\/span>.randomUUID<\/span>().toString<\/span>();<\/span><\/span><\/span>    \/\/saveUser(user);<\/span><\/span><\/span><\/span>    rabbitTemplate<\/span>.convertAndSend<\/span>(\"direct_user_exchange\"<\/span>, \"sms\"<\/span>, userId<\/span> +<\/span> username<\/span>);<\/span>    rabbitTemplate<\/span>.convertAndSend<\/span>(\"direct_user_exchange\"<\/span>, \"email\"<\/span>, userId<\/span> +<\/span> username<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
      3.2.2 \u8c03\u6574\u6d4b\u8bd5\u7c7b<\/span><\/h3>\n
      @SpringBootTest<\/span>(classes<\/span> =<\/span> RabbitMqProducerApplication<\/span>.class<\/span>, webEnvironment<\/span> =<\/span> SpringBootTest<\/span>.WebEnvironment<\/span>.DEFINED_PORT<\/span>)<\/span>public<\/span> class<\/span> RabbitMqProducerApplicationTest<\/span> {<\/span><\/span><\/span>  @Autowired<\/span><\/span>  private<\/span> UserService<\/span> userService<\/span>;<\/span><\/span><\/span>  @Test<\/span><\/span>  public<\/span> void<\/span> contextLoads<\/span>() {<\/span>    userService<\/span>.register<\/span>(\"\u5f20\u4e09\"<\/span>, \"zhangsan\"<\/span>);<\/span>   }<\/span><\/span><\/span>  @Test<\/span><\/span>  public<\/span> void<\/span> contextLoadsDirect<\/span>() {<\/span>    userService<\/span>.registerDirect<\/span>(\"\u674e\u56db\"<\/span>, \"lisi\"<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
      3.3 \u6d4b\u8bd5<\/span><\/h2>\n
      \u542f\u52a8\u6d88\u8d39\u8005\u670d\u52a1\uff0c\u6267\u884c\u751f\u4ea7\u8005\u6d4b\u8bd5\u7c7bcontextLoadsDirect\uff0c\u6d88\u8d39\u8005\u6210\u529f\u6536\u5230\u6d88\u606f\u5e76\u6253\u5370<\/span><\/p>\n
      4 \u4e3b\u9898\u6a21\u5f0fTopic<\/span><\/h1>\n
      \u6a21\u7cca\u7684routing-key\u7684\u5339\u914d\u6a21\u5f0f\uff0cTopic\u6a21\u5f0f\u662fDirect\u6a21\u5f0f\u4e0a\u7684\u4e00\u79cd\u53e0\u52a0\uff0c\u589e\u52a0\u4e86\u6a21\u7cca\u8def\u7531RoutingKey\u7684\u6a21\u5f0f\u3002<\/span><\/p>\n
      4.1 \u6d88\u8d39\u8005<\/span><\/h2>\n
      4.1.1 \u65b0\u5efa\u914d\u7f6e\u7c7b<\/span><\/h3>\n
      \u4e00\u822c\u5728\u751f\u4ea7\u4e2d\uff0c\u5148\u542f\u52a8\u6d88\u8d39\u8005\u670d\u52a1\uff0c\u518d\u542f\u52a8\u751f\u4ea7\u8005\u670d\u52a1\uff0c\u56e0\u6b64\u6211\u4eec\u901a\u5e38\u628a\u914d\u7f6e\u7c7b\u653e\u5728\u6d88\u8d39\u8005\u670d\u52a1\u4e2d\uff0c\u5426\u5219\u53ef\u80fd\u5bfc\u81f4\u65e0\u961f\u5217\u76d1\u542c\u800c\u670d\u52a1\u542f\u52a8\u5931\u8d25\u6216\u62a5\u9519<\/span><\/p>\n
      @Configuration<\/span><\/span>public<\/span> class<\/span> RabbitMqTopicConfig<\/span> {<\/span><\/span><\/span>  \/**<\/span><\/span>   * Topic \u4ea4\u6362\u673a<\/span><\/span>   *<\/span><\/span>   * @return<\/span><\/span>   *\/<\/span><\/span>  @Bean<\/span><\/span>  public<\/span> TopicExchange<\/span> topicExchange<\/span>() {<\/span>    return<\/span> new<\/span> TopicExchange<\/span>(\"topic_user_exchange\"<\/span>, true<\/span>, false<\/span>);<\/span>   }<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u53d1\u9001\u77ed\u4fe1\u961f\u5217<\/span><\/span>   *<\/span><\/span>   * @return<\/span><\/span>   *\/<\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Queue<\/span> smsQueue<\/span>() {<\/span>    \/\/durable    \u662f\u5426\u6301\u4e45\u5316\uff0c\u9ed8\u8ba4\u4e3afalse<\/span><\/span>    \/\/exclusive   \u662f\u5426\u53ea\u80fd\u88ab\u5f53\u524d\u521b\u5efa\u7684\u8fde\u63a5\u4f7f\u7528\uff0c\u9ed8\u8ba4\u4e3afalse<\/span><\/span>    \/\/autoDelete   \u662f\u5426\u81ea\u52a8\u5220\u9664\uff0c\u9ed8\u8ba4\u4e3afalse<\/span><\/span><\/span><\/span>    \/\/\u4e00\u822c\u8bbe\u7f6e\u961f\u5217\u7684\u6301\u4e45\u5316\uff0c\u5176\u4f59\u4e24\u4e2a\u9ed8\u8ba4false<\/span><\/span>    return<\/span> new<\/span> Queue<\/span>(\"sms.topic.queue\"<\/span>, true<\/span>);<\/span>   }<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u53d1\u9001\u90ae\u4ef6\u961f\u5217<\/span><\/span>   *<\/span><\/span>   * @return<\/span><\/span>   *\/<\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Queue<\/span> emailQueue<\/span>() {<\/span>    return<\/span> new<\/span> Queue<\/span>(\"email.topic.queue\"<\/span>, true<\/span>);<\/span>   }<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u53d1\u9001\u5fae\u4fe1\u961f\u5217<\/span><\/span>   *<\/span><\/span>   * @return<\/span><\/span>   *\/<\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Queue<\/span> wechatQueue<\/span>() {<\/span>    return<\/span> new<\/span> Queue<\/span>(\"wechat.topic.queue\"<\/span>, true<\/span>);<\/span>   }<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u5c06\u961f\u5217\u548c\u4ea4\u6362\u673a\u7ed1\u5b9a, \u5e76\u8bbe\u7f6e\u7528\u4e8e\u5339\u914d\u952e<\/span><\/span>   *<\/span><\/span>   * @return<\/span><\/span>   *\/<\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Binding<\/span> smsBindingTopic<\/span>() {<\/span>    return<\/span> BindingBuilder<\/span>.bind<\/span>(smsQueue<\/span>()).to<\/span>(topicExchange<\/span>()).with<\/span>(\"*.sms.#\"<\/span>);<\/span>   }<\/span><\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Binding<\/span> emailBindingTopic<\/span>() {<\/span>    return<\/span> BindingBuilder<\/span>.bind<\/span>(emailQueue<\/span>()).to<\/span>(topicExchange<\/span>()).with<\/span>(\"#.email.#\"<\/span>);<\/span>   }<\/span><\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Binding<\/span> wechatBindingTopic<\/span>() {<\/span>    return<\/span> BindingBuilder<\/span>.bind<\/span>(wechatQueue<\/span>()).to<\/span>(topicExchange<\/span>()).with<\/span>(\"#.wechat.*\"<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
      4.1.2 \u65b0\u5efa\u77ed\u4fe1\u6d88\u8d39\u670d\u52a1<\/span><\/h3>\n
      @RabbitListener<\/span>(queues<\/span> =<\/span> \"sms.topic.queue\"<\/span>)<\/span>@Service<\/span><\/span>public<\/span> class<\/span> TopicSmsService<\/span> {<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u6d88\u606f\u63a5\u6536\u7684\u65b9\u6cd5<\/span><\/span>   *<\/span><\/span>   * @param message<\/span><\/span>   *\/<\/span><\/span>  @RabbitHandler<\/span><\/span>  public<\/span> void<\/span> receiveMessage<\/span>(String<\/span> message<\/span>) {<\/span>    \/\/\u53d1\u9001\u77ed\u4fe1<\/span><\/span><\/span><\/span>    System<\/span>.out<\/span>.println<\/span>(\"sms.topic\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
      4.1.3 \u65b0\u5efa\u90ae\u4ef6\u6d88\u8d39\u670d\u52a1<\/span><\/h3>\n
      @RabbitListener<\/span>(queues<\/span> =<\/span> \"email.topic.queue\"<\/span>)<\/span>@Service<\/span><\/span>public<\/span> class<\/span> TopicEmailService<\/span> {<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u6d88\u606f\u63a5\u6536\u7684\u65b9\u6cd5<\/span><\/span>   *<\/span><\/span>   * @param message<\/span><\/span>   *\/<\/span><\/span>  @RabbitHandler<\/span><\/span>  public<\/span> void<\/span> receiveMessage<\/span>(String<\/span> message<\/span>) {<\/span>    \/\/\u53d1\u9001\u90ae\u4ef6<\/span><\/span><\/span><\/span>    System<\/span>.out<\/span>.println<\/span>(\"email.topic\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
      4.1.4 \u65b0\u5efa\u5fae\u4fe1\u6d88\u8d39\u670d\u52a1<\/span><\/h3>\n
      @RabbitListener<\/span>(queues<\/span> =<\/span> \"wechat.topic.queue\"<\/span>)<\/span>@Service<\/span><\/span>public<\/span> class<\/span> TopicWechatService<\/span> {<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u6d88\u606f\u63a5\u6536\u7684\u65b9\u6cd5<\/span><\/span>   *<\/span><\/span>   * @param message<\/span><\/span>   *\/<\/span><\/span>  @RabbitHandler<\/span><\/span>  public<\/span> void<\/span> receiveMessage<\/span>(String<\/span> message<\/span>) {<\/span>    \/\/\u63a8\u9001\u5fae\u4fe1\u6d88\u606f<\/span><\/span><\/span><\/span>    System<\/span>.out<\/span>.println<\/span>(\"wechat.topic\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
      4.2 \u751f\u4ea7\u8005<\/span><\/h2>\n
      4.2.1 \u8c03\u6574\u670d\u52a1\u7c7b<\/span><\/h3>\n
        public<\/span> void<\/span> registerTopic<\/span>(String<\/span> username<\/span>, String<\/span> password<\/span>) {<\/span>    \/\/\u6a21\u62df\u7528\u6237\u6ce8\u518c<\/span><\/span>    String<\/span> userId<\/span> =<\/span> UUID<\/span>.randomUUID<\/span>().toString<\/span>();<\/span><\/span><\/span>    \/\/saveUser(user);<\/span><\/span><\/span><\/span>    rabbitTemplate<\/span>.convertAndSend<\/span>(\"topic_user_exchange\"<\/span>, \"*.sms.email.*\"<\/span>, userId<\/span> +<\/span> username<\/span>);<\/span>   }<\/span><\/pre>\n
      4.2.2 \u8c03\u6574\u6d4b\u8bd5\u7c7b<\/span><\/h3>\n
        @Test<\/span><\/span>  public<\/span> void<\/span> contextLoadsTopic<\/span>() {<\/span>    userService<\/span>.registerTopic<\/span>(\"\u738b\u4e94\"<\/span>, \"wangwu\"<\/span>);<\/span>   }<\/span><\/pre>\n
      4.3 \u6d4b\u8bd5<\/span><\/h2>\n
      \u542f\u52a8\u6d88\u8d39\u8005\u670d\u52a1\uff0c\u6267\u884c\u751f\u4ea7\u8005\u6d4b\u8bd5\u7c7bcontextLoadsTopic\uff0c\u6d88\u8d39\u8005\u6210\u529f\u6536\u5230\u6d88\u606f\u5e76\u6253\u5370<\/span><\/p>\n
      5 \u8bbe\u7f6e\u8fc7\u671f\u65f6\u95f4<\/span><\/h1>\n
      5.1 \u8c03\u6574\u6d88\u8d39\u8005\u914d\u7f6e\u7c7b<\/span><\/h2>\n
      \u8c03\u6574RabbitMqTopicConfig<\/strong><\/span><\/p>\n
        \/**<\/span><\/span>   * durable     \u521b\u5efa\u6301\u4e45\u5316\u961f\u5217phone.topic.queue<\/span><\/span>   * withArgument   \u8bbe\u7f6e\u6d88\u606f\u8fc7\u671f\u65f6\u95f460000\u6beb\u79d2<\/span><\/span>   *<\/span><\/span>   * @return<\/span><\/span>   *\/<\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Queue<\/span> phoneQueue<\/span>() {<\/span>    return<\/span> QueueBuilder<\/span>.durable<\/span>(\"phone.topic.queue\"<\/span>).withArgument<\/span>(\"x-message-ttl\"<\/span>, 60000<\/span>).build<\/span>();<\/span>   }<\/span><\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Binding<\/span> phoneBindingTopic<\/span>() {<\/span>    return<\/span> BindingBuilder<\/span>.bind<\/span>(phoneQueue<\/span>()).to<\/span>(topicExchange<\/span>()).with<\/span>(\"#.phone.#\"<\/span>);<\/span>   }<\/span><\/pre>\n
      5.2 \u6d4b\u8bd5<\/span><\/h2>\n
      \u542f\u52a8\u670d\u52a1\uff0cRabitMQ\u4e2d\u961f\u5217\u5982\u4e0b\uff0c\u961f\u5217\u6807\u8bc6\u4e3aTTL<\/span><\/p>\n
      6 \u6d88\u606f\u786e\u8ba4\u673a\u5236<\/span><\/h1>\n
      \u4ee5\u4e0b\u5747\u4e3a\u751f\u4ea7\u8005module\u7684\u8c03\u6574<\/strong><\/span><\/p>\n
      6.1 \u8c03\u6574\u751f\u4ea7\u8005yml<\/span><\/h2>\n
      server<\/span>:<\/span><\/span>  port<\/span>: <\/span>8090<\/span><\/span>#<\/span><\/span>#\u914d\u7f6eRabbitMQ\u670d\u52a1<\/span><\/span>spring<\/span>:<\/span><\/span>  rabbitmq<\/span>:<\/span><\/span>   username<\/span>: <\/span>guest<\/span>   password<\/span>: <\/span>guest<\/span>   virtual-host<\/span>: <\/span>\/<\/span>   host<\/span>: <\/span>127.0.0.1<\/span><\/span>   port<\/span>: <\/span>5672<\/span><\/span>  #none \u7981\u7528\u53d1\u5e03\u786e\u8ba4\u6a21\u5f0f\uff0c\u9ed8\u8ba4\u503c<\/span><\/span>  #correlated \u6d88\u606f\u6210\u529f\u53d1\u5e03\u5230\u4ea4\u6362\u673a\u540e\u4f1a\u89e6\u53d1\u56de\u8c03\u65b9\u6cd5<\/span><\/span>   publisher-confirm-type<\/span>: <\/span>correlated<\/span><\/pre>\n
      6.2 \u65b0\u5efa\u56de\u8c03\u65b9\u6cd5<\/span><\/h2>\n
      public<\/span> class<\/span> MessageConfirmCallback<\/span> implements<\/span> RabbitTemplate<\/span>.ConfirmCallback<\/span> {<\/span><\/span><\/span>  @Override<\/span><\/span>  public<\/span> void<\/span> confirm<\/span>(CorrelationData<\/span> correlationData<\/span>, boolean<\/span> b<\/span>, String<\/span> s<\/span>) {<\/span>    if<\/span> (b<\/span>) {<\/span>      System<\/span>.out<\/span>.println<\/span>(\"\u6d88\u606f\u786e\u8ba4\u6210\u529f\"<\/span>);<\/span>     } else<\/span> {<\/span>      System<\/span>.out<\/span>.println<\/span>(\"\u6d88\u606f\u786e\u8ba4\u5931\u8d25\"<\/span>);<\/span>     }<\/span>   }<\/span>}<\/span><\/pre>\n
      6.3 \u8c03\u6574\u670d\u52a1\u7c7b<\/span><\/h2>\n
        public<\/span> void<\/span> registerTopicCallback<\/span>(String<\/span> username<\/span>, String<\/span> password<\/span>) {<\/span>    \/\/\u6a21\u62df\u7528\u6237\u6ce8\u518c<\/span><\/span>    String<\/span> userId<\/span> =<\/span> UUID<\/span>.randomUUID<\/span>().toString<\/span>();<\/span><\/span><\/span>    \/\/saveUser(user);<\/span><\/span><\/span><\/span>    \/\/\u8bbe\u7f6e\u6d88\u606f\u786e\u8ba4<\/span><\/span>    rabbitTemplate<\/span>.setConfirmCallback<\/span>(new<\/span> MessageConfirmCallback<\/span>());<\/span>    rabbitTemplate<\/span>.convertAndSend<\/span>(\"topic_user_exchange\"<\/span>, \"*.sms.email.*\"<\/span>, userId<\/span> +<\/span> username<\/span>);<\/span>   }<\/span><\/pre>\n
      6.4 \u8c03\u6574\u6d4b\u8bd5\u7c7b<\/span><\/h2>\n
        @Test<\/span><\/span>  public<\/span> void<\/span> contextLoadsTopicCallback<\/span>() {<\/span>    userService<\/span>.registerTopicCallback<\/span>(\"\u5468\u516d\"<\/span>, \"zhouliu\"<\/span>);<\/span>   }<\/span><\/pre>\n
      \u6267\u884c\u6d4b\u8bd5\u7c7bcontextLoadsTopicCallback\uff0c\u6210\u529f\u8fdb\u5165\u56de\u8c03\u65b9\u6cd5<\/span><\/p>\n
      7 \u6b7b\u4fe1\u961f\u5217<\/span><\/h1>\n
      DLX\uff08Dead-Letter-Exchange\uff09\uff0c\u79f0\u4e3a\u6b7b\u4fe1\u4ea4\u6362\u673a\u6216\u6b7b\u4fe1\u90ae\u7bb1\u3002<\/span><\/p>\n
      \u5f53\u6d88\u606f\u5728\u4e00\u4e2a\u961f\u5217\u4e2d\u53d8\u6210\u6b7b\u4fe1\uff08dead message\uff09\u4e4b\u540e\uff0c\u5b83\u80fd\u88ab\u91cd\u65b0\u53d1\u9001\u5230\u53e6\u4e00\u4e2a\u4ea4\u6362\u673a\u4e2d\uff0c\u8fd9\u4e2a\u4ea4\u6362\u673a\u5c31\u662fDLX \uff0c\u7ed1\u5b9aDLX\u7684\u961f\u5217\u5c31\u662f\u6b7b\u4fe1\u961f\u5217\u3002<\/span><\/p>\n
      \u6d88\u606f\u53d8\u6210\u6b7b\u4fe1\uff0c\u53ef\u80fd\u662f\u7531\u4e8e\u4ee5\u4e0b\u7684\u539f\u56e0\uff1a<\/span><\/p>\n
        \n
      • \n
        \u6d88\u606f\u88ab\u62d2\u7edd<\/span><\/p>\n<\/li>\n
      • \n
        \u6d88\u606f\u8fc7\u671f<\/span><\/p>\n<\/li>\n
      • \n
        \u961f\u5217\u8fbe\u5230\u6700\u5927\u957f\u5ea6<\/span><\/p>\n<\/li>\n<\/ul>\n
        DLX\u4e5f\u662f\u4e00\u4e2a\u6b63\u5e38\u7684\u4ea4\u6362\u673a\uff0c\u548c\u4e00\u822c\u7684\u4ea4\u6362\u673a\u6ca1\u6709\u533a\u522b\uff0c\u5b83\u80fd\u5728\u4efb\u4f55\u7684\u961f\u5217\u4e0a\u88ab\u6307\u5b9a\uff0c\u5b9e\u9645\u4e0a\u5c31\u662f\u8bbe\u7f6e\u67d0\u4e00\u4e2a\u961f\u5217\u7684\u5c5e\u6027\u3002<\/span><\/p>\n
        \u5f53\u8fd9\u4e2a\u961f\u5217\u4e2d\u5b58\u5728\u6b7b\u4fe1\u65f6\uff0cRabbitMQ\u5c31\u4f1a\u81ea\u52a8\u5c06\u8fd9\u4e2a\u6d88\u606f\u91cd\u65b0\u53d1\u5e03\u5230\u8bbe\u7f6e\u7684DLX\u4e0a\u53bb\uff0c\u8fdb\u800c\u88ab\u8def\u7531\u5230\u53e6\u4e00\u4e2a\u961f\u5217\uff0c\u5373\u6b7b\u4fe1\u961f\u5217\u3002<\/span><\/p>\n
        \u5728\u5b9a\u4e49\u961f\u5217\u7684\u65f6\u5019\u8bbe\u7f6e\u961f\u5217\u53c2\u6570 <\/span>x-dead-letter-exchange<\/code><\/span> \u6307\u5b9a\u4ea4\u6362\u673a\u5373\u53ef\u8bbe\u7f6e\u4e3a\u6b7b\u4fe1\u961f\u5217\u3002<\/span><\/p>\n
        7.1 \u8c03\u6574\u6d88\u8d39\u8005\u914d\u7f6e\u7c7b<\/span><\/h2>\n
        \u8c03\u6574RabbitMqTopicConfig<\/strong><\/span><\/p>\n
          @Bean<\/span><\/span>  public<\/span> Queue<\/span> dlxQueue<\/span>() {<\/span>    return<\/span> new<\/span> Queue<\/span>(\"dlx.topic.queue\"<\/span>, true<\/span>);<\/span>   }<\/span><\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Queue<\/span> vipQueue<\/span>() {<\/span>    return<\/span> QueueBuilder<\/span>.durable<\/span>(\"vip.topic.queue\"<\/span>)<\/span>         .withArgument<\/span>(\"x-message-ttl\"<\/span>, 60000<\/span>)<\/span>         .withArgument<\/span>(\"x-dead-letter-exchange\"<\/span>, \"dlx.topic.queue\"<\/span>)<\/span>         .build<\/span>();<\/span>   }<\/span><\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Binding<\/span> dlxBindingTopic<\/span>() {<\/span>    return<\/span> BindingBuilder<\/span>.bind<\/span>(dlxQueue<\/span>()).to<\/span>(topicExchange<\/span>()).with<\/span>(\"#.#\"<\/span>);<\/span>   }<\/span><\/span><\/span>  @Bean<\/span><\/span>  public<\/span> Binding<\/span> vipBindingTopic<\/span>() {<\/span>    return<\/span> BindingBuilder<\/span>.bind<\/span>(vipQueue<\/span>()).to<\/span>(topicExchange<\/span>()).with<\/span>(\"#.vip.#\"<\/span>);<\/span>   }<\/span><\/pre>\n
        7.2 \u6d4b\u8bd5<\/span><\/h2>\n
        \u542f\u52a8\u670d\u52a1\uff0cRabitMQ\u4e2d\u961f\u5217\u5982\u4e0b\uff0c\u961f\u5217\u6807\u8bc6\u4e3aDLX<\/span><\/p>\n
        7.3 \u8c03\u6574\u751f\u4ea7\u8005\u670d\u52a1\u7c7b<\/span><\/h2>\n
          public<\/span> void<\/span> registerTopicDlx<\/span>(String<\/span> username<\/span>, String<\/span> password<\/span>) {<\/span>    \/\/\u6a21\u62df\u7528\u6237\u6ce8\u518c<\/span><\/span>    String<\/span> userId<\/span> =<\/span> UUID<\/span>.randomUUID<\/span>().toString<\/span>();<\/span><\/span><\/span>    \/\/saveUser(user);<\/span><\/span><\/span><\/span>    rabbitTemplate<\/span>.convertAndSend<\/span>(\"topic_user_exchange\"<\/span>, \"*.vip.*\"<\/span>, userId<\/span> +<\/span> username<\/span>);<\/span>   }<\/span><\/pre>\n
        7.4 \u8c03\u6574\u751f\u4ea7\u8005\u6d4b\u8bd5\u7c7b<\/span><\/h2>\n
          @Test<\/span><\/span>  public<\/span> void<\/span> contextLoadsTopicDlx<\/span>() {<\/span>    userService<\/span>.registerTopicDlx<\/span>(\"\u94b1\u4e03\"<\/span>, \"qianqi\"<\/span>);<\/span>   }<\/span><\/pre>\n
        7.5 \u6d4b\u8bd5<\/span><\/h2>\n
        \u5173\u95ed\u6d88\u8d39\u8005\u670d\u52a1<\/strong><\/span>\uff0c\u6267\u884c\u751f\u4ea7\u8005\u6d4b\u8bd5\u7c7bcontextLoadsTopicDlx<\/span><\/p>\n
        \u672a\u8fc7\u671f\u524d<\/span><\/p>\n
        \u8fc7\u671f\u540e<\/span><\/p>\n
        7.6 \u65b0\u5efa\u6b7b\u4fe1\u6d88\u8d39\u670d\u52a1<\/span><\/h2>\n
        \u6d88\u8d39\u8005\u65b0\u5efa<\/span><\/p>\n
        @RabbitListener<\/span>(queues<\/span> =<\/span> \"dlx.topic.queue\"<\/span>)<\/span>@Service<\/span><\/span>public<\/span> class<\/span> TopicDlxService<\/span> {<\/span><\/span><\/span>  \/**<\/span><\/span>   * \u6d88\u606f\u63a5\u6536\u7684\u65b9\u6cd5<\/span><\/span>   *<\/span><\/span>   * @param message<\/span><\/span>   *\/<\/span><\/span>  @RabbitHandler<\/span><\/span>  public<\/span> void<\/span> receiveMessage<\/span>(String<\/span> message<\/span>) {<\/span>    System<\/span>.out<\/span>.println<\/span>(\"dlx.topic\uff1a\"<\/span> +<\/span> message<\/span>);<\/span>   }<\/span>}<\/span><\/pre>\n
        7.7 \u6d4b\u8bd5<\/span><\/h2>\n
        \u518d\u542f\u52a8\u6d88\u8d39\u8005\u670d\u52a1\uff0c\u6210\u529f\u63a5\u6536\u6b7b\u4fe1\u961f\u5217\u4e2d\u6d88\u606f<\/span><\/p>\n
        RabbitMQ\u4e2d\u6d88\u606f\u961f\u5217\u5982\u4e0b<\/span><\/p>\n
        \u81f3\u6b64\uff0cSpringBoot\u6210\u529f\u6574\u5408RabbitMQ\u4e14\u6d4b\u8bd5\u901a\u8fc7\uff0c\u96c6\u7fa4\u3001\u5206\u5e03\u5f0f\u4e8b\u52a1\u7b49\u7528\u6cd5\u656c\u8bf7\u7b49\u5f85\u540e\u7eed\u3002<\/span><\/p>\n
        \n
        \n
        CSDN\uff1a<\/span>https:\/\/blog.csdn.net\/dkbnull\/article\/details\/137995945<\/span><\/span><\/p>\n
        \n
        <\/mp-style-type><\/p>\n
        \n
        \u672c\u7bc7\u6587\u7ae0\u6765\u6e90\u4e8e\u5fae\u4fe1\u516c\u4f17\u53f7:                 \u7a0b\u5e8f\u5458null              <\/p>\n<\/blockquote>\n<\/div>\n","raw":"","protected":false},"excerpt":{"rendered":"
        \u5982\u679c\u6587\u7ae0\u4e2d\u4ee3\u7801\u4e0d\u4fbf\u4e8e\u9605\u8bfb\uff0c\u8bf7\u4f7f\u7528\u7535\u8111\u67e5\u770b\u6216\u70b9\u51fb\u9605\u8bfb\u539f\u6587\u3002\u6e90\u7801\u8be6\u89c1\uff1a GitHub\uff1ahttps:\/\/github.com\/dkbnu …<\/p>\n","protected":false},"author":1,"featured_media":4217,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"emotion":"","emotion_color":"","title_style":"","license":"","footnotes":""},"categories":[31,7],"tags":[],"class_list":["post-4238","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-rabbitmq","category-spring-boot"],"post_thumbnail_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151826141-150x150.jpeg","content_first_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151830966.png","post_medium_image_300":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151826141-300x127.jpeg","post_thumbnail_image_624":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151826141-1024x435.jpeg","post_frist_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151830966.png","post_medium_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151826141-300x127.jpeg","post_large_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151826141-1024x435.jpeg","post_full_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151826141.jpeg","post_all_images":[{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151830966.png","id":"image0"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151830966.png","id":"image1"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151834355.png","id":"image2"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151834355.png","id":"image3"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151838382.png","id":"image4"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151838382.png","id":"image5"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151841992.png","id":"image6"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151841992.png","id":"image7"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151843816.png","id":"image8"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151843816.png","id":"image9"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151846217.png","id":"image10"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151846217.png","id":"image11"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151848165.png","id":"image12"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151848165.png","id":"image13"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151850928.png","id":"image14"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151850928.png","id":"image15"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151853301.png","id":"image16"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151853301.png","id":"image17"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151855296.png","id":"image18"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151855296.png","id":"image19"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151857374.png","id":"image20"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151857374.png","id":"image21"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151859284.png","id":"image22"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151859284.png","id":"image23"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151901141.png","id":"image24"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151901141.png","id":"image25"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151903115.png","id":"image26"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151903115.png","id":"image27"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151906789.png","id":"image28"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151906789.png","id":"image29"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151909843.png","id":"image30"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151909843.png","id":"image31"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151911277.png","id":"image32"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151911277.png","id":"image33"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151913396.png","id":"image34"},{"imagesurl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2024\/05\/20240524151913396.png","id":"image35"}],"videoAdId":"","listAd":"0","listAdId":"","listAdEvery":6,"total_comments":0,"category_name":"RabbitMQ","post_date":"2024-04-20","like_count":"0","praiseWord":"\u9f13\u52b1","copyright_state":"","excitationAd":"0","rewardedVideoAdId":"","detailAdId":"","detailAd":"0","enterpriseMinapp":"0","audios":[],"postImageUrl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230519082947553.jpg","avatarurls":[],"related_posts":null,"pageviews":587,"next_post_id":3935,"next_post_title":"springboot\u6574\u5408mqtt\u5b9e\u73b0\u6d88\u606f\u53d1\u9001\u548c\u6d88\u8d39\uff0c\u4ee5\u53ca\u5ba2\u6237\u7aef\u65ad\u7ebf\u91cd\u8fde\u4e4b\u540e\u7684\u6d88\u606f\u6062\u590d","previous_post_id":3958,"previous_post_title":"\u5904\u7406\u8bf7\u6c42\u5934\uff1a@RequestHeader\u6ce8\u89e3\u7684\u4f7f\u7528","_links":{"self":[{"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/posts\/4238","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/comments?post=4238"}],"version-history":[{"count":0,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/posts\/4238\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/media\/4217"}],"wp:attachment":[{"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/media?parent=4238"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/categories?post=4238"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/tags?post=4238"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}