备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

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

2017-12-21 1382
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：
最近遇到这样一个需求：在我们的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，如需转载请自行联系原作者

文章标签：
JavaScript
C++
前端开发
关键词：
开发进程
mozilla thunderbird扩展开发进程socket
扩展进程
嗯哼9925
目录
相关文章
lyshark
|
2月前
|
监控 C++
C++ Qt开发：QProcess进程管理模块
Qt是一个跨平台的C++图形库，简化了窗体应用开发，支持通过拖放组件提升效率。本章节关注`QProcess`组件，它用于控制和管理进程，例如执行命令、运行可执行文件及与外部进程通信。`QProcess`提供多种方法如`start`、`waitForStarted`和`waitForFinished`等，实现启动、监控和交互。示例展示了如何使用`QProcess`获取系统进程和信息，通过`tasklist`和`systeminfo`命令，并将结果展示在`QTreeWidget`中。
lyshark
31 0
C++ Qt开发：QProcess进程管理模块
程序员三木
|
5月前
|
存储 Linux 调度
[操作系统]秋招面试问到进程扩展知识！！！面试官喜欢的答案
[操作系统]秋招面试问到进程扩展知识！！！面试官喜欢的答案
程序员三木
42 0
lyshark
|
5月前
|
Windows
5.4 Windows驱动开发：内核通过PEB取进程参数
PEB结构`(Process Envirorment Block Structure)`其中文名是进程环境块信息，进程环境块内部包含了进程运行的详细参数信息，每一个进程在运行后都会存在一个特有的PEB结构，通过附加进程并遍历这段结构即可得到非常多的有用信息。在应用层下，如果想要得到PEB的基地址只需要取`fs:[0x30]`即可，TEB线程环境块则是`fs:[0x18]`，如果在内核层想要得到应用层进程的PEB信息我们需要调用特定的内核函数来获取。
lyshark
49 0
5.4 Windows驱动开发：内核通过PEB取进程参数
lyshark
|
5月前
|
监控 安全 API
7.1 Windows驱动开发：内核监控进程与线程回调
在前面的文章中`LyShark`一直在重复的实现对系统底层模块的枚举，今天我们将展开一个新的话题，内核监控，我们以`监控进程线程`创建为例，在`Win10`系统中监控进程与线程可以使用微软提供给我们的两个新函数来实现，此类函数的原理是创建一个回调事件，当有进程或线程被创建或者注销时，系统会通过回调机制将该进程相关信息优先返回给我们自己的函数待处理结束后再转向系统层。
lyshark
61 0
7.1 Windows驱动开发：内核监控进程与线程回调
lyshark
|
5月前
|
存储 Windows
4.6 Windows驱动开发：内核遍历进程VAD结构体
在上一篇文章`《内核中实现Dump进程转储》`中我们实现了ARK工具的转存功能，本篇文章继续以内存为出发点介绍`VAD`结构，该结构的全程是`Virtual Address Descriptor`即`虚拟地址描述符`，VAD是一个`AVL`自`平衡二叉树`，树的每一个节点代表一段虚拟地址空间。程序中的代码段，数据段，堆段都会各种占用一个或多个`VAD`节点，由一个`MMVAD`结构完整描述。
lyshark
41 0
4.6 Windows驱动开发：内核遍历进程VAD结构体
lyshark
|
5月前
|
存储 数据安全/隐私保护 Windows
4.5 Windows驱动开发：内核中实现进程数据转储
多数ARK反内核工具中都存在驱动级别的内存转存功能，该功能可以将应用层中运行进程的内存镜像转存到特定目录下，内存转存功能在应对加壳程序的分析尤为重要，当进程在内存中解码后，我们可以很容易的将内存镜像导出，从而更好的对样本进行分析，当然某些加密壳可能无效但绝大多数情况下是可以被转存的。
lyshark
24 0
4.5 Windows驱动开发：内核中实现进程数据转储
lyshark
|
5月前
|
监控 Windows
4.4 Windows驱动开发：内核监控进程与线程创建
当你需要在Windows操作系统中监控进程的启动和退出时，可以使用`PsSetCreateProcessNotifyRoutineEx`函数来创建一个`MyCreateProcessNotifyEx`回调函数，该回调函数将在每个进程的创建和退出时被调用。PsSetCreateProcessNotifyRoutineEx 用于在系统启动后向内核注册一个回调函数，以监视新进程的创建和退出，
lyshark
41 0
4.4 Windows驱动开发：内核监控进程与线程创建
lyshark
|
5月前
|
监控 安全 Windows
4.3 Windows驱动开发：监控进程与线程对象操作
在内核中，可以使用`ObRegisterCallbacks`这个内核回调函数来实现监控进程和线程对象操作。通过注册一个`OB_CALLBACK_REGISTRATION`回调结构体，可以指定所需的回调函数和回调的监控类型。这个回调结构体包含了回调函数和监控的对象类型，还有一个`Altitude`字段，用于指定回调函数的优先级。优先级越高的回调函数会先被调用，如果某个回调函数返回了一个非NULL值，后续的回调函数就不会被调用。当有进程或线程对象创建、删除、复制或重命名时，内核会调用注册的回调函数。回调函数可以访问被监控对象的信息，如句柄、进程ID等，并可以采取相应的操作，如打印日志、记录信息等。
lyshark
32 0
4.3 Windows驱动开发：监控进程与线程对象操作
lyshark
|
6月前
|
存储 安全 调度
4.2 Windows驱动开发：内核中进程线程与模块
内核进程线程和模块是操作系统内核中非常重要的概念。它们是操作系统的核心部分，用于管理系统资源和处理系统请求。在驱动安全开发中，理解内核进程线程和模块的概念对于编写安全的内核驱动程序至关重要。内核进程是在操作系统内核中运行的程序。每个进程都有一个唯一的进程标识符（PID），它用于在系统中唯一地标识该进程。在内核中，进程被表示为一个进程控制块（PCB），它包含有关进程的信息，如进程状态、优先级、内存使用情况等。枚举进程可以让我们获取当前系统中所有正在运行的进程的PID和其他有用的信息，以便我们可以监视和管理系统中的进程。
lyshark
70 0
4.2 Windows驱动开发：内核中进程线程与模块
lyshark
|
6月前
|
存储 API Windows
4.1 Windows驱动开发：内核中进程与句柄互转
在内核开发中，经常需要进行进程和句柄之间的互相转换。进程通常由一个唯一的进程标识符（PID）来标识，而句柄是指对内核对象的引用。在Windows内核中，`EProcess`结构表示一个进程，而HANDLE是一个句柄。为了实现进程与句柄之间的转换，我们需要使用一些内核函数。对于进程PID和句柄的互相转换，可以使用函数如`OpenProcess`和`GetProcessId`。OpenProcess函数接受一个PID作为参数，并返回一个句柄。GetProcessId函数接受一个句柄作为参数，并返回该进程的PID。
lyshark
49 1
4.1 Windows驱动开发：内核中进程与句柄互转