通过RabbitMQ来向邮箱随机发送一个验证码 1、导入相关依赖； <!-- 邮件发送`--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-mail</artifac ...
分类：
编程语言 时间：
2020-07-23 01:44:42
阅读次数：
76
服装价格变动，触发淘宝发布活动和消费者购买衣服事件流 1 public class EventStandard 2 { 3 public class Clothes { 4 5 /// <summary> 6 /// 服装编码 7 /// </summary> 8 public string Id ...
1）先写一个日志订单的消费者； OrderConsumer.java package com.seecen.redis.rabbitmq; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.annotat ...
分类：
编程语言 时间：
2020-07-23 01:36:43
阅读次数：
106
SpringCloud生产消费者 生产者与消费者 上一篇文章介绍了Euarka的搭建，SpringCloud服务注册中心 本篇文章，我们搭建俩个服务，生产者服务与消费者服务。 本文就以电商系统为例：服务生产者，订单查询服务order-server，服务消费者order-client 说明：order ...
分类：
编程语言 时间：
2020-07-22 23:35:55
阅读次数：
100
转自： https://blog.csdn.net/ID__9527/article/details/84255680 RocketMQ是阿里巴巴公司的一个消息队列框架（很多思想借鉴Kafka），对于RocketMQ本身不做过多说明，下面主要说明RocketMQ的两种消费模型。 消费模型有两种：广播 ...
分类：
其他好文 时间：
2020-07-21 21:27:30
阅读次数：
82
本次利用Java+netty实现自定义rpc框架，共分为三个工程,公共模块+服务提供者+服务消费者： rpc-common工程 pom.xml <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.or ...
分类：
编程语言 时间：
2020-07-21 14:16:43
阅读次数：
78
前言 与生产者对应的是消费者，应用程序可以通过KafkaConsumer来订阅主题，并从订阅的主题中拉取消息。不过在使用KafkaConsumer消费消息之前需要先了解消费者和消费组的概念，否则无法理解如何使用KafkaConsumer。 <!--more--> Consumer 消费者（Consu ...
分类：
其他好文 时间：
2020-07-21 11:34:08
阅读次数：
71
RabbitMQ常用端口 client端通信端口： 5672 管理端口 ： 15672 server间内部通信端口： 25672 可能的问题 如端口出现不能访问，考虑是否防火墙问题，可以使用形如以下命令开启或直接关闭防火墙： firewall-cmd --add-port=15672/tcp --p ...
分类：
其他好文 时间：
2020-07-19 17:46:41
阅读次数：
74
关于MQ的定义MessageQueue（MQ）消息队列中间件，通常我们在网上看到的对其定义是将消息的发送和接受分离来实现应用程序的异步和解耦，给人的直觉是MQ是异步的，用来解耦的。但这个只是MQ的效果，而不是目的。MQ真正的目的是为了通讯，屏蔽底层复杂的通讯协议，定义了一套应用层上更加简单的通讯协议。一套分布式系统中两个模块之间通讯要么是HTTP，要么是TCP，但这两种协议其实都是原始的协议。前者
分类：
其他好文 时间：
2020-07-19 11:25:55
阅读次数：
72
什么是RabbitMQ简介（优点）基于ErLang语言开发有高可用高并发的优点，适合集群。开源、稳定、易用、跨平台、支持多种语言、文档齐全。有消息确认机制和持久化机制，可靠性高。概念生产者和消费者Producer：消息的生产者Consumer：消息的消费者Queue消息队列提供了FIFO的处理机制，具有缓存消息的能力。在RabbitMQ中，队列消息可以设置为持久化，临时或者自动删除。如果是持久化的
分类：
其他好文 时间：
2020-07-19 11:25:40
阅读次数：
75
