SpringBoot+RocketMq+Mybatis项目整合demo

最新推荐文章于 2025-04-14 23:40:41 发布
最新推荐文章于 2025-04-14 23:40:41 发布
阅读量1.2k 收藏 1
点赞数 3
分类专栏： springBoot rocketMq 文章标签： spring boot
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/mikewuhao/article/details/106666109
版权

Demo实现的功能

项目启动生产者和消费者2个服务后, 生产者端执行用户查询, 从数据库查出用户数据后, 发送给消息中间件rocketMq, 消费者监听到mq消息后获取到用户数据.

github源码地址

https://github.com/mikewuhao/soringBoot-mq-demo/

搭建详细步骤

1. 准备工作
提前把rocketMq环境搭建和启动好, rocketMq可视化工具安装启动好.
(本人mac环境部署rocketMq,参考https://www.jianshu.com/p/a759e8ea6ac1)
(windows环境部署rocketMq,参考https://www.cnblogs.com/darendu/p/12036380.html)

注意: 按照官方启动rocketMq ,可能会报运行环境内存不足,建议修改内存, 参考: https://blog.csdn.net/u014803081/article/details/90705792?utm_medium=distribute.pc_relevant.none-task-blog-baidujs-6

2. 项目结构
在这里插入图片描述
在idea开发工具里面先建普通空的project, 命名为springBoot-mq-demo, 再新建2个maven类型的module, 分别命名 consumer(消费者服务), provider(生产者服务).
3. provider生产者服务创建
3.1 provider服务目录结构
在这里插入图片描述
3.2 provider服务的pom文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.wuhao.demo</groupId>
    <artifactId>provider</artifactId>
    <version>1.0-SNAPSHOT</version>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.7.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!-- spring-boot整合mybatis -->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.1.1</version>
        </dependency>

        <!-- mysql驱动 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.6</version>
        </dependency>

        <!--rocketMq-->
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-common</artifactId>
            <version>4.4.0</version>
        </dependency>

        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-client</artifactId>
            <version>4.4.0</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>

        <!--lombok-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.0</version>
            <scope>provided</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

3.3 provider服务的application.properties

server.port=8082

logging.level.org.springframework=DEBUG

#数据库
spring.datasource.driver-class-name= com.mysql.jdbc.Driver
spring.datasource.url = jdbc:mysql://127.0.0.1:3306/boot?useUnicode=true&characterEncoding=utf-8
spring.datasource.username = root
spring.datasource.password = root

#mybatis
mybatis.type-aliases-package=com.wuhao.domain
mybatis.mapper-locations=classpath:mapper/*.xml

#Rocketmq producer
rocketmq.producer.groupName=ProducerGroup
rocketmq.producer.namesrvAddr=127.0.0.1:9876
rocketmq.producer.instanceName=ProducerGroup
rocketmq.producer.topic=topic2020
rocketmq.producer.tag=test
rocketmq.producer.maxMessageSize=131072
rocketmq.producer.sendMsgTimeout=10000

3.4 provider服务的启动类, ProviderApplication

package com.wuhao;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class ProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
    }

}

3.5 provider服务的controller, MqController

package com.wuhao.controller;

import com.alibaba.fastjson.JSONObject;
import com.wuhao.domain.User;
import com.wuhao.mq.RocketMQProducer;
import com.wuhao.service.UserService;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.text.SimpleDateFormat;
import java.util.Date;
/**
 * @author wuhao
 * @Title: MqController
 * @Description: Mq测试 controller
 * @date 2020/6/9 17:38
 */
@RestController
@Slf4j
public class MqController {
    @Autowired
    @Qualifier("rocketMQProducer")
    RocketMQProducer rocketMQProducer;

    @Autowired
    private UserService userService;

    @GetMapping("/testSend")
    public void testSend() {

        DefaultMQProducer producer = rocketMQProducer.getRocketMQProducer();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        User user = userService.queryUserById(1L);
        String body = "hi RocketMQ, now is  " + sdf.format(new Date()) + "---"+ JSONObject.toJSONString(user);
        Message message = new Message("topic2020", "test", body.getBytes());
        try {
            producer.send(message);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

3.6 provider服务的mq配置类, RocketMQProducer

package com.wuhao.mq;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author wuhao
 * @Title: RocketMQProducer
 * @Description: 消息生产者
 * @date 2020/6/9 17:31
 */
@Configuration
@Slf4j
public class RocketMQProducer {

    @Value("${rocketmq.producer.groupName}")
    private String groupName;

    @Value("${rocketmq.producer.namesrvAddr}")
    private String nameserAddr;

    @Value("${rocketmq.producer.instanceName}")
    private String instanceName;

    @Value("${rocketmq.producer.maxMessageSize}")
    private int maxMessageSize;

    @Value("${rocketmq.producer.sendMsgTimeout}")
    private int sendMsgTimeout;

    @Bean(initMethod = "start", destroyMethod = "shutdown")
    public DefaultMQProducer getRocketMQProducer() {
        DefaultMQProducer producer = new DefaultMQProducer(groupName);
        producer.setNamesrvAddr(nameserAddr);
        producer.setInstanceName(instanceName);
        producer.setMaxMessageSize(maxMessageSize);
        producer.setSendMsgTimeout(sendMsgTimeout);
        producer.setVipChannelEnabled(false);
        log.info("================>生产者创建完成，ProducerGroupName{}<================", groupName);
        return producer;
    }

}

3.7 provider服务的实体类, User

package com.wuhao.domain;

import lombok.AllArgsConstructor;
import lombok.NoArgsConstructor;

import javax.persistence.*;

/**
 * @Description: User实体
 * @CreateDate: 2020-02-04 19:25
 * @Author: wuhao
 */
@Entity
@NoArgsConstructor
@AllArgsConstructor
public class User {


    @Id
    @GeneratedValue
    private Long id;

    @Column(name = "username")
    private String username;

    @Column(name = "birthday")
    private String birthday;

    @Column(name = "sex")
    private String sex;

    @Column(name = "address")
    private String address;

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getBirthday() {
        return birthday;
    }

    public void setBirthday(String birthday) {
        this.birthday = birthday;
    }

    public String getSex() {
        return sex;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }

    public String getAddress() {
        return address;
    }

    public void setAddress(String address) {
        this.address = address;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", username='" + username + '\'' +
                ", birthday='" + birthday + '\'' +
                ", sex='" + sex + '\'' +
                ", address='" + address + '\'' +
                '}';
    }

}

3.8 provider服务的接口

package com.wuhao.service;

import com.wuhao.domain.User;

/**
 * @Description: User的Service
 * @CreateDate: 2020-06-09 09:35
 * @Author: wuhao
 */
public interface UserService {

    User queryUserById(Long id);

    int addUser(User user);

    int modifyUser(User user);

    int deleteUserById(Long id);

}

3.8 provider服务的接口实现类

package com.wuhao.service.impl;

import com.wuhao.domain.User;
import com.wuhao.dao.UserMapper;
import com.wuhao.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * @Description:User的Service实现类
 * @CreateDate: 2020-02-05 09:36
 * @Author: wuhao
 */
@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    @Override
    public User queryUserById(Long id) {
        return userMapper.queryUserById(id);
    }

    @Override
    public int addUser(User user) {
        return userMapper.addUser(user);

    }

    @Override
    public int modifyUser(User user) {
        return userMapper.modifyUser(user);
    }

    @Override
    public int deleteUserById(Long id) {
        return userMapper.deleteUserById(id);
    }

 }

3.9 provider服务的Dao层, UserMapper

package com.wuhao.dao;

import com.wuhao.domain.User;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;

/**
 * @Description: user的mapper
 * @CreateDate: 2020-06-04 19:38
 * @Author: wuhao
 */
@Mapper
@Repository
public interface UserMapper {

    User queryUserById(Long id);

    int addUser(User user);

    int modifyUser(User user);

    int deleteUserById(Long id);

}

3.10 provider服务sql的xml文件, userMapper.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

    <mapper namespace="com.wuhao.dao.UserMapper">

    <!--按id查询用户-->
    <select id="queryUserById" resultType="com.wuhao.domain.User">
        select * from `user` where id = #{id}
    </select>

    <!--用户更新-->
    <update id="modifyUser" parameterType="com.wuhao.domain.User" >
        update `user` set username=#{username},birthday=#{birthday},sex=#{sex}, address=#{address} where id=#{id}
    </update>

    <!--删除用户-->
    <delete id="deleteUserById" parameterType="long">
        delete from `user` where id=#{id}
    </delete>

    <!--用户添加-->
    <insert id="addUser" parameterType="com.wuhao.domain.User">
        insert into `user` (username,birthday,sex,address)
             values(#{username},#{birthday},#{sex},#{address})
    </insert>


</mapper>

4. consumer消费者服务创建
4.1 consumer服务目录结构
在这里插入图片描述
4.2 consumer服务的pom文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.wuhao.demo</groupId>
    <artifactId>consumer</artifactId>
    <version>1.0-SNAPSHOT</version>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.7.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!--rocketMq-->
        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-common</artifactId>
            <version>4.4.0</version>
        </dependency>

        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-client</artifactId>
            <version>4.4.0</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>

        <!--lombok-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.0</version>
            <scope>provided</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

4.3 consumer服务的application.properties

server.port=8083

logging.level.org.springframework=DEBUG

#Rocketmq consumer
rocketmq.consumer.namesrvAddr=127.0.0.1:9876
rocketmq.consumer.groupName=ConsumerGroup
rocketmq.consumer.topic=topic2020
rocketmq.consumer.tag=test
rocketmq.consumer.consumeThreadMin=20
rocketmq.consumer.consumeThreadMax=64

4.4 consumer服务的启动类

package com.wuhao;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;

@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
public class ConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }

}

4.5 consumer服务的实体类, User

package com.wuhao.domain;

import lombok.AllArgsConstructor;
import lombok.NoArgsConstructor;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;

/**
 * @Description: User实体
 * @CreateDate: 2020-02-04 19:25
 * @Author: wuhao
 */
@Entity
@NoArgsConstructor
@AllArgsConstructor
public class User {


    @Id
    @GeneratedValue
    private Long id;

    @Column(name = "username")
    private String username;

    @Column(name = "birthday")
    private String birthday;

    @Column(name = "sex")
    private String sex;

    @Column(name = "address")
    private String address;

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getBirthday() {
        return birthday;
    }

    public void setBirthday(String birthday) {
        this.birthday = birthday;
    }

    public String getSex() {
        return sex;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }

    public String getAddress() {
        return address;
    }

    public void setAddress(String address) {
        this.address = address;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", username='" + username + '\'' +
                ", birthday='" + birthday + '\'' +
                ", sex='" + sex + '\'' +
                ", address='" + address + '\'' +
                '}';
    }

}

4.6 consumer服务的监听器, MessageListen

package com.wuhao.mq;

import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.common.message.MessageExt;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * @author wuhao
 * @Title: MessageListen
 * @Description: 消息监听类
 * @date 2020/4/17 17:28
 */
@Component
public class MessageListen implements MessageListenerConcurrently {

    @Autowired
    private MessageProcessor messageProcessor;

    @Override
    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list, ConsumeConcurrentlyContext consumeConcurrentlyContext) {
        MessageExt ext = list.get(0);
        boolean result = messageProcessor.handle(ext);
        if (!result) {
            return ConsumeConcurrentlyStatus.RECONSUME_LATER;
        }
        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
    }
}

4.7 consumer服务的mq消息处理接口

package com.wuhao.mq;

import org.apache.rocketmq.common.message.MessageExt;

/**
 * @author wuhao
 * @Title: MessageProcessor
     * @Description: mq消息处理接口
 * @date 2020/4/17 17:24
 */
public interface MessageProcessor {

    boolean handle(MessageExt messageExt);
}

4.8 consumer服务的消息处理类

package com.wuhao.mq;

import org.apache.rocketmq.common.message.MessageExt;
import org.springframework.stereotype.Service;

/**
 * @author wuhao
 * @Title: MessageProcessorImpl
 * @Description: 消息处理类
 * @date 2020/4/17 17:27
 */
@Service
public class MessageProcessorImpl implements MessageProcessor {
    @Override
    public boolean handle(MessageExt messageExt) {
        // 收到的body（消息体），字节类型，需转为String
        String result = new String(messageExt.getBody());
        System.out.println("监听到了消息，消息为："+ result);
        return true;
    }
}

4.9 consumer服务的mq消费者配置类

package com.wuhao.mq;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.exception.MQClientException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author wuhao
 * @Title: RocketMQConsumer
 * @Description: Mq消费者
 * @date 2020/4/17 17:36
 */
@Configuration
@Slf4j
public class RocketMQConsumer {

    @Autowired
    private MessageListen messageListen;

    @Value("${rocketmq.consumer.namesrvAddr}")
    private String namesrvAddr;

    @Value("${rocketmq.consumer.groupName}")
    private String groupName;

    @Value("${rocketmq.consumer.topic}")
    private String topic;

    @Value("${rocketmq.consumer.tag}")
    private String tag;

    @Value("${rocketmq.consumer.consumeThreadMin}")
    private int consumeThreadMin;

    @Value("${rocketmq.consumer.consumeThreadMax}")
    private int consumeThreadMax;

    @Bean(initMethod = "start", destroyMethod = "shutdown")
    public DefaultMQPushConsumer getRocketMQConsumer() {
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(groupName);
        consumer.setNamesrvAddr(namesrvAddr);
        consumer.setConsumeThreadMin(consumeThreadMin);
        consumer.setConsumeThreadMax(consumeThreadMax);
        consumer.setVipChannelEnabled(false);
        // 我们自己实现的监听类
        consumer.registerMessageListener(messageListen);
        try {
            consumer.subscribe(topic, tag);
            log.info("================>消费者创建完成，ConsumerGroupName{}<================", groupName);
            log.info("============>消费者监听开始,groupName:{},topic:{}<============", groupName, topic);
        } catch (MQClientException e) {
            log.error("消费者启动失败");
            e.printStackTrace();
        }
        return consumer;
    }

}

演示效果

编写完成后, 按顺序启动provider服务, consumer服务
1 浏览器上执行http://localhost:8082/testSend, 开始发送消息
2 查看rocketMq可视化工具, mq里已经有消息了.
在这里插入图片描述3查看consumer服务的控制台日志, 已经有消息输出了
在这里插入图片描述

遇到过的问题

安装启动rocketMq时 ,windows环境下一直报运行环境内存不足,修改内存也不起作用, 不知道是够是个人电脑问题, 后来换成mac环境, 成功安装和启动了rocketMq.

参考博客

https://www.jianshu.com/p/38a3596beea6

springboot+mybatis+rocketmq整合
generous_F的博客
12-10 759
这里用的是idea springboot需要jdk1.8及以上maven3以上，这里要提前准备好 首先创建项目Spring Initializr,点next，Group和Artifact自己起名字，其他不用改动，继续，选择依赖，这里选中Web下的Web和SQL下的MySQL、JDBC和MyBatis，然后就创建项目成功了。只是spring boot整合mybatis的话以及反向生成可以参考http...
SpringBoot+Mybatis+RocketMQ+SpringCloud（一，SpringBoot整合）
weixin_42603009的博客
03-14 2591
简单说下自己目前的理解：springBoot是对spring的升级，为什么升级？因为各种语言发展到现在，已经非常方便了。但是java,甚至是spring都需要大量的jar包，编译，然后放入tomcat/apache中去执行，上线也需要很多。但是如果使用springBoot,就可以使用它自动生成的相当于main函数的，直接运行。上线，也变得简单。（待写） ...
springboot集成rocketMQdemo
08-27
springboot集成rocketMQdemo，简单，简洁，高效，大家可以下载参考参考
rocketMQ 第一天 spring boot集成 rocketMQ demo
黄泉路的博客
08-12 495
首先判断rocketMQ是否启动成功 pom.xml文件 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/PO.....
Spring Boot 集成 RocketMQ 全流程指南：从依赖引入到消息收发
最新发布
qq_17153885的博客
04-14 1853
本文将通过 **手动连接** 和 **配置连接** 两种方式，详细讲解如何在 Spring Boot 中集成 RocketMQ，实现消息的同步与异步发送，并提供完整示例代码
SpringBoot集成RocketMQ(完整demo)
supreme000的博客
10-20 4438
RocketMQ本地源码安装https://blog.csdn.net/supreme000/article/details/109117577 RocketMQ可视化控制台rocketmq-externals安装https://blog.csdn.net/supreme000/article/details/109156523 以上两步都完成后，将RocketMQ集成到SpringBoot中 新建一个SpringBoot工程 pom文件如下 <?xml version="1.0" enc
Springboot集成rocketmq快速入门demo
HBLOG
02-03 655
一、rocketmq介绍RocketMQ是一个纯Java、分布式、队列模型的开源消息中间件，前身是MetaQ，是阿里参考Kafka特点研发的一个队列模型的消息中间件，后开源给apache基金会成为了apache的顶级开源项目，具有高性能、高可靠、高实时、分布式特点。二、rocketmq环境搭建采用docker-compose搭建，具体配置如下version: '3' services: # r...
SpringBoot整合RocketMQ的一些Demo使用
张俊杰 的博客
10-25 1229
原文 出自 图灵学院 四期 RocketMQ的讲义 ,我自己整理了一下,然后听课的时候自己也记了一些笔记,整理完了发到了博客上. 注意点 在使用SpringBoot的starter集成包时，要特别注意版本。因为SpringBoot集成RocketMQ的starter依赖是由Spring社区提供的，目前正在快速迭代的过程当中，不同版本之间的差距非常大，甚至基础的底层对象都会经常有改动。例如如果使用rocketmq-spring-boot-starter:2.0.4版本开发的代码，升级到目前最新的rocke.
springBoot整合Redis， RocketMQ，Mybatis，Swagger等技术的文件管理管理系统
Saul_M的博客
03-02 1029
file_management_sys github地址 前言 file_management_sys项目希望完成一个文件共享系统，采用现阶段公司常用技术来实现，例如Redis, RocketMQ, Mybatis, Nginx等。总的目的是用来熟悉这些技术。希望一起讨论学习，共同进步。 目录 前言 项目介绍 项目演示 用户端演示 管理端演示 技术选型 后端技术 前端技术 环境搭建 ...
springboot-mybatis-demo.rar
10-24
通过以上步骤，SpringBoot项目成功整合了Mybatis和RocketMQ，不仅简化了数据库操作，还利用RocketMQ实现了高并发场景下的消息队列通信，提升了系统的可扩展性和稳定性。 总结，SpringBoot整合Mybatis和RocketMQ是一...
SpringBoot实战演示：集成MyBatis、Redis、MySQL、Kafka与RocketMQ
资源摘要信息: "SpringBootDemo是一个展示Spring Boot系列技术的代码演示项目，包含了与Spring Boot整合的多项技术，如MyBatis、Redis、MySql、Kafka和RocketMQ。该项目不仅包含基本的后端服务搭建，还涉及到了...
spring-boot操作rocketmq的demo
09-06
spring-boot操作rocketmq的demo，亲测可用，代码整理的好
springboot-rocketmq-demo.zip
04-09
springboot 整合 rocketmq实例代码
SpringBoot整合RocketMq，rocketMq
08-24
SpringBoot整合RocketMq
SpringBoot整合RocketMQ消息队列demo
IceCaptain的博客
04-18 909
前言 在此只引入关键依赖，关于SpringBoot等其他基础依赖请自行准备。 另外，本文中的实现方式为点对点的方式。   开始 首先，在pom文件中引入依赖 <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketm...
【MQ-02】基于SpringBoot的RocketMQ简单Demo(附源码)
qq_32106647的博客
12-18 372
创建Topic 以下操作都基于目录1下 启动broker mqbroker -n localhost:9876 创建Topic mqadmin updatetopic -n localhost:9876 -b localhost:10911 -t demo 开发生产者Producer
RocketMq整合springboot,demo示例
撸起袖子加油干
11-03 561
一、window安装rocketmq: 1.1地址：http://rocketmq.apache.org/release_notes/release-notes-4.2.0/ 1.2选择‘Binary’进行下载 1.3解压已下载工程 2.配置 2.1 系统环境变量配置 变量名：ROCKETMQ_HOME 变量值：MQ解压路径\MQ文件夹名 2.2重启服务器 3.启动 3.1 启动NAMESERVER Cmd命令框执行...
java版商城源码之商家中心Spring Cloud+Spring Boot+mybatis+security+uniapp+Redis+MQ+VR全景+b2b2c多商家入驻前后端分离商城源码
iteye_3750的博客
02-10 738
java版商城源码之商家中心Spring Cloud+Spring Boot+mybatis+security+uniapp+Redis+MQ+VR全景+b2b2c多商家入驻前后端分离商城源码
SpringBoot 集成 RocketMQ 和 Elasticsearch 的小demo
weixin_43909647的博客
08-18 359
SpringBoot 集成 RocketMQ 和 Elasticsearch 的小demo 为了毕设我一点点的攒（功能描述） 一，RocketMQ 就是消息队列。 现在这个demo的理解就是 一个 存放 springboot组件（关注业务，由业务催生）生成通用消息（封装springboot entity） 的队列（我没有在意是否是队列，dome的应用像是 内存）。 为啥不用MySQL，因为还没到时候。 RocketMQ 像是个集体公寓前面的信箱，组件就是每个公寓，生产出来一个信就放到信箱。 我要集中分类一下
Springboot+SpringSecurity+Mybatis
05-27
Spring Boot是一个用于快速构建企业级应用的Java框架，它提供了各种功能强大的特性，例如自动配置、快速启动、监控等。Spring Security是一个基于Spring框架的安全框架，它提供了身份验证、授权、攻击防护等安全功能。MyBatis是一个Java持久化框架，它通过XML或注解方式将Java对象映射到数据库表中。 SpringBoot + SpringSecurity + MyBatis可以用于构建安全可靠的企业级应用程序。其中，SpringBoot提供了快速启动和自动配置的特性，简化了应用程序的开发和部署。SpringSecurity提供了各种安全功能，例如身份验证、授权、攻击防护等。MyBatis提供了Java与数据库之间的映射功能，使得开发者可以很方便地操作数据库。 在使用SpringBoot + SpringSecurity + MyBatis时，一般可以采用前后端分离的方式，前端使用Vue或React等框架，后端使用SpringBoot + SpringSecurity + MyBatis进行开发。前端向后端发送请求时，后端使用SpringSecurity进行身份验证和授权，然后使用MyBatis操作数据库进行数据查询和更新，最终将结果返回给前端。 当然，具体的实现方式还需要根据具体的业务需求和技术栈进行选择。
评论
添加红包

请填写红包祝福语或标题

个

红包个数最小为10个

元

红包金额最低5元

当前余额3.43元 前往充值 >
需支付：10.00元
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付元
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明：

1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载，可以购买VIP、付费专栏及课程。

余额充值