路行的亚洲

LV0
发表了文章

pmq学习五-pmq启动学习

前面我们看到了pmq从端到端的调用,但是没有看到的还有很多细节的东西。比如我们看到在学习RocketMQ时,可以看到很多启动都是在broker中启动,那pmq中...

路行的亚洲
发表了文章

pmq学习四-生产消息到存储到消费的过程

需要承认的是前面学习二中,pmq中的发送消息和消费消息是两个动作,同时操作的过程publish和pullData两个操作。认知有限,我误导大家了。接上上面的话题...

路行的亚洲
发表了文章

Netty流程学习

Netty中首先会经过OP_ACCEPT操作,再经过OP_READ事件,此时的操作是在processSelectionKeys中进行处理的,此时首先select...

路行的亚洲
发表了文章

pmq学习一-一些典型的使用和套路

pmq是信也科技开源的一款消息中间件,虽然没有RocketMQ和Kafka出名,但是里面的代码还是有值得我们学习的地方的。

路行的亚洲
发表了文章

pmq学习三-mq客户端启动的流程

我们知道在RocketMQ中,服务端代表的是broker,而客户端才是我们的生产者和消费者。而pmq中,也是如此,服务端是broker,而客户端是生产者和消费者...

路行的亚洲
发表了文章

pmq学习二-生产者和消费者流程

学习一个框架,通常从example开始。同时一个消息中间件是从生产者开始,消费者消费消息。这里mq-client-test-001里面的两个类开始。

路行的亚洲
发表了文章

Netty流程学习一-netty启动服务

什么时候创建severSocketChannel、初始化serverSocketChannel,同时给serverSocketChannel从bossGroup...

路行的亚洲
发表了文章

dubbo生产者暴露服务流程

前面我们知道dubbo如果采用dubbo协议的话,此时会调用netty来启动服务。同时我们可以其在进行标签解析和注入到spring中。此时最为关键的是doExp...

路行的亚洲
发表了文章

设计模式之装饰者模式

在前面我们看到了单例模式的使用,在dubbo中,同样有单例模式的使用,找到dubbo中的ExtensionLoader类可以看到这样的代码:

路行的亚洲
发表了文章

设计模式之单例模式

在前面中,我们知道如果一个bean需要被加载,首先需要获取资源的位置,然后根据资源位置获取xml文件,然后将其变成document,然后根据document对元...

路行的亚洲
发表了文章

设计模式之工厂模式

工厂模式属于创建型模式,它是创建对象的最佳方式,它负责事项创建所有实例的内部逻辑。工厂类创建产品类的方法可以被外界直接调用,创建所需要的产品对象。它在sprin...

路行的亚洲
发表了文章

设计模式之观察者模式

观察者模式:Observer Pattern,又称为发布-订阅(Publish-Subscribe)模式,对象之间存在一对多或者一对一依赖,当一个对象改变状态,...

路行的亚洲
发表了文章

设计模式之设计原则

单一职责原则:类的职责单一,不能将太多的职责放在一个类中,该原则是实现高内聚、低耦合的指导方针

路行的亚洲
发表了文章

Kafka流程流转-服务端

kafka分为客户端和服务端,通常我们知道broker是服务端,而生产者和消费者作为客户端。因此在服务端就必定需要解决并发和网络IO的问题。因此不可避免需要用到...

路行的亚洲
发表了文章

kafka学习六-生产延迟操作

这里思考问题,什么时候会用到延迟组件,同时哪些时候会用到延迟组件,同时为什么要用延迟组件?

路行的亚洲
发表了文章

Kafka学习五

前面我们知道其重要的启动方法里面有关的方法:它的注释是非常具有启发性的, 启动API,以启动Kafka服务器的单个实例。实例化LogManager,Socket...

路行的亚洲
发表了文章

Scala学习三-面向对象

前面我们已经学习了特质类似接口,其可以被继承,同时如果需要继承多个特质的话,则需要使用extends…with…进行继承。其类似java中的接口和抽象方法的结合...

路行的亚洲
发表了文章

Kafka学习四

在kafka启动时,首先执行的broker的操作,然后接着会执行生产者操作,接着将生产者的消息放入到存储中,此时生产者和broker会进行交互,而消费者发送消...

路行的亚洲
发表了文章

kafka学习三-broker的入口

前面我们通过学习scala知道通常如果想运行scala程序,必然会有一个入口,而这个入口可以通过kafka的启动脚本kafka-server-start.sh可...

路行的亚洲
发表了文章

Scala学习二-面向对象

适用于var变量,对于val不适用,注意如果使用下划线进行初始化,此时必须提供数据类型,这样就可以进行自动推断赋初始值

路行的亚洲

个人简介

个人成就

扫码关注云+社区

领取腾讯云代金券