wordpress改网站logo,世界500强企业名字,wordpress预约页面,杭州网站推广怎样做说明#xff1a;Topic主题交换机它的大致流程是交换机和一个或者多个队列绑定#xff0c;这个绑定的Routingkey是包含通配符的#xff0c;满足通配符的队列会接收到消息。
通配符规则#xff1a;
##xff1a;匹配一个或多个词
*#xff1a;匹配一个词
例如#xff…说明Topic主题交换机它的大致流程是交换机和一个或者多个队列绑定这个绑定的Routingkey是包含通配符的满足通配符的队列会接收到消息。
通配符规则
#匹配一个或多个词
*匹配一个词
例如
topic.#能匹配 topic.xxx 或者 topic.xxx.xxx
topic.*只能匹配 topic.xxx
工程图 A.总体maven依赖
pom.xml
?xml version1.0 encodingUTF-8?project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersionparentartifactIdspring-boot-starter-parent/artifactId !-- 被继承的父项目的构件标识符 --groupIdorg.springframework.boot/groupId !-- 被继承的父项目的全球唯一标识符 --version2.2.2.RELEASE/version !-- 被继承的父项目的版本 --relativePath/ !-- lookup parent from repository --/parentgroupIdRabbitMqSpringbootDemo/groupIdartifactIdRabbitMqSpringbootDemo/artifactIdversion1.0-SNAPSHOT/versionpackagingpom/packagingmodulesmoduleMqCustomer/modulemoduleMqProducer/module/modulesnameRabbitMqSpringbootDemo Maven Webapp/name!-- FIXME change it to the projects website --urlhttp://www.example.com/urlpropertiesproject.build.sourceEncodingUTF-8/project.build.sourceEncodingmaven.compiler.source1.8/maven.compiler.sourcemaven.compiler.target1.8/maven.compiler.target/propertiesdependencies/dependenciesbuildfinalNameRabbitMqSpringbootDemo/finalNamepluginManagement!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) --pluginspluginartifactIdmaven-clean-plugin/artifactIdversion3.1.0/version/plugin!-- see http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_war_packaging --pluginartifactIdmaven-resources-plugin/artifactIdversion3.0.2/version/pluginpluginartifactIdmaven-compiler-plugin/artifactIdversion3.8.0/version/pluginpluginartifactIdmaven-surefire-plugin/artifactIdversion2.22.1/version/pluginpluginartifactIdmaven-war-plugin/artifactIdversion3.2.2/version/pluginpluginartifactIdmaven-install-plugin/artifactIdversion2.5.2/version/pluginpluginartifactIdmaven-deploy-plugin/artifactIdversion2.8.2/version/plugin/plugins/pluginManagement/build
/projectB.生产者
1.pom.xml
?xml version1.0 encodingUTF-8?project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdparentartifactIdRabbitMqSpringbootDemo/artifactIdgroupIdRabbitMqSpringbootDemo/groupIdversion1.0-SNAPSHOT/version/parentmodelVersion4.0.0/modelVersionartifactIdMqProducer/artifactIdpackagingjar/packagingnameMqProducer Maven Webapp/name!-- FIXME change it to the projects website --urlhttp://www.example.com/urlpropertiesproject.build.sourceEncodingUTF-8/project.build.sourceEncodingmaven.compiler.source1.8/maven.compiler.sourcemaven.compiler.target1.8/maven.compiler.target/propertiesdependencies!--spring boot核心--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter/artifactId/dependency!--spring boot 测试--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency!--springmvc web--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependency!--开发环境调试--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-devtools/artifactIdoptionaltrue/optional/dependency!--amqp 支持--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId/dependencydependencygroupIdcom.alibaba/groupIdartifactIdfastjson/artifactIdversion1.2.78/version/dependency!-- commons-lang3 --dependencygroupIdorg.apache.commons/groupIdartifactIdcommons-lang3/artifactIdversion3.4/version/dependency!--lombok--dependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdversion1.16.10/version/dependency/dependenciesbuildfinalNameMqProducer/finalNamepluginManagement!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) --pluginspluginartifactIdmaven-clean-plugin/artifactIdversion3.1.0/version/plugin!-- see http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_war_packaging --pluginartifactIdmaven-resources-plugin/artifactIdversion3.0.2/version/pluginpluginartifactIdmaven-compiler-plugin/artifactIdversion3.8.0/version/pluginpluginartifactIdmaven-surefire-plugin/artifactIdversion2.22.1/version/pluginpluginartifactIdmaven-war-plugin/artifactIdversion3.2.2/version/pluginpluginartifactIdmaven-install-plugin/artifactIdversion2.5.2/version/pluginpluginartifactIdmaven-deploy-plugin/artifactIdversion2.8.2/version/plugin/plugins/pluginManagement/build
/project2.application.yml
server:port: 8080
spring:rabbitmq:port: 5672host: 192.168.18.145username: adminpassword: adminvirtual-host: /3.TopicRabbitConfig
package com.dev.config;import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** 类名称主题交换机的使用** author lqw* date 2024年02月28日 10:40*/
Configuration
public class TopicRabbitConfig {//绑定键public final static String high topic.highSchool.one;public final static String middle topic.middleSchool.one;Beanpublic Queue oneQueue() {return new Queue(TopicRabbitConfig.high);}Beanpublic Queue twoQueue() {return new Queue(TopicRabbitConfig.middle);}BeanTopicExchange exchange() {return new TopicExchange(topicExchange);}BeanBinding bindingExchangeMessageA() {return BindingBuilder.bind(oneQueue()).to(exchange()).with(topic.highSchool.#);}BeanBinding bindingExchangeMessageB() {return BindingBuilder.bind(twoQueue()).to(exchange()).with(topic.middleSchool.#);}}4.TopicRabbitController
package com.dev.controller;import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.HashMap;
import java.util.Map;/*** 类名称主题交换机 消息生产者** author lqw* date 2024年02月27日 14:47*/
Slf4j
RestController
RequestMapping(topic)
public class TopicRabbitController {AutowiredRabbitTemplate rabbitTemplate; //使用RabbitTemplate,这提供了接收/发送等等方法/*** topic测试* return*/GetMapping(/sendMessageA)//匹配到 topic.highSchool.onepublic String sendMessageA() {MapString,Object map new HashMap();map.put(name,张龙);map.put(school,高中);rabbitTemplate.convertAndSend(topicExchange, topic.highSchool.two, map);return ok;}GetMapping(/sendMessageB)//匹配到 topic.middleSchool.onepublic String sendMessageB() {MapString,Object map new HashMap();map.put(name,赵虎);map.put(school,初中);rabbitTemplate.convertAndSend(topicExchange, topic.middleSchool.two, map);return ok;}GetMapping(/sendMessageBB)//匹配到 topic.middleSchool.onepublic String sendMessageBB() {MapString,Object map new HashMap();map.put(name,赵虎B);map.put(school,初中B);rabbitTemplate.convertAndSend(topicExchange, topic.middleSchool.two.cc, map);return ok;}}
5.AppP
package com.dev;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;/*** 类名称** author 李庆伟* date 2024年02月27日 14:20*/
SpringBootApplication
public class AppP {public static void main(String[] args) {SpringApplication.run(AppP.class);}
}C.消费者
1.pom.xml
?xml version1.0 encodingUTF-8?project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdparentartifactIdRabbitMqSpringbootDemo/artifactIdgroupIdRabbitMqSpringbootDemo/groupIdversion1.0-SNAPSHOT/version/parentmodelVersion4.0.0/modelVersionartifactIdMqCustomer/artifactIdpackagingjar/packagingnameMqCustomer Maven Webapp/name!-- FIXME change it to the projects website --urlhttp://www.example.com/urlpropertiesproject.build.sourceEncodingUTF-8/project.build.sourceEncodingmaven.compiler.source1.8/maven.compiler.sourcemaven.compiler.target1.8/maven.compiler.target/propertiesdependencies!--spring boot核心--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter/artifactId/dependency!--spring boot 测试--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency!--springmvc web--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependency!--开发环境调试--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-devtools/artifactIdoptionaltrue/optional/dependency!--amqp 支持--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId/dependency!-- commons-lang3 --dependencygroupIdorg.apache.commons/groupIdartifactIdcommons-lang3/artifactIdversion3.4/version/dependency!--lombok--dependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdversion1.16.10/version/dependency/dependenciesbuildfinalNameMqCustomer/finalNamepluginManagement!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) --pluginspluginartifactIdmaven-clean-plugin/artifactIdversion3.1.0/version/plugin!-- see http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_war_packaging --pluginartifactIdmaven-resources-plugin/artifactIdversion3.0.2/version/pluginpluginartifactIdmaven-compiler-plugin/artifactIdversion3.8.0/version/pluginpluginartifactIdmaven-surefire-plugin/artifactIdversion2.22.1/version/pluginpluginartifactIdmaven-war-plugin/artifactIdversion3.2.2/version/pluginpluginartifactIdmaven-install-plugin/artifactIdversion2.5.2/version/pluginpluginartifactIdmaven-deploy-plugin/artifactIdversion2.8.2/version/plugin/plugins/pluginManagement/build
/project2.application.yml
server:port: 8081spring:rabbitmq:port: 5672host: 192.168.18.145username: adminpassword: admin3.TopicRabbitListenerA
package cn.ct.listeners;import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;import java.util.Map;/*** 类名称主题交换机消息消费者* 直连* author lqw* date 2024年02月27日 14:58*/
Component
public class TopicRabbitListenerA {RabbitListener(queues topic.highSchool.one)RabbitHandlerpublic void process(Map msg) {System.out.println(Rabbitmq topic : msg);System.out.println(Rabbitmq topic : msg);}}4.TopicRabbitListenerB
package cn.ct.listeners;import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;import java.util.Map;/*** 类名称主题交换机消息消费者* 直连* author lqw* date 2024年02月27日 14:58*/
Component
public class TopicRabbitListenerB {RabbitListener(queues topic.middleSchool.one)RabbitHandlerpublic void process(Map msg) {System.out.println(Rabbitmq topic : msg);System.out.println(Rabbitmq topic : msg);}}5.AppC
package cn.ct;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;/*** 类名称** author lqw* date 2024年02月27日 14:20*/
SpringBootApplication
public class AppC {public static void main(String[] args) {SpringApplication.run(AppC.class);}
}
