Mozilla Thunderbird的擴展開發(fā)
最近遇到這樣一個需求：在我們的MFC程序中控制Thunderbird。拿到這個奇怪的需求后，有了這么幾個想法：1)用全局鉤子試著勾住Thunderbird，可細想好像不對。2)用spy++探查點擊Thunderbird的各個菜單，按鈕時觸發(fā)的事件，總歸是win32平臺上跑的程序，歸根到底還是事件觸發(fā)，從理論上說應(yīng)該是可以在我們自己的MFC程序中模擬標目程序中的各個事件觸發(fā)。
但接觸到Mozilla的socket方面的知識后，放棄了上面的想法，改用socket通信來實現(xiàn)此需求。一來Thunderbird源代碼可以自行修改，因此可以加入一些代碼使之成為一個類似HTTP服務(wù)器的服務(wù)器端程序，二來使用socket進行連接與語言無關(guān)，因此C++的程序可以和javascript的程序完成通信，但缺點也很明顯，要占用端口，只涉及到本地機器的通信卻使用了socket這樣的網(wǎng)絡(luò)通信機制。
先來介紹下完成這個功能用到的基本知識：由于輸入流基接口nsIInputStream沒有提供任何從javascript中讀取數(shù)據(jù)的方法，而只能在C++中讀取，因此我們必須使用一個可腳本化的輸入流來對其進行包裝，這個可腳本化的輸入流實現(xiàn)了nsIScriptableInputStream接口。
當然也可以使用其他流類型，比如為了讀取二進制數(shù)據(jù)，我們可以使用nsIBinaryInputStream，反正在javascript中，你總得以其他形式的流來包裝基流。
在Mozilla中，網(wǎng)絡(luò)數(shù)據(jù)的讀和寫是在一個單獨的線程中進行的，從socket中讀數(shù)據(jù)是異步的，這就意味著只要socket中有數(shù)據(jù)存在，就在后臺讀取數(shù)據(jù)，而程序會收到數(shù)據(jù)可讀的通知信息，這就意味著我們需要創(chuàng)建一個監(jiān)聽者來監(jiān)聽這個信息。
對于異步讀取數(shù)據(jù)，我們還需要創(chuàng)建一個輸入流Pump,之所以Mozilla選擇“泵”這個名稱是因為當有數(shù)據(jù)存在時它就發(fā)送小塊的數(shù)據(jù)給監(jiān)聽者。這個Pump實現(xiàn)了nsIInputStreamPump接口，這個接口繼承自nsIRequest,后者提供了暫停連接和特定的緩存行為(這些一般的socket程序用不上，但像HTTP這樣構(gòu)建在socket上的高層次應(yīng)用會用得上的)。
pump.asyncRead(dataListener,null);
asyncRead函數(shù)用來給Pump對象設(shè)置一個監(jiān)聽者，當有數(shù)據(jù)到來或連接關(guān)閉時，監(jiān)聽者就會被調(diào)用。監(jiān)聽者對象應(yīng)該實現(xiàn)nsIStreamListener接口，這個接口有一個方法onDataAvailable,當有額外數(shù)據(jù)可讀時就會被調(diào)用。此接口繼承自nsIRequestObserver，這個接口有兩個方法，onStartRequest，onStopRequest，這兩個方法在輸入流的開始和結(jié)束時分別被調(diào)用，因此這3個方法都應(yīng)該實現(xiàn)。
下面是客戶端代碼，使用最簡單的阻塞式TCP連接：
- void CClientTestDlg::OnSend()
- {//發(fā)送按鈕
- UpdateData();
- if(str.IsEmpty())
- {
- list.InsertString(0,"發(fā)送的字符串不能為空。");
- 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,"創(chuàng)建socket發(fā)生錯誤。");
- 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,"連接服務(wù)器發(fā)生錯誤。");
- return;
- }
- if(::send(socket,szText,strlen(szText),0) == SOCKET_ERROR)// recv(ServerSocket,buf,sizeof(buf),0);
- {
- list.InsertString(0,"發(fā)送數(shù)據(jù)發(fā)生錯誤。");
- 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);
- }
#p#
服務(wù)器端代碼，通過修改Thunderbird源代碼，使之成為一個類似HTTP服務(wù)器的服務(wù)器端
- //***************************************************************************
- //Author: phinecos
- //Date : 2008/5/19
- //Description:服務(wù)器監(jiān)聽對象
- //Contact:phinecos@163.com
- //***************************************************************************
- //服務(wù)器端對象
- const CI = Components.interfaces, CC = Components.classes, CR = Components.results;
- var gServer = null;//服務(wù)器對象
- var gUtility = null;//工具類對象
- //var gConnection = null;//客戶端連接對象
- function tBirdBiffServerOnLoad()
- {//啟動監(jiān)聽服務(wù)器
- try
- {
- gUtility = new tBirdBiffUtility();//新建日志對象
- gUtility.initialize();
- gUtility.log("tBirdBiffServerUi.tBirdBiffServerOnLoad", "Thunderbird biff server loaded");
- gServer = new tBirdBiffServer();//新建服務(wù)器對象
- gServer.initialize();//初始化服務(wù)器端
- gUtility.log("tBirdBiffServerOnLoad","start server");
- }
- catch(err)
- {
- gUtility.log("tBirdBiffServerOnLoad","start server failed");
- }
- }
- function tBirdBiffServerOnClose()
- {//關(guān)閉服務(wù)器
- gUtility.log("tBirdBiffServerOnClose","close server");
- gServer.finalize();
- gServer = null;
- gUtility = null;
- }
- function tBirdBiffServer()
- {
- this.serverSocket = null;//服務(wù)器端socket
- this.port = null;//服務(wù)器端口
- this.initialized = false;
- gUtility.log("tBirdBiffServer constructor","construct ok");
- }
- tBirdBiffServer.prototype =
- {
- getServerSocket: function()
- {//創(chuàng)建服務(wù)器端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);//開始異步監(jiān)聽
- gUtility.log("tBirdBiffServer.getServerSocket","Server socket established");
- }
- catch(e)
- {
- gUtility.log("tBirdBiffServer.getServerSocket, Server socket established error");
- this.serverSocket = null;
- }
- }
- },
- closeServerSocket: function()
- {//關(guān)閉服務(wù)器端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();//創(chuàng)建服務(wù)器端socket
- this.initialized = true;
- gUtility.log("tBirdBiffServer.initialize","initialize ok!");
- },
- finalize: function()
- {//退出程序
- if(!this.initialized)
- {
- return;
- }
- this.closeServerSocket();//關(guān)閉服務(wù)器端socket
- gUtility.log("tBirdBiffServer.finalize","server Finalized");
- },
- }
- var listener =
- {
- finished : function(data)
- {//數(shù)據(jù)讀取完畢
- 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 : "",//來自客戶端的數(shù)據(jù)
- 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)
- {//服務(wù)器端停止監(jiān)聽
- gUtility.log("tBirdBiffServerSocketListener.onStopListening","Server socket has stopped listening");
- }
- }
【編輯推薦】
