「环境配置」RocketMQ安装并整合SpringBoot

RocketMQ 是阿里巴巴团队使用Java语言开发的一个分布式、队列模型的消息中间件,后开源给Apache基金会成为了Apache的顶级开源项目,具有高性能、高可靠、高实时、分布式特点。

RocketMQ 主要由ProducerBrokerConsumerNameServer组成;其中Producer负责生产消息;Consumer负责消费消息;BrokerMQ服务,负责接收、分发消息;NameServer是路由中心,负责MQ服务之间的协调。

「Redis」Redis故障处理-持久化时内存不足

问题描述

1
2
3
4
5
6
7
# Java错误日志:
redis.clients.jedis.exceptions.JedisDataException: MISCONF Redis is configured to save RDB snapshots, but is currently not able to persist on disk. Commands that may modify the data set are disabled. Please check Redis logs for details about the error.

# Redis错误日志:
Can't save in background: fork: Resource temporaily unavailable
# 或
Can’t save in background: fork: Cannot allocate memory

「Spring Reactive Stack」Reactor异常处理

不管是在响应式编程还是普通的程序设计中,异常处理都是一个非常重要的方面。

对于Flux或者Mono来说,所有的异常都是一个终止的操作,即使你使用了异常处理,原生成序列也不会继续。
但是如果你对异常进行了处理,那么它会将oneError信号转换成为新的序列的开始,并将替换掉之前上游产生的序列。