GGTalk——C#开源即时通讯系统源码介绍系列(一)

摘要:
}}2.服务器接口实现namespaceGGTalk。服务器{internalclassRemotingService;this.rapidServerEngine=引擎;

       坦白讲,我们公司其实没啥技术实力,之所以还能不断接到各种项目,全凭我们老板神通广大!要知道他每次的饭局上可都是些什么人物!

       但是项目接下一大把,就凭咱哥儿几个的水平,想要独立自主、保质保量保期地一个个做出来,那也是有点难以置信。之前咱也跟老板反映过这个困难,建议他再召两个高手过来。不过领导虽然书读的不多,有一句古训倒是背得特别熟——“君子生非异也,善假于物也”。所以咱们公司一直奉行拿来主义。

       园子里的这个GGTalk——C#开源即时通讯系统,咱们前前后后用它移花接木做的IM项目也不下三四个了。初次入手的时候,洋洋代码,多少感觉有些难以把握。不过一来二去,理清了头绪,也就一览无余了。

       相信跟我们一样想要利用GGTalk的同学大有人在,于是我打算写这样一个《GGTalk——C#开源即时通讯系统源码介绍系列》,把自己对GGTalk的梳理分享给大家,让大家更容易上手。

      那接下来我们就言归正传。

一.GGTalk的宏观结构

      GGTalk——C#开源即时通讯系统源码介绍系列(一)第1张

      如图,GGTalk中有4个项目,第一个“GGTalk”是客户端项目;“GGTalk.Core”是客户端和服务端共用的一些类,主要包括一些数据实体,还有一些通信协议类;“GGTalk.Server”是服务端项目;“JustLib”是作者封装的一些常用类和控件。

二.GGTalk是如何实现注册的?

      GGTalk采用Remoting技术来完成注册。

1.先定义接口

namespace GGTalk
{
    /// <summary>
    /// 用于提供注册服务的Remoting接口。
    /// </summary>
    public interface IRemotingService :IChatRecordPersister
    {
        RegisterResult Register(GGUser user); 

        /// <summary>
        /// 根据ID或Name搜索用户【完全匹配】。
        /// </summary>   
        List<GGUser> SearchUser(string idOrName);

        /// <summary>
        /// 发送系统通知给所有在线用户。
        /// </summary>      
        void SendSystemNotify(string title, string content);
    }  
}

2.服务端接口实现

namespace GGTalk.Server
{
    internal class RemotingService :MarshalByRefObject, IRemotingService
    {
        private GlobalCache globalCache;
        private IRapidServerEngine rapidServerEngine;
        public RemotingService(GlobalCache db ,IRapidServerEngine engine)
        {
            this.globalCache = db;
            this.rapidServerEngine = engine;
        }     public RegisterResult Register(GGUser user)
        {
            try
            {
                if (this.globalCache.IsUserExist(user.UserID))
                {
                    return RegisterResult.Existed;
                }
                this.globalCache.InsertUser(user);
                return RegisterResult.Succeed;
            }
            catch (Exception ee)
            {
                return RegisterResult.Error;
            }
        }

        public List<GGUser> SearchUser(string idOrName)
        {
            return this.globalCache.SearchUser(idOrName);
        }

        public override object InitializeLifetimeService()
        {
            return null;
        }     
    }
}

3.服务端发布服务

 #region 发布用于注册的Remoting服务
 RemotingConfiguration.Configure("GGTalk.Server.exe.config", false);
 RemotingService registerService = new Server.RemotingService(globalCache ,Program.RapidServerEngine);
 RemotingServices.Marshal(registerService, "RemotingService");      
 #endregion      

服务端配置文件:

<system.runtime.remoting>
    <application>
      <channels>
        <!--用户注册Remoting服务端口-->
        <channel ref="tcp" port="4500" >
          <serverProviders>
            <provider ref="wsdl" />
            <formatter ref="soap" typeFilterLevel="Full" />
            <formatter ref="binary" typeFilterLevel="Full" />
          </serverProviders>
          <clientProviders>
            <formatter ref="binary" />
          </clientProviders>
        </channel>
      </channels>
    </application>
  </system.runtime.remoting>

4.客户端订阅服务

int registerPort = int.Parse(ConfigurationManager.AppSettings["RemotingPort"]);
this.remotingService = (IRemotingService)Activator.GetObject(typeof(IRemotingService), string.Format("tcp://{0}:{1}/RemotingService", ConfigurationManager.AppSettings["ServerIP"], registerPort)); ;

 三.总结Remoting技术

1.Remoting使用中的三要素:

      1.一个可远程处理的对象。

      2.一个服务端应用程序域用(也叫宿主应用程序域中),于侦听针对该对象的请求。

      3.一个客户端应用程序域,用于发出针对该对象的请求。

2.代理:

      代理是一个提供了和真实对象完全一样的接口、公共方法、属性等成员的对象。在运行过程中,.NET Remoting基于对象元数据生成代理。代理只提供接口,不提供对象的状态,因为对象的真正状态在宿主应用程序域中存储。代理在这里只转发调用。转发调用到一个对象叫封送处理。封送处理的目标是让客户端调用服务端时感觉不到是在与远端对象交流,而是与本地对象在交流。如果通过代理来访问对象,该对象必需是从 MarshalByRefObject抽象类派生。

3.Remoting架构:

      image 

四.知识点拓展

1. 用应用程序域

      操作系统和运行库环境通常会在应用程序间提供某种形式的隔离。例如,Microsoft Windows 使用进程来隔离应用程序。为确保在一个应用程序中运行的代码不会对其他不相关的应用程序产生不良影响,这种隔离是必需的。

      GGTalk——C#开源即时通讯系统源码介绍系列(一)第3张

2.用应用程序域优点

      在一个应用程序中出现的错误不会影响其他应用程序。因为类型安全的代码不会导致内存错误,所以使用应用程序域可以确保在一个域中运行的代码不会影响进程中的其他应用程序。

      能够在不停止整个进程的情况下停止单个应用程序。使用应用程序域使您可以卸载在单个应用程序中运行的代码。

      在一个应用程序中运行的代码不能直接访问其他应用程序中的代码或资源。为了强制实施此隔离,公共语言运行库禁止在不同应用程序域中的对象之间进行直接调用。要在各域之间传递对象,可以复制这些对象,或通过代理访问这些对象。如果复制对象,那么对该对象的调用为本地调用。也就是说,调用方和被引用的对象位于同一应用程序域中。如果通过代理访问对象,那么对该对象的调用为远程调用。在此情况下,调用方和被引用的对象位于不同的应用程序域中。域间调用所采用的远程调用基础结构与两个进程间的调用或两台计算机间的调用的基础结构相同。因此,被引用的对象的元数据必须对于两个应用程序域均可用,以便用 JIT 正确编译该方法调用。如果调用域对被调用对象的元数据没有访问权,则编译可能失败,并引发类型为 System.IO.FileNotFound 的异常。

      代码行为的作用范围由它运行所在的应用程序决定。换言之,应用程序域将提供应用程序版本策略等配置设置、它所访问的任意远程程序集的位置,以及加载到该域中的程序集的位置信息。

      向代码授予的权限可以由代码运行所在的应用程序域来控制。

五.后记

      这是该系列的第一篇,一篇博客篇幅有限,能讲清楚一两个问题已经很不错。要想把GGTalk——C#开源即时通讯系统全部讲透,恐怕得要上百篇博客才够。首先要感谢GGTalk的作者,能够开发出这样优秀的C#开源即时通讯系统,而且无私的开源出来。其次,希望我做的工作也能给大家带来收获,一方面可以方便大家利用GGTalk,另一方面也为学习GGTalk的同学提供一个参考,希望大家可以从中汲取营养,不仅仅是复用这些代码,也能够从中学到蕴含着的知识与技术。

      解读GGTalk,这个工作很辛苦,希望大家鼓励,也希望更多的朋友参与其中!

免责声明:文章转载自《GGTalk——C#开源即时通讯系统源码介绍系列(一)》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇基于GTID的主从架构异常处理流程Vue 监听---&amp;gt;watch下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

java强制类型转换

在Java项目的实际开发和应用中,常常需要用到将对象转为String这一基本功能。本文将对常用的转换方法进行一个总结。常用的方法有Object.toString(),(String)要转换的对象,String.valueOf(Object)等。下面对这些方法一一进行分析。 方法1:采用 Object.toString()方法 请看下面的例子: 1 Obj...

C#笔记21:多线程之线程同步中的锁定lock、Monitor

C#笔记21:多线程之线程同步中的锁定lock、Monitor 1:什么是锁 2:如何选择锁定对象 3:如何锁定集合 4:Monitor 1:什么是锁      lock 语句可以用来确保代码块完成运行,而不会被其他线程中断。这是通过在代码块运行期间为给定对象获取互斥锁来实现的。 2:如何选择锁定对象      提供给 lock 关键字的参数必须为基于引用...

当析构函数遇到多线程 ── C++ 中线程安全的对象回调

陈硕 (giantchen_AT_gmail) 本文 PDF  下载: http://www.cppblog.com/Files/Solstice/dtor_meets_mt.pdf 摘要 编写线程安全的类不是难事,用同步原语保护内部状态即可。但是对象的生与死不能由对象自身拥有的互斥器来保护。如何保证即将析构对象 x 的时候,不会有另一个线程正在调用...

.NET Mocking Framework对比

  单元测试中,为了让单元测试程序完全脱离外部依赖,需要使用到Mock对象和Stub对象。虽然可以手工编写Mock对象和Stub对象,但通常我们都使用Mocking Framework来帮助我们简单快速的构建需要的Mock对象以及Stub对象。 一、概述   常见的Mocking Framework有如下几种:     1、Rhino Mocks V3...

反序列化漏洞

反序列化 原理介绍 序列化就是把对象转换成字节流,便于保存在内存、文件、数据库中;反序列化即逆过程,由字节流还原成对象。Java中的ObjectOutputStream类的writeObject()方法可以实现序列化,类ObjectInputStream类的readObject()方法用于反序列化。比如你可以将字符串对象先进行序列化,存储到本地文件,然后再...

AE加载不同数据的方法(GeoDatabase空间数据管理)

先看一下GeoDatabase核心结构模型图:     1  工作空间工厂WorkspaceFactory对象    WorkspaceFactory是GeoDatabase的入口,是一个抽象类,拥有很多子类,例如SdeWorkspaceFactory, AccessWorkspaceFactory, ShapfileWorkspaceFactory ...