大气简约企业网站模板免费下载,泰国网站后缀,iis网站改端口,营销公司官网前置条件先安装好RocketMQ
希望在Window10安装rocketMQ并简单使用#xff0c;可以参考如下文章#xff1a;
Window10安装rocketMQ并简单使用-CSDN博客
1、pom.xml文件里面加上依赖
dependencygroupIdorg.apache.rocketmq/groupIdartifactId可以参考如下文章
Window10安装rocketMQ并简单使用-CSDN博客
1、pom.xml文件里面加上依赖
dependencygroupIdorg.apache.rocketmq/groupIdartifactIdrocketmq-spring-boot-starter/artifactIdversion2.2.3/version/dependency
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 https://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersionparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion2.6.4/versionrelativePath/ !-- lookup parent from repository --/parentgroupIdcom.hmblogs/groupIdartifactIdhmblogs/artifactIdversion0.0.1-SNAPSHOT/versionnamehmblogs/namedescriptionhmblogs/descriptionpropertiesjava.version8/java.versiondruid.version1.2.8/druid.versionlog4jdbc.version1.16/log4jdbc.versiones.version7.9.2/es.versioneasyexcel.version3.3.4/easyexcel.versionredisson.version2.15.2/redisson.version/propertiesdependenciesdependencygroupIdorg.apache.rocketmq/groupIdartifactIdrocketmq-spring-boot-starter/artifactIdversion2.2.3/version/dependency!-- 操作minio的java客户端--dependencygroupIdio.minio/groupIdartifactIdminio/artifactIdversion8.2.1/version/dependency!-- jwt鉴权相应依赖--dependencygroupIdch.qos.logback/groupIdartifactIdlogback-classic/artifactIdversion1.2.3/version/dependencydependencygroupIdio.jsonwebtoken/groupIdartifactIdjjwt-jackson/artifactIdversion0.11.2/version/dependencydependencygroupIdcn.hutool/groupIdartifactIdhutool-all/artifactIdversion5.8.16/version/dependencydependencygroupIdorg.redisson/groupIdartifactIdredisson/artifactIdversion${redisson.version}/version/dependencydependencygroupIdcom.alibaba/groupIdartifactIdeasyexcel/artifactIdversion${easyexcel.version}/version/dependencydependencygroupIdorg.redisson/groupIdartifactIdredisson/artifactIdversion3.16.0/version/dependency!-- druid数据源驱动 --dependencygroupIdcom.alibaba/groupIdartifactIddruid-spring-boot-starter/artifactIdversion${druid.version}/version/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency!-- mybatis --dependencygroupIdcom.baomidou/groupIdartifactIdmybatis-plus-boot-starter/artifactIdversion3.5.3.1/version/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactId/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdoptionaltrue/optional/dependency!--Mysql依赖包--dependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdscoperuntime/scope/dependency!--lombok插件--dependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdoptionaltrue/optional/dependency!--监控sql日志--dependencygroupIdorg.bgee.log4jdbc-log4j2/groupIdartifactIdlog4jdbc-log4j2-jdbc4.1/artifactIdversion${log4jdbc.version}/version/dependencydependencygroupIdcom.alibaba/groupIdartifactIdfastjson/artifactIdversion1.2.9/version/dependencydependencygroupIdredis.clients/groupIdartifactIdjedis/artifactId/dependencydependencygroupIdorg.apache.kafka/groupIdartifactIdkafka-clients/artifactId/dependencydependencygroupIdorg.springframework.kafka/groupIdartifactIdspring-kafka/artifactId/dependency!-- high client--dependencygroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-high-level-client/artifactIdversion${es.version}/versionexclusionsexclusiongroupIdorg.elasticsearch/groupIdartifactIdelasticsearch/artifactId/exclusionexclusiongroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-client/artifactId/exclusion/exclusions/dependency!-- rest-high-level-client 依赖如下2个jar --dependencygroupIdorg.elasticsearch/groupIdartifactIdelasticsearch/artifactIdversion${es.version}/version/dependencydependencygroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-client/artifactIdversion${es.version}/version/dependencydependencygroupIdjunit/groupIdartifactIdjunit/artifactId/dependency!-- dependency--
!-- groupIdorg.springframework.boot/groupId--
!-- artifactIdspring-boot-starter-data-mongodb/artifactId--
!-- /dependency--!-- spring需要依赖日志文件--dependencygroupIdcommons-logging/groupIdartifactIdcommons-logging/artifactIdversion1.2/version/dependency!-- dependency--
!-- groupIdorg.aspectj/groupId--
!-- artifactIdaspectjweaver/artifactId--
!-- version1.9.0/version--
!-- /dependency--
!-- dependency--
!-- groupIdorg.aspectj/groupId--
!-- artifactIdaspectjrt/artifactId--
!-- version1.9.0/version--
!-- /dependency--dependencygroupIdcom.googlecode.aviator/groupIdartifactIdaviator/artifactIdversion5.3.0/version/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-aop/artifactId/dependencydependencygroupIdcn.hutool/groupIdartifactIdhutool-all/artifactIdversion5.8.16/version/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-cache/artifactId/dependencydependencygroupIdcom.googlecode.xmemcached/groupIdartifactIdxmemcached/artifactIdversion2.4.7/version/dependencydependencygroupIdnet.spy/groupIdartifactIdspymemcached/artifactIdversion2.10.3/version/dependency/dependenciesbuildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactId/plugin/plugins/build/project2、application.yml配置文件需要加上如下配置
rocketmq:name-server: 127.0.0.1:9876producer:group: superman-producer-group
该配置文件全部内容如下
server:port: 8081servlet.context-path: /hmblogs#配置数据源
spring:datasource:druid:db-type: com.alibaba.druid.pool.DruidDataSourcedriverClassName: net.sf.log4jdbc.sql.jdbcapi.DriverSpyurl: jdbc:log4jdbc:mysql://${DB_HOST:localhost}:${DB_PORT:3306}/${DB_NAME:hmblogs}?useSSLtrueallowPublicKeyRetrievaltrueserverTimezoneUTCusername: ${DB_USER:root}password: ${DB_PWD:demo}redis:host: localhostport: 6379password: hemingdatabase: 10
# data:
# mongodb:
# host: 43.138.0.199
# port: 27017
# username: hmblogs
# password: demo
# database: hmblogs
# authentication-database: adminservlet:multipart:max-file-size: 10MBmax-request-size: 10MB#minio配置minio:access-key: Irr1hKVWRacP91HAqJ60secret-key: demourl: http://localhost:9000 #访问地址bucket-name: hmblogs-bucketes:host: 43.138.0.199port: 9200scheme: httpuser: elasticpassword: democaptcha:width: 200height: 100rocketmq:name-server: 127.0.0.1:9876producer:group: superman-producer-group
3、生产者代码如下
package com.hmblogs.backend.controller;import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
RestController
RequestMapping(/mq)
Slf4j
public class MqProducerController {Autowiredprivate RocketMQTemplate rocketMQTemplate;RequestMapping(/producer)public String producer(RequestParam(msg) String msg){log.info(我要发消息msg);rocketMQTemplate.convertAndSend(first-topic,你好 msg);return connected;}
}
4、消费者代码如下
package com.hmblogs.backend.util;import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;Component
RocketMQMessageListener(topic first-topic, consumerGroup superman-consumer-group)
Slf4j
public class MqConsumer implements RocketMQListenerString {Overridepublic void onMessage(String message) {log.info(我的RocketMQ接收到的消息为message);//在此处添加自己要加的逻辑}
}
5、调用生产者的生产消息接口 查看日志发现打印的日志符合预期 调用生产者的生产消息接口msg参数换一下 查看日志发现打印的日志符合预期
