dubbo源码分析6-telnet方式的管理实现
2016-07-14 09:16
218 查看
dubbo源码分析1-reference bean创建
dubbo源码分析2-reference bean发起服务方法调用
dubbo源码分析3-service bean的创建与发布
dubbo源码分析4-基于netty的dubbo协议的server
dubbo源码分析5-dubbo的扩展点机制
dubbo提供了telnet的方式,直接用命令查看服务信息等。怎么实现的呢。1. 编解码器
com.alibaba.dubbo.remoting.transport.netty.NettyCodecAdapter.InternalDecoder实现了SimpleChannelUpstreamHandler类
然后注册给ChannelPipeline
后面的都是用netty的套路
2. dubbo中URL类
com.alibaba.dubbo.common.URL该类的作用类似于我们通常用的上下文,它描述了调用过程中一些配置信息,形式如下:
dubbo://192.168.1.101:20880/org.simonme.dubbo.demo.provider.service.HelloService?anyhost=true&application=hello-world-app&channel.readonly.sent=true&codec=dubbo&dubbo=2.4.9&heartbeat=60000&interface=org.simonme.dubbo.demo.provider.service.HelloService&methods=sayHello&monitor=dubbo%3A%2F%2F192.168.1.100%3A2174%2Fcom.alibaba.dubbo.registry.RegistryService%3Fapplication%3Dhello-world-app%26dubbo%3D2.4.9%26pid%3D8976%26protocol%3Dregistry%26refer%3Ddubbo%253D2.4.9%2526interface%253Dcom.alibaba.dubbo.monitor.MonitorService%2526pid%253D8976%2526timestamp%253D1468370420113%26registry%3Dzookeeper%26timestamp%3D1468370419870&pid=8976&side=provider×tamp=1468370419920
比如我需要怎样的编解码器,我会到这url中取
com.alibaba.dubbo.remoting.transport.AbstractEndpoint.AbstractEndpoint(URL, ChannelHandler)
this.codec = ExtensionLoader.getExtensionLoader(Codec.class).getExtension(url.getParameter(Constants.CODEC_KEY, "telnet"));
我们在上述的url示例中能找到 codec=dubbo
所以就知道这次采用dubbo的编解码器。
略微和我们之前用上下文方式不同的是,上下文中可以防止一些比较复杂的对象,比如放置一个根窗体容器之类的。
用了URL这种形式,结合ZooKeeper使用比较方便。
3. dubbo的扩展点实现
分析 com.alibaba.dubbo.common.extension.ExtensionLoader<T>本质上还是将构建出来的实例放在cachedInstances属性中,这个事本来可以交给spring干,spring专业干IOC的。但是dubbo这么干了之后一个明显的好处是:dubbo在不依赖任何第三方框架的情况下可以跑起来。说的简单一点:dubbo自己做了一个简易的IOC机制,它这里面称之为SPI。自己做IOC的框架真是不少,Struts2也自己干了IOC。详细分析见之前画的一份思维导图
4. telnet协议编解码器
DubboCountCodec与netty对接,DubboCountCodec 关联了DubboCodec。DubboCodec继承体系上有个TelnetCodec。TelnetCodec完成了telenet协议的编解码,在decode方法中会将InputStream 实例转换成message。5. 解码后的动作链路
NettyHandler extends SimpleChannelHandler 这个类会注册给netty,netty在解码后会触发下面的messageReceived逻辑。com.alibaba.dubbo.remoting.transport.netty.NettyHandler.messageReceived(ChannelHandlerContext, MessageEvent)
这个handler又关联了真正处理逻辑的handler,com.alibaba.dubbo.remoting.telnet.support.TelnetHandlerAdapter
TelnetHandlerAdapter触发telnet方法 调用真正的命令处理逻辑
根据拿到的命令 再通过扩展点机制获取具体的命令实现类的实例。
可以以com.alibaba.dubbo.rpc.protocol.dubbo.telnet.ListTelnetHandler为例子分析一下。
命令的实现使用了@Help注解,描述了命令的帮助。
6. telnet连接后,按向上或者向下方向键的时候能回显历史命令,怎么实现的
实现在com.alibaba.dubbo.remoting.telnet.codec.TelnetCodec.decode(Channel, InputStream, int, byte[])中,编解码器会将历史命令记录在channel中,然后根据方向来获取。boolean down = endsWith(message, DOWN); if (up || down) { LinkedList<String> history = (LinkedList<String>) channel.getAttribute(HISTORY_LIST_KEY); if (history == null || history.size() == 0) { return NEED_MORE_INPUT; }
7. 部分问题
dubbo的这个telnet管理台实现还是比较简陋的 只实现了telnet的行模式并没有实现字符模式,这样的话 按tab补全这种事就不好做了。
之前看过huawei的命令行管理平台的工具,tab补全能力非常强大 也非常好用。
--EOF--
相关文章推荐
- CSS强制英文换行
- FatFs文件系统的移植
- overload与override的区别
- SEO失败案例之希尔顿酒店网页重定向
- 关于android电话监听显示(类似360通话)
- android:descendantFocusability用法简析
- UVA 1625 Color Length
- Android 四大组件 博客链接
- Asp.Net生成RSS方法
- C#防止注入式攻击的方法
- Error:(2, 0) Cause: org/gradle/api/publication/maven/internal/DefaultMavenFactory
- caffe制作数据集
- Java 匿名对象的详解
- mongo vue 批量删除表数据
- 微信分享自定义图片标题摘要-微信官方API
- ASP.NET中POST提交数据并跳转页面
- varnish安装及一些遇到的问题的解决方法
- HDU 4135 Co_prime(容斥原理、[A,B]中和n互素数个数)
- kindeditor编辑器图片水印
- WIN7系统Dubbo-Admin管理平台搭建