RocketMQ是阿里开源的分布式消息中间件，在阿里云上有它的商业版本ONS，类似的开源消息中间件还有Kafka, ActiveMQ等。跟其它中间件相比，rocketMQ的特...
IP属地：广东
-
RocketMQ源码解析(一)-架构原理 -
[从零开始的Unity网络同步] 1.在Unity中搭建网络模块前言 最近在鼓捣网络同步相关的东西,略有心得,故此打算写些心得和感悟,也方便以后重温复习. 1.在Unity中配置网络 虽然在Unity中有个自带的挂在GameObject上...
-
已知一个消息只会呗同个consumerGroup内的一个消费者消费， 假如consumer1和consumer2都在消费 queueId=1的队列. consumer1 pull到了queueOffset=1的消息，但是消费失败了，完了之后，还没来得及往%RETRY%TOPIC回写消息又挂了. consumer2 pull到了queueOffset=2的消息，正常消费了， 那consumerOffset.json记录的queueOffset值会是多少？ 会不会导致queueOffset=1的消息 丢失？ 这个搞不懂rocketmq怎么处理的
RocketMQ源码解析(十一)-Broker#消息消费
终于讲到Broker消息处理流程的最后一步了。讲Consumer的时候说到消费消息分为Pull和Push两种模式，底层其实都是依靠Pull实现的。在Broker这端处理Pus...
-
消费失败的那里没太懂， 如果消费失败，要重新消费由客户端重新发消息到%RETRY%topic 来进行重新消息？ 如果客户端发送到%RETRY%topic之前挂了，这消息岂不是丢了？ 感觉还是得结合 broker 服务器端怎么处理pull请求再细讲下才比较明白
RocketMQ源码解析(四)-Consumer
消息消费方式 Consumer分为两种，PullConsumer和PushConsumer。从名字就可以看出一种是拉取的方式，一种是主动Push的方式。具体实现如下： Pul...
-
跟菜鸟一起学习vertx1、什么是vertx vert.x是Eclipse软件基金会顶级java开源项目之一，它基于netty的、运行在jvm之上的、支持多种编程语言的异步、非阻塞、响应式编程的工具...
-
idea2020.3bug(java.lang.UnsupportedClassVersionError)昨天新下载了2020.3的idea来使用，随手先运行了main方法，打印个hello world。 然后~~直接给我报了个下面的错。 2020.3：java.lang.Uns...
-
我擦， 还真可以
idea2020.3bug(java.lang.UnsupportedClassVersionError)
昨天新下载了2020.3的idea来使用，随手先运行了main方法，打印个hello world。 然后~~直接给我报了个下面的错。 2020.3：java.lang.Uns...
-
spring循环依赖分析个人学习总结 整个缓存分为三级 singletonObjects，一级缓存，存储的是所有创建好了的单例 Bean earlySingletonObjects，完成实例化，但是...
-
Kubeadm方式安装
kubeadm是官方社区推出的一个用于快速部署kubernetes集群的工具。 这个工具能通过两条指令完成一个kubernetes集群的部署： 1. 安装要求 在开始之前，部...
-
Protocol buffers协议分析
简介 protocol buffers是Google的一个灵活的、高效的、自动化的用于对结构化数据进行序列化的协议，与json、xml相比，protocol buffers序...
-
Android Studio4.0构建项目报错错误如下 cd到sdk路径，我这边是C:\Users\86137\AppData\Local\Android\Sdk\tools\bin执行命令
-
-
[java] ganymed-ssh2 远程执行shell脚本需求场景: 用户微信三方平台授权通过后,需要上传微信业务文件至nginx前端服务器中 后台实现方案: 1.客户登录微信公众平台,下载业务文件 如:MP_verify_xxx....
-
-
goland debug运行报错问题goland run运行正常，但是debug运行报如下错误 主要是因为缺少dlv， go程序debug需要dlv下面是安装dlv的步骤 百度出来结果都是，执行以下命令,但是我...
