基于Mozilla Thunderbird的扩展开发(八)---进程间通信之Socket篇(续)

简介:
最近遇到这样一个需求:在我们的MFC程序中控制Thunderbird。拿到这个奇怪的需求后,有了这么几个想法:1)用全局钩子试着勾住Thunderbird,可细想好像不对。2)用spy++探查点击Thunderbird的各个菜单,按钮时触发的事件,总归是win32平台上跑的程序,归根到底还是事件触发,从理论上说应该是可以在我们自己的MFC程序中模拟目标程序中的各个事件触发。
但接触到Mozilla的socket方面的知识后,放弃了上面的想法,改用socket通信来实现此需求。一来Thunderbird源代码可以自行修改,因此可以加入一些代码使之成为一个类似HTTP服务器的服务器端程序,二来使用socket进行连接与语言无关,因此C++的程序可以和javascript的程序完成通信,但缺点也很明显,要占用端口,只涉及到本地机器的通信却使用了socket这样的网络通信机制。
先来介绍下完成这个功能用到的基本知识:由于输入流基接口nsIInputStream没有提供任何从javascript中读取数据的方法,而只能在C++中读取,因此我们必须使用一个可脚本化的输入流来对其进行包装,这个可脚本化的输入流实现了nsIScriptableInputStream接口。
当然也可以使用其他流类型,比如为了读取二进制数据,我们可以使用nsIBinaryInputStream,反正在javascript中,你总得以其他形式的流来包装基流。
在Mozilla中,网络数据的读和写是在一个单独的线程中进行的,从socket中读数据是异步的,这就意味着只要socket中有数据存在,就在后台读取数据,而程序会收到数据可读的通知信息,这就意味着我们需要创建一个监听者来监听这个信息。
对于异步读取数据,我们还需要创建一个输入流Pump,之所以Mozilla选择“泵”这个名称是因为当有数据存在时它就发送小块的数据给监听者。这个Pump实现了nsIInputStreamPump接口,这个接口继承自nsIRequest,后者提供了暂停连接和特定的缓存行为(这些一般的socket程序用不上,但像HTTP这样构建在socket上的高层次应用会用得上的)。
pump.asyncRead(dataListener,null);
     asyncRead函数用来给Pump对象设置一个监听者,当有数据到来或连接关闭时,监听者就会被调用。监听者对象应该实现nsIStreamListener接口,这个接口有一个方法onDataAvailable,当有额外数据可读时就会被调用。此接口继承自nsIRequestObserver,这个接口有两个方法,onStartRequest,onStopRequest,这两个方法在输入流的开始和结束时分别被调用,因此这3个方法都应该实现。

下面是客户端代码,使用最简单的阻塞式TCP连接:
void CClientTestDlg::OnSend() 
{//发送按钮
    UpdateData();
    if(str.IsEmpty())
    {
        list.InsertString(0,"发送的字符串不能为空。");
        return;
    }
    //strcpy(msg.msg,(LPCTSTR)str);
    char szText[1024];
    strcpy(szText,(LPCTSTR)str);
    SOCKET socket = ::socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
    if(socket==INVALID_SOCKET)
    {
        list.InsertString(0,"创建socket发生错误。");
        return;
    }
    SOCKADDR_IN servAddr;
    servAddr.sin_family = AF_INET;
    servAddr.sin_port = htons(25501);
    servAddr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
    if(::connect(socket,(sockaddr*)&servAddr,sizeof(servAddr))==-1)
    {
        list.InsertString(0,"连接服务器发生错误。");
        return;
    }
    if(::send(socket,szText,strlen(szText),0) == SOCKET_ERROR)//    recv(ServerSocket,buf,sizeof(buf),0);
    {
        list.InsertString(0,"发送数据发生错误。");
        return;
    }
    int bytesRecv = SOCKET_ERROR;
    char buffer[1024];
    memset(buffer,0,1024);
    bytesRecv = recv( socket, buffer, 1024, 0 );
    DWORD dwerr = WSAGetLastError();
    CString str;
    str.Format("%s",buffer);
    list.InsertString(0,str);
    ::closesocket(socket);
}


服务器端代码,通过修改Thunderbird源代码,使之成为一个类似HTTP服务器的服务器端
 
//***************************************************************************
//Author: phinecos
//Date : 2008/5/19
//Description:服务器监听对象
//Contact:phinecos@163.com
//***************************************************************************
//服务器端对象

const CI = Components.interfaces, CC = Components.classes, CR = Components.results;

var gServer = null;//服务器对象
var gUtility = null;//工具类对象
//var gConnection = null;//客户端连接对象

function tBirdBiffServerOnLoad()
{//启动监听服务器
    
    try
    {
        gUtility = new tBirdBiffUtility();//新建日志对象
        gUtility.initialize();
          gUtility.log("tBirdBiffServerUi.tBirdBiffServerOnLoad", "Thunderbird biff server loaded");

        gServer = new tBirdBiffServer();//新建服务器对象
        gServer.initialize();//初始化服务器端
        gUtility.log("tBirdBiffServerOnLoad","start server");
    }
    catch(err)
    {
          gUtility.log("tBirdBiffServerOnLoad","start server failed");
    }
}

function tBirdBiffServerOnClose()
{//关闭服务器    
    gUtility.log("tBirdBiffServerOnClose","close server");
    gServer.finalize();
    gServer = null;
    gUtility = null;
}

function tBirdBiffServer()
{
  this.serverSocket = null;//服务器端socket
  this.port = null;//服务器端口
  this.initialized = false;
  gUtility.log("tBirdBiffServer constructor","construct ok");
}

tBirdBiffServer.prototype =
{
  getServerSocket: function()
  {//创建服务器端socket
    this.serverSocket = CC["@mozilla.org/network/server-socket;1"].createInstance(CI.nsIServerSocket);
    if(!this.serverSocket)
    {
      gUtility.log("tBirdBiffServer.getServerSocket","Unable to get a server socket");
    }
    else
    {
      try
      {
        this.serverSocket.init(this.port, false, -1);//初始化socket,绑定到端口port上
        this.serverSocket.asyncListen(tBirdBiffServerSocketListener);//开始异步监听
        gUtility.log("tBirdBiffServer.getServerSocket","Server socket established");
      }
      catch(e)
      {
         gUtility.log("tBirdBiffServer.getServerSocket, Server socket established error");
         this.serverSocket = null;
      }
    }
  },

  closeServerSocket: function()
  {//关闭服务器端socket
    if(!this.serverSocket)
    {
      this.serverSocket.close(null);
      this.serverSocket = null;
    }
  },

  initialize: function()
  {
    if(this.initialized)
    {
      return;
    }
    
    this.port = 25501;//获取端口号
    gUtility.log("tBirdBiffServer.initialize","port is: "+this.port);
    this.getServerSocket();//创建服务器端socket
    this.initialized = true;
       gUtility.log("tBirdBiffServer.initialize","initialize ok!");
  },
  finalize: function()
  {//退出程序
    if(!this.initialized)
    {
      return;
    }
    this.closeServerSocket();//关闭服务器端socket
    gUtility.log("tBirdBiffServer.finalize","server Finalized");
  },

}
  var listener = 
  {
    finished : function(data)
    {//数据读取完毕
      ParseCommand(data);//解析命令字
    }
  }

const tBirdBiffServerSocketListener =
{
  onSocketAccepted: function(serverSocket, clientSocket)
  {//接受来自客户端的socket请求
     gUtility.log("tBirdBiffServerSocketListener.onSocketAccepted","Got a connection from: " + clientSocket.host + ":" + clientSocket.port);
     var outputData = "Ok,server get your command";
     var outstream = clientSocket.openOutputStream(0,0,0);
     outstream.write(outputData,outputData.length);
     try
     {
         //打开输入流
         var stream = clientSocket.openInputStream(0,0,0);
         var instream = Components.classes["@mozilla.org/scriptableinputstream;1"].createInstance(Components.interfaces.nsIScriptableInputStream);
         instream.init(stream);
         
        var dataListener = 
        {
          data : "",//来自客户端的数据
          onStartRequest: function(request, context){},
          onStopRequest: function(request, context, status){
            instream.close();
            outstream.close();
            listener.finished(this.data);
          },
          onDataAvailable: function(request, context, inputStream, offset, count){
            this.data += instream.read(count);
          },
        };
        var pump = Components.classes["@mozilla.org/network/input-stream-pump;1"].createInstance(Components.interfaces.nsIInputStreamPump);
        pump.init(stream, -1, -1, 0, 0, false);
        pump.asyncRead(dataListener,null);
    }
    catch(err)
    {
        gUtility.log("tBirdBiffServerConnection.setSocket",e);
           return false;
    }
  },
  onStopListening: function(serverSocket, status)
  {//服务器端停止监听
    gUtility.log("tBirdBiffServerSocketListener.onStopListening","Server socket has stopped listening");
  }
}

 
Reference
1, http://www.xulplanet.com/tutorials/mozsdk/sockets.php
2, 基于Mozilla Thunderbird的扩展开发(五)---进程间通信之Socket篇(上)
3, 基于Mozilla Thunderbird的扩展开发(六)---进程间通信之Socket篇(下)
 


本文转自Phinecos(洞庭散人)博客园博客,原文链接:http://www.cnblogs.com/phinecos/archive/2008/05/27/1208729.html,如需转载请自行联系原作者

目录
相关文章
|
1月前
|
安全 Java 数据处理
Python网络编程基础(Socket编程)多线程/多进程服务器编程
【4月更文挑战第11天】在网络编程中,随着客户端数量的增加,服务器的处理能力成为了一个重要的考量因素。为了处理多个客户端的并发请求,我们通常需要采用多线程或多进程的方式。在本章中,我们将探讨多线程/多进程服务器编程的概念,并通过一个多线程服务器的示例来演示其实现。
|
1月前
|
Arthas 测试技术
这个错误提示表明Arthas无法打开目标进程的socket文
【1月更文挑战第11天】【1月更文挑战第55篇】这个错误提示表明Arthas无法打开目标进程的socket文
374 4
|
1月前
|
算法 Linux 调度
xenomai内核解析--xenomai与普通linux进程之间通讯XDDP(一)--实时端socket创建流程
xenomai与普通linux进程之间通讯XDDP(一)--实时端socket创建流程
159 1
xenomai内核解析--xenomai与普通linux进程之间通讯XDDP(一)--实时端socket创建流程
|
1月前
|
Java 调度 开发者
构建高效微服务架构:后端开发的新趋势深入理解操作系统之进程调度策略
【4月更文挑战第30天】 随着企业数字化转型的不断深入,传统的单体应用逐渐不能满足快速迭代和灵活部署的需求。微服务架构以其高度模块化、独立部署和易于扩展的特性,成为现代后端开发的重要趋势。本文将探讨如何构建一个高效的微服务架构,包括关键的设计原则、技术选型以及可能面临的挑战。
|
1月前
|
监控 C++
C++ Qt开发:QProcess进程管理模块
Qt是一个跨平台的C++图形库,简化了窗体应用开发,支持通过拖放组件提升效率。本章节关注`QProcess`组件,它用于控制和管理进程,例如执行命令、运行可执行文件及与外部进程通信。`QProcess`提供多种方法如`start`、`waitForStarted`和`waitForFinished`等,实现启动、监控和交互。示例展示了如何使用`QProcess`获取系统进程和信息,通过`tasklist`和`systeminfo`命令,并将结果展示在`QTreeWidget`中。
50 0
C++ Qt开发:QProcess进程管理模块
|
1月前
|
监控 Unix Linux
socket监控进程,并对程序执行有关操作。
socket监控进程,并对程序执行有关操作。
|
1月前
|
Arthas 测试技术
错误提示表明Arthas无法打开目标进程的socket文件
错误提示表明Arthas无法打开目标进程的socket文件
64 2
|
1月前
|
Linux 测试技术 调度
进程调度预备开发
进程调度预备开发
33 0
|
1月前
|
存储 Linux 调度
[操作系统]秋招面试问到进程扩展知识!!!面试官喜欢的答案
[操作系统]秋招面试问到进程扩展知识!!!面试官喜欢的答案
|
6月前
|
Windows
5.4 Windows驱动开发:内核通过PEB取进程参数
PEB结构`(Process Envirorment Block Structure)`其中文名是进程环境块信息,进程环境块内部包含了进程运行的详细参数信息,每一个进程在运行后都会存在一个特有的PEB结构,通过附加进程并遍历这段结构即可得到非常多的有用信息。在应用层下,如果想要得到PEB的基地址只需要取`fs:[0x30]`即可,TEB线程环境块则是`fs:[0x18]`,如果在内核层想要得到应用层进程的PEB信息我们需要调用特定的内核函数来获取。
63 0
5.4 Windows驱动开发:内核通过PEB取进程参数

相关实验场景

更多