初级的消息中心准备提供一个统一的消息中心接口，用户通过消息中心可以将消息发送到kafka集群
，然后通过消费去推送企业微信消息，或者企业邮箱

实战

框架

首先框架上使用了spring-kafka 2.5.7.RELEASE，使用了nacos注册中心和配置中心（可根据需要使用）

  <dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId></dependency>

代码

生产者

package com.test.message.controller;@RestController
@RequestMapping("/message")
public class MessageController {private static final Logger log = LoggerFactory.getLogger(MessageController.class);@Resourceprivate KafkaTemplate<String, String> kafkaTemplate;/*** 发送消息* @param msgReq* @return*/@ApiOperation(value = "发送消息",notes = "发送消息")@PostMapping("sendMess

【分布式微服务】消息中心初步搭建相关推荐

【我的新书】分布式微服务架构：原理与实战
开心一笑一次批小学语文卷,要求用"有--有--还有--"造句.一学生是这样写的:昨天去奶奶家,奶奶给我拿个鸡腿,我都吃完了问奶奶还有吗,奶奶答:"有,有,还有!&quo ...
spring cloud构建互联网分布式微服务云平台-消息总线
Spring Cloud Bus除了支持RabbitMQ的自动化配置之外,还支持现在被广泛应用的Kafka.在本文中,我们将搭建一个Kafka的本地环境,并通过它来尝试使用Spring Cloud B ...
java基础巩固-宇宙第一AiYWM：为了维持生计，架构知识+分布式微服务+高并发高可用高性能知识序幕就此拉开（三：注册中心、补充CAP定理、BASE 理论）~整起
架构知识+分布式微服务+高并发高可用高性能知识序幕就此拉开(一:总览篇) 网关开了个头你请求来了,我网关把你拦截住,验明正身,加以控制,协助你调用服务,完成请求的调用.但是这个过程中,为了解耦和或者 ...
企业分布式微服务云SpringCloud SpringBoot mybatis （七）高可用的分布式配置中心(Spring Cloud Config)...
讲述了一个服务如何从配置中心读取文件,配置中心如何从远程git读取配置文件,当服务实例很多时,都从配置中心读取文件,这时可以考虑将配置中心做成一个微服务,将其集群化,从而达到高可用,架构图如下: 一. ...
java springcloud版b2b2c社交电商spring cloud分布式微服务（七）高可用的分布式配置中心(Spring Cloud Config)...
Springcloud b2b2c电子商务社交平台源码请加企鹅求求:一零三八七七四六二六.讲述了一个服务如何从配置中心读取文件,配置中心如何从远程git读取配置文件,当服务实例很多时,都从配置中心读取 ...
java spring cloud版b2b2c社交电商spring cloud分布式微服务：分布式配置中心
JAVASpring Cloud大型企业分布式微服务云构建的B2B2C电子商务平台源码请加企鹅求求:一零三八七七四六二六.Spring Cloud Config是Spring Cloud团队创建的一个 ...
java版b2b2c社交电商spring cloud分布式微服务（十）高可用的服务注册中心
电子商务社交平台源码请加企鹅求求:一零三八七七四六二六.文章史上最简单的 SpringCloud 教程 | 第一篇: 服务的注册与发现(Eureka) 介绍了服务注册与发现,其中服务注册中心Eure ...
（十六）java springcloud版b2b2c社交电商spring cloud分布式微服务-使用spring cloud Bus刷新配置...
b2b2c电子商务社交平台源码请加企鹅求求:一零三八七七四六二六.我们使用spring cloud分布式微服务云架构做了b2b2c的电子商务系统,除了架构本身自带的系统服务外,我们将b2b2c的业务服 ...
【九】分布式微服务架构体系详解——共识问题
前言分布式架构体系中,一致性和共识是分不开的概念,一致性也是我们解决很多分布式问题的关键.比如通过一致性模型可以实现数据集群的数据复制:通过基于阻塞的2PC协议可以实现分布式的原子性提交,保证事务数 ...

【分布式微服务】消息中心初步搭建

实战

框架

代码

【分布式微服务】消息中心初步搭建相关推荐

最新文章

热门文章