互动
最近评论
最近评论内容 TODO
正式迁移到halo2
Halo Theme Mai
更多信息请关注 GitHub
JDK原生序列化如果使用Java语言开发,JDK原生就有序列化:import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.IOException;import java.io.ObjectInputSt
RPC协议需要自定义通信协议,RPC负责应用间的通信,所以性能要求相对较高。以HTTP协议为例,HTTP协议的数据包大小相对请求数据本身要大很多,又要加入很多没用的内容,例如换行符号、回车符号等。还有一个原因是HTTP属于无状态协议,客户端无法对请求合响应进行关联,每次请求都需要重新建立连接,响应完
一、生产者:DefaultMQProducer 消息生产者的代码都在client模块中,对于RocketMQ来说,它既是客户端,也是消息的提供者,我们在应用系统中初始化生产者的一个实例即可使用它来发消息。 DefaultMQProducer是默认的生产者实现类,实现了一个接口MQProducer,都
一、清理Tomcat 1、清理 webapps下的应用 清理webapps目录下不需要的应用,一般是host-manager、example、doc等默认的应用,也有可能是之前添加而现在不再使用的应用。这些项目最好都删掉,Tomcat在每次启动的使用都会加载webapps目录下的应用。如果使用Spr
前言在前面所介绍的RocketMQ的文章中,介绍了RocketMQ的消息发送方式有3种:同步、异步和单向。具体的可查看:RocketMQ的主要组件及其功能在接下来的关于RocketMQ的消息发送的文章中,可以带着几个问题来阅读:1、RocketMQ的消息队列是如何负载的?2、RocketMQ的消息发
一、NameServer的路由元信息NameServer的主要作用是为消息生产者和消息消费者提供Topic的路由信息。所以NameServer需要保存和管理路由的基础信息。NameServer的路由管理的实现类是:org.apache.rocketmq.namesrv.routeinfo.Route
一、NameServer的架构设计Broker启动的时候会向所有的NameServer注册,生产者在发送消息时会先从NameServer中获取Broker消息服务器的地址列表,根据负载均衡算法选取一台Broker消息服务器发送消息。NameServer与每台Broker之间保持着长连接,并且每隔10
什么是RocketMQ?RocketMQ都有些什么东西?RocketMQ一个基于主题的订阅发布机制的消息中间。
一、前言在工作中接到了对接第三方广告平台的接口,需要上报转化数据,看了对接文档提到了遇到接口请求超时需要重试三次。看了现有的HttpClient工具类并没有添加重试。所以对工具类进行改造。二、编码实现2.1 前置准备这里使用Spring Boot 2.5版本<parent>    &lt
一、分布式发号器在分布式系统里面我们经常需要生成整个系统的唯一ID或者叫流水号,一般生成这个唯一ID的我们俗称发号器。例如订单号、交易号等。分布式发号器是分布式系统不可或缺的基础设施之一,在保证系统的正确运行和高可用上发挥着不可取代的作用,在不同的公司有不同的实现方式。二、UUIDUUID 是 通用
程序都是运行在内存里的,所以对于一门开发语言来说,对于内存的管理都是重中之重的,前有C、C++需要开发者管理内存,后有Java的自动内存管理,到如今的内存安全的Rust。
一、Redlock算法的Java落地实现Redisson目前大多数基于Redisde分布式锁的实现,都有上面章节所说的问题。如果是使用单机的Redis上面的例子就够用了,但是一般在使用Redis时,为了保证Redis的可用性一般都是使用Redis集群。在上篇中单机版Redis环境下的Redis分布式