为什么使用消息队列?
消息队列的常见使用场景有很多但是核心的有三个:解耦、异步、削峰
RocketMQ是一个纯Java、分布式、队列模型的开源消息中间件,前身是MetaQ,是阿里参考Kafka特点研发的一个队列模型的消息中间件,后开源给apache基金会成为了apache的顶级开源项目,具有高性能、高可靠、高实时、分布式特点。
1 | cd xxxx\kafka\bin\windows |
1 | Uninstall old versions |
1 | Uninstall old versions |
reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
ref: https://datatracker.ietf.org/doc/html/rfc7230#section-6
The “Connection” header field allows the sender to indicate desired
control options for the current connection. In order to avoid
confusing downstream recipients, a proxy or gateway MUST remove or
replace any received connection options before forwarding the
message.
nginx转发,设置 Connection: close