文档章节

tigase内部处理(1):启动

greki
 greki
发布于 2014/06/06 16:57
字数 783
阅读 951
收藏 2
点赞 0
评论 0

1.启动

参考:http://my.oschina.net/greki/blog/209928

入口:XMPPServer.start(),关键源码如下:

router = (MessageRouterIfc) Class.forName( mr_class_name ).newInstance();
router.setName( serverName );
router.setConfig( config );//初始化配置
router.start();//启动

1.1.MessageRouter.setConfig(config)

主要任务就是初始化组件,把组件按名字和对绑定到相关的变量里,为后面xmpp packet路由做准备;

components.put(getName(), this);//将自己添加到自己的components成员变量
this.config = config;//将config赋值给自己的成员变量
config.addRegistrator(config);//config注册到自己的成员变量registrators

--->addRegistrator()

registrators.put(registr.getName(),registr);//1.registr注册到MessageRouter的registrators
addComponent(registr);//2.registr注册到MessageRouter的components和components_byId
for (ServerComponent comp : components.values()) {
  registr.addComponent(comp);//3
}
--------->2:addComponent(registr)
for (ComponentRegistrator registr : registrators.values()) {
	if (registr != component) {
		registr.addComponent(component);
	}
}      
components.put(component.getName(), component);
components_byId.put(component.getComponentId(), component);
if (component instanceof XMPPService) {
      xmppServices.put(component.getName(), (XMPPService) component);
}

--------------->3:registr.addComponent(comp)

if (isCorrectType(component)) {
	components.put(component.getName(), (E) component);
	componentAdded((E) component);
	return true;
} else {
	return false;
}

----------------------->4:componentAdded((E) component);调用setup方法

1.getDefConfigParams()

        通过[BasicComponent和ConfigaratorAbstract].getDefaults 获取初始化默认参数列表 ,添加感兴趣的属性。 MessageRouter与registr在执行getDefaults不同的是,他还有获取AbstractMessageReceive的成员变量信息。添加了队列的相关信息。

    在通过 MessageRouterConfig.getDefaults(defs, params, getName())设置MessageRouter配置信息。

2.component.setProperties

    BasicComponent和ConfigaratorAbstract的setProperties方法,设置组件成员变量:如:compId、defHostname、admins、commandsACL等,并loadScripts。此过程主要是通过加载、过滤参数列表,初始化话registr组件。

     每个component的初始化方法就是component.setProperties

1.2.MessageRouter.setProperties的初始化

这里可以帮助我理解packet在组件中是怎么处理的,packet有个from和to属性,包在组件间的路由主要根据TO属性来判断有谁来处理这个packet

1.这里有2个对后面包处理关系比较的

ServerComponent mr
if (mr instanceof MessageReceiver) {
  ((MessageReceiver) mr).setParent(this);//把message-router设置为他的上级服务器组件
   ((MessageReceiver) mr).start();  //MessageReceiver启动处理component的in和out的QueueListener处理线程,监听AbstractMessageReceiver的in和out的packet_queue

2.如果是messagerReceiver添加到组件的路由

if (mr instanceof MessageReceiver) {
	addRouter((MessageReceiver) mr);
} else {
	addComponent(mr);
}

3.组件初始化完毕处理

for (ServerComponent comp : components.values()) {
	comp.initializationCompleted();
}

4.特别说明下clientConnectionManager.initializationCompleted()处理;

追踪了下,c2s是怎么接收client发送过来的tcp的包和处理的;

最终会启动负责读写的socketReadThread和socketWriteThread及ResultsListener线程;报文的接受和发送是通过nio实现;用户的socketChannel是被对象

socketIO持有,再被IOService【集成了Callable】持有,再被放到selectionKey里;

socketThread线程在收到报文后,selectionKey的IOService放到forCompletion的列表里,

在统一被completionService.submit(serv),调用XMPPIOService的call方法进行内部的packet处理;

ResultsListener负责处理处理完毕的IOService;

(对于packet在tigase的内部处理,到时候在起一篇文章整理下;基本上都是线程+队里的处理方式)

可以先看下http://my.oschina.net/greki/blog/209588

1.3.再看看router.start()启动

主要调用了AbstractMessageReceiver.startThreads();启动了router组件的in和out线程,处理由QueueListener的run来处理;

收到queue里的packet,根据packet.to属性获的来处理该packet的component,交它处理


packet=queue.take()
message_router.processPacket(packet){
compent comp = getLocalComponent(packet.getTo());
compent.processPacket(packet)


© 著作权归作者所有

共有 人打赏支持
greki
粉丝 94
博文 109
码字总数 45232
作品 0
杭州
技术主管
Tigase开发笔记

Tigase学习笔记整理 1、主要分三部分组成: 1、组件(component,tigase的核心) 2、Plugin(插件,被sessionManager组件和C2S组件加载) 3、连接器(认证连接器和用户数据连接器) 2、 组件接口...

wjwei113 ⋅ 2014/12/19 ⋅ 0

Tigase组件第一节 – 概述和基础信息

本文翻译自 - http://www.tigase.org/content/component-implementation-lesson-1-basics Tigase组件是一个具有jid的实体。它可以接受/处理也可以产生packet。 举一些大家都知道的组件:MUC...

GREKI ⋅ 2014/03/19 ⋅ 0

tigase用户集成

tigase官方说明 目前支持的有 At the moment the Tigase server offers following authentication connectors: 'mysql', 'pgsql', 'derby' - standard authentication connector used to lo......

GREKI ⋅ 2014/03/31 ⋅ 4

tigase代码框架解读

摘要: 在java下实现的xmpp开源实现,除了openfire外,tigase是另一个牛逼的项目。实际的实验室压力下,50万人同时在线的单 机,tigase的gc情况要优于openfire,而且openfire的网络层代码借鉴...

今幕明 ⋅ 2014/09/10 ⋅ 0

搭建Tigase jaxmpp使用

假设本机已经成功安装了MySQL数据库 A:搭建Tigase 官方安装文档:http://www.tigase.org/content/manual-installation-console-mode 1:下载架包并解压缩 /usr/local/tigase-server-5.1.4-b...

丁佳辉 ⋅ 2016/06/08 ⋅ 0

linux tigase (IM服务器)安装

官方指导:http://www.tigase.org/content/manual-installation-console-mode 安装的为derby db,有人说是个内存数据库(也不是,数据会保留到磁盘) 1 下载安装包 https://projects.tigase....

GREKI ⋅ 2014/03/10 ⋅ 5

XMPP服务tigase配置流程

下载jdk,我使用的是1.8版本的。 下载tigase包,我使用tigase-server-5.2.1-b3461-dist-max.tar,这个包,在JDK1.6 上,运行不起来。需要在1.7以上。 解压缩包, $ unzip tigase-server-x.y....

淡风 ⋅ 2014/04/25 ⋅ 0

Tigase组件 – Packet过滤

本文翻译自 – http://www.tigase.org/content/packet-filtering-component Packet过滤API Tigase为所有组件都提供了一个packet过滤API。你可以分别过滤传入和传出packet。 通过学习过滤,我...

GREKI ⋅ 2014/03/20 ⋅ 0

Tigase XMPP Server源码部署

1相关文档 Tigase官网:http://www.tigase.org 开发指南:http://www.tigase.org/devel-guide Eclipse下部署Tigase源码:Hack Tigase Jabber/XMPP Server in Eclipse Tigase5.2版本以后使用了......

蛙牛 ⋅ 2014/04/29 ⋅ 1

eclipse部署tigase源码

1 下载tigase源码一份 要用git下载,下载地址:git clone https://svn.tigase.org/git/tigase-server.git 2 通过eclipse的import引入maven项目(tigase源码是maven项目) 3 配置启动项 Main...

今幕明 ⋅ 2014/04/29 ⋅ 2

没有更多内容

加载失败,请刷新页面

加载更多

下一页

LVM

LVM: 硬盘划分分区成物理卷->物理卷组成卷组->卷组划分逻辑分区。 1.磁盘分区: fdisk /dev/sdb 划分几个主分区 输入t更改每个分区类型为8e(LVM) 使用partprobe生成分区的文件:如/dev/sd...

ZHENG-JY ⋅ 35分钟前 ⋅ 0

彻底删除Microsoft Office的方法

参照此链接彻底删除Office https://support.office.com/zh-cn/article/%e4%bb%8e-pc-%e5%8d%b8%e8%bd%bd-office-9dd49b83-264a-477a-8fcc-2fdf5dbf61d8?ui=zh-CN&rs=zh-CN&ad=CN......

Kampfer ⋅ 50分钟前 ⋅ 0

大盘与个股之间关系

大盘走多:积极出手 顺势加码 大盘走空: 少量出手 退场观望 大盘做头:逆势减码 少量操作 大盘做底 : 小量建仓 小量试单

guozenhua ⋅ 51分钟前 ⋅ 0

Day16 LVM(逻辑卷管理)与磁盘故障小案例

lvm详解 简述 LVM的产生是因为传统的分区一旦分区好后就无法在线扩充空间,也存在一些工具能实现在线扩充空间但是还是会面临数据损坏的风险;传统的分区当分区空间不足时,一般的解决办法是再...

杉下 ⋅ 58分钟前 ⋅ 0

rsync实现多台linux服务器的文件同步

一、首先安装rsync,怎样安装都行,rpm,yum,还是你用源码安装都可以。因为我用的是阿里云的ESC,yum install rsync就ok了。 二、配置rsync服务 1.先建立个同步数据的帐号 123 groupadd r...

在下头真的很硬 ⋅ 今天 ⋅ 0

前端基础(三):函数

字数:1685 阅读时间:5分钟 函数定义 在最新的ES规范中,声明函数有4中方法: -函数声明 -函数表达式 -构造函数Function -生成器函数 1.函数声明 语法: function name([param[, param2 [....

老司机带你撸代码 ⋅ 今天 ⋅ 0

Java虚拟机的Heap监狱

在Java虚拟机中,我是一个位高权重的大管家,他们都很怕我,尤其是那些Java 对象,我把他们圈到一个叫做Heap的“监狱”里,严格管理,生杀大权尽在掌握。 中国人把Stack翻译成“栈”,把Hea...

java高级架构牛人 ⋅ 今天 ⋅ 0

Spring MVC基本概念

只写Controller

颖伙虫 ⋅ 今天 ⋅ 0

微软重金收购GitHub的背后逻辑原来是这样的

全球最大的开发者社区GitHub网站花落谁家的问题已经敲定,微软最终以75亿美元迎娶了这位在外界看来无比“神秘”的小家碧玉。尽管此事已过去一些时日,但整个开发者世界,包括全球各地的开源社...

linux-tao ⋅ 今天 ⋅ 0

磁盘管理—逻辑卷lvm

4.10-4.12 lvm 操作流程: 磁盘分区-->创建物理卷-->划分为卷组-->划分成逻辑卷-->格式化、挂载-->扩容。 磁盘分区 注: 创建分区时需要更改其文件类型为lvm(代码8e) 分区 3 已设置为 Linu...

弓正 ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部