heima的mq实战------2

惯例文档:

heima的mq实战------2

---

我们先搞一个starter。

heima的mq实战------2

heima的mq实战------2

要俺安装的工程在哪里?

heima的mq实战------2

代码在哪里?

springboot集成rocketmq的生产者。

heima的mq实战------2

在工程里面果然有:

heima的mq实战------2

heima的mq实战------2

springboot集成rocketmq的消费者代码:

heima的mq实战------2

heima的mq实战------2

---01-07---

同样下载springboot和dubbo整合的依赖包到本地的maven

heima的mq实战------2

heima的mq实战------2

上代码:

heima的mq实战------2

heima的mq实战------2

zookeeper包括自己多余半数,收到的follower为半数就是一次消息成功。

服务的提供者。

管理平台得到搭建:

heima的mq实战------2

heima的mq实战------2

服务的消费方(web的方式)

---08-13---

创建数据库表:

heima的mq实战------2

heima的mq实战------2

工程:

heima的mq实战------2

heima的mq实战------2

---14-15---

mybatis的逆袭工程。

heima的mq实战------2

好好看下这个****。

第一步:

heima的mq实战------2

第二步:

heima的mq实战------2

第三步:

heima的mq实战------2

第四步:解决一个报错的问题:https://blog.****.net/qq_41525021/article/details/93048277

第五步:运行main方法。

---16---

公共类的作用:

heima的mq实战------2

为什么用雪花算法,要是分库分表的话两个数据库都是自增的话可能是一样的。

---17----

heima的mq实战------2

---18---

lombok使用lock:https://www.cnblogs.com/yanguobin/p/11525584.html

开始编写逻辑了:

第一步:先写接口

heima的mq实战------2

第二步:

zookeeper:

zookeeper://192.168.244.128:2181;zookeeper://192.168.244.129:2181;zookeeper://192.168.244.130:2181

rocketMQ:

rocketmq.name-server=192.168.244.128:9876;192.168.244.129:9876

mysql:

spring.datasource.url=jdbc:mysql://192.168.244.128:3306/trade?useUnicode=true&characterEncoding=utf8
spring.datasource.username=root
spring.datasource.password=123456

heima的mq实战------2

heima的mq实战------2

十分重要的知识点,真这个这个必须是原子性质的。

---19---