前面我们看到了pmq从端到端的调用，但是没有看到的还有很多细节的东西。比如我们看到在学习RocketMQ时，可以看到很多启动都是在broker中启动，那pmq中...
需要承认的是前面学习二中，pmq中的发送消息和消费消息是两个动作，同时操作的过程publish和pullData两个操作。认知有限，我误导大家了。接上上面的话题...
Netty中首先会经过OP_ACCEPT操作，再经过OP_READ事件，此时的操作是在processSelectionKeys中进行处理的，此时首先select...
pmq是信也科技开源的一款消息中间件，虽然没有RocketMQ和Kafka出名，但是里面的代码还是有值得我们学习的地方的。
我们知道在RocketMQ中，服务端代表的是broker，而客户端才是我们的生产者和消费者。而pmq中，也是如此，服务端是broker，而客户端是生产者和消费者...
学习一个框架，通常从example开始。同时一个消息中间件是从生产者开始，消费者消费消息。这里mq-client-test-001里面的两个类开始。
什么时候创建severSocketChannel、初始化serverSocketChannel，同时给serverSocketChannel从bossGroup...
前面我们知道dubbo如果采用dubbo协议的话，此时会调用netty来启动服务。同时我们可以其在进行标签解析和注入到spring中。此时最为关键的是doExp...
在前面我们看到了单例模式的使用，在dubbo中，同样有单例模式的使用，找到dubbo中的ExtensionLoader类可以看到这样的代码：
在前面中，我们知道如果一个bean需要被加载，首先需要获取资源的位置，然后根据资源位置获取xml文件，然后将其变成document，然后根据document对元...
工厂模式属于创建型模式，它是创建对象的最佳方式，它负责事项创建所有实例的内部逻辑。工厂类创建产品类的方法可以被外界直接调用，创建所需要的产品对象。它在sprin...
观察者模式：Observer Pattern,又称为发布-订阅(Publish-Subscribe)模式,对象之间存在一对多或者一对一依赖，当一个对象改变状态，...
单一职责原则:类的职责单一，不能将太多的职责放在一个类中，该原则是实现高内聚、低耦合的指导方针
kafka分为客户端和服务端，通常我们知道broker是服务端，而生产者和消费者作为客户端。因此在服务端就必定需要解决并发和网络IO的问题。因此不可避免需要用到...
这里思考问题，什么时候会用到延迟组件，同时哪些时候会用到延迟组件，同时为什么要用延迟组件？
前面我们知道其重要的启动方法里面有关的方法：它的注释是非常具有启发性的， 启动API，以启动Kafka服务器的单个实例。实例化LogManager，Socket...
前面我们已经学习了特质类似接口，其可以被继承，同时如果需要继承多个特质的话，则需要使用extends…with…进行继承。其类似java中的接口和抽象方法的结合...
在kafka启动时，首先执行的broker的操作，然后接着会执行生产者操作，接着将生产者的消息放入到存储中，此时生产者和broker会进行交互，而消费者发送消...
前面我们通过学习scala知道通常如果想运行scala程序，必然会有一个入口，而这个入口可以通过kafka的启动脚本kafka-server-start.sh可...
适用于var变量，对于val不适用，注意如果使用下划线进行初始化，此时必须提供数据类型，这样就可以进行自动推断赋初始值
暂未填写技能专长
暂未填写学校和专业
暂未填写个人网址
扫码关注云+社区
领取腾讯云代金券
