Libjingle中重要概念

Signals、sigslot简介

在复杂的工程中，整个系统被分为数个模块，每个模块提供有限的功能，由上层调用从而组成整个系统，为了保证每个模块的独立性，我们经常限制模块与模块之间直接联系，每个模块只提供有限的API或Com接口，内部完全封装起来。

       有时候两个不同的逻辑层的模块需要通信，如果直接include头文件会使项目变的复杂，sigslot的出现为我们提供了一种解决问题的思想，它用“信号”的概念实现不同模块之间的传输问题，sigslot本身类似于一条通讯电缆，两端提供发送器和接收器，只要把两个模块用这条电缆连接起来就可以实现接口调用，而sigslot本身只是一个轻量级的作品，整个库只有一个.h文件，所以无论处于何种层次的库，都可以非常方便的包含它。

 

 举个例子，我们设计一个发送消息的类，这个类负责在某种时刻向外界发出求救信号

#include "sigslot.h"

class Sender  
{
public:
    // 定义信号，该信号有两个参数
    sigslot::signal2< std::string , int > SignalDanger;
    
    // 该函数发送消息
    void Panic()
    {
        SignalDanger("Help!", 0); 
    }
};

 

另外一个类则负责接收求助信号

class Receiver : public sigslot::has_slots<>
{
public:
    // 接收SignalDanger 信号的函数，该函数参数必须和信号的参数一致
    void OnDanger(std::string message, int time)
    {
        printf("I heard something like "%s" at %d!n", message.c_str(), time);
    }
};

现在让我们在主逻辑中把这两个类连接起来

Sender sender;
Receiver receiver;

// 将发送者的信号连接到接收方的接收函数上；和断开连接
sender.SignalDanger.connect(&receiver, Receiver::OnDanger);

sender.SignalDanger.disconnect(&receiver);

只要在任何时候调用 sender.Panic()函数，就会把求救信号发送给接收者，而且这两个发送和接收端的模块都可以独立编译，不会出现版本问题。

 

libjingle命名规则：

信号命名：signal....

收到信号：on...

 

 

 

扩展思考：

1.       可以在消息循环处理函数中调用不同的类进行处理

 

 

Threads、signaling thread和worker thread

Libjingle部件使用一个或两个全局线程：

Signaling thread：它主要用来创建所有底层部件、例如Session Manager、Control、Xmpp.

worker thread(channel thread)：被P2P组件对象用来处理更多资源密集的过程，例如数据流。放入独立线程中的这些数据流，被xmpp阻塞或被用户界面阻塞。使用worker thread的类有ChandleManager，SocketMonitor、P2PtransportChannel和port objects。为了使用该线程，你必须创建一个thread对象并将它传递到SessionMnager的constructor中。如果没有线程对象传入、the thread in which sessionManager 被创建为工作线程。在CallClient::InitPhone中演示了如何为底层创建一个workthread线程。

 

此外，现在libjingle提供了一个SignalThread，扩展此类现存的类可用，可被实例化、开始、

 

尽管libjingle支持多线程，只有确认是线程安全的，例如在methods中：

ASSERT(talk_base::Thread::Current() == channel_thread_);

channel_thread_->Clear(this);

 

libjingle包装了线程、信号线程、工作线程和任何其他线程，用task_base::Thread. 所有线程对象是由ThreadManager管理。SessionManager调用ThreadManager::CurrentThread提供它用signal thread当它是实体。XmppPump使用当前线程的信号线。因此，你必须为信号线而创建一个线程对象，并将它放入ThreadManager的线程池中，之前需创建SessionManager对象，或者期待XmppPump开始工作。（看Siging in server代码例子）这里有两种方法创建线程：

·AutoThread 是用libjingle对象包装现有系统的线程，并使当前线程在ThreadManager的线程池中（将返回线程如果Thread::CurrentThread被调用）

·Thread为work thread创建和包装新线程。为了使用线程，创建一个新的Thread对象，调用ThreadManager::Add或ThreadManager::SetCurrent将它添加到线程池中，并调用Run()开始运行在阻塞循环中，或调用Start()开始线程侦听。

 

线程提供了信息交换的渠道在两个对象之间。例如SocketManager发送一个信息到他自己或别的线程为了摧毁socket。线程对象继承消息队列 ，和他们一起揭露发送 ， 邮政和发送邮件同步和异步的其他方法。一个对象，它发送的邮件会收到使用消息队列必须继承和实施MessageHandler。MessageHandler定义onMessage方法，这与所谓的消息队列消息。

 

您可以将邮件发送到任何对象继承talk_base::MessageHandler对任何线程talk_base::MessageHandler但是，如果发送消息来执行一个资源密集的线，你应该发送的工作线程的消息。你能得到处理，要求SessionManager::worker_thread（）。你能得到处理，要求SessionManager::signaling_thread（）。

 

一个对象有几种方法来访问一个特定的线程：它可以请求和存储作为输入参数的线程的指针，它可以假定当前线程创建时（由ThreadManager访问：：在其构造CurrentThread）是一个特殊的线程和高速缓存的成员指向它的指针，它可以调用SessionManger：：signal_thread（）或SessionManager：：worker_thread（）检索线程。所有这三个技术用于了libjingle。

 

因为对象可以在任何线程调用，对象可能需要验证的线程被调用的方法。要做到这一点，调用线程：：目前 （即当前线程检索）和比对已知线程的价值-这可以是由SessionManager，或者对象暴露了一个线程可以存储在一个指针，它的初始线程构造。以下是调用在另一个线程上的同一个对象的方法，更加广泛的例子。

 转自：http://blog.csdn.net/shuixin536/article/details/8074498