快捷導(dǎo)航

利用thrift實現(xiàn)js與C#通訊的實例代碼

更新時間：2013年04月16日 11:02:17 作者：

利用thrift實現(xiàn)js與C#通訊的實例代碼，需要的朋友可以參考一下

1.為什么要用thrift js C#？

1.1 首先，js 通過 thrift 訪問C#，實際上是一種c/s模式。thrift是通信工具，js是客戶端，C#是服務(wù)端。

1.2 使用js直接與thrift server通信。讓web開發(fā)變得更簡單。如果使用Web Service，你需要自己去實現(xiàn)C/S兩端的序列化與反序列化操作，還需要自行處理異常，降低了開發(fā)效率。而thrift則會自動生成兩端的操作類，你只需要處理方法內(nèi)部的邏輯即可。

1.3 js直接與thrift server通信，可以提高性能，并且用C#開發(fā)server，開發(fā)效率也非常高。（那些web service弱爆了）

1.4 當然，我們不能只看到優(yōu)點。用這種方法也有比較明顯的缺點：如果使用web service，則網(wǎng)頁與web service可以封裝在一個工程里，部署到IIS上后，可以存在于一個網(wǎng)站內(nèi)。而使用了thrift后，你還需要手動管理thrift程序。包括：

1.4.1 你需要擁有服務(wù)端的絕對控制權(quán)，比如，你可以直接登錄服務(wù)器的操作系統(tǒng)上進行操作。因此，如果你只有一個網(wǎng)頁空間，則不適合這種方法。當然，你也可以用web service里綁定thrift，但這樣你又需要自己手動進行序列化與反序列操作，而且兩次轉(zhuǎn)換讓性能更低，有違初衷

1.4.2 給thrift server程序增加自動啟動，與監(jiān)視程序，來完成thrift的崩潰后自動重啟。

2.環(huán)境

Win7 - VS2012 - .net 4.0 C# 控制臺工程（用來承載thrift）

Win7 - VS2012 - .net 4.0 C# Web工程（用來調(diào)試js，超方便）

3.步驟（以下步驟，對于小白來說，有些困難。QQ討論群：23152359 ）

3.1 去thrift官方下載thrift庫，目前是0.9.0。

3.2 去thrift官方下載編譯好的win下的thrift編譯器，是一個exe文件。

3.3 寫一個數(shù)據(jù)結(jié)構(gòu)定義文件。我在這里只是用了服務(wù)，沒有定義自定義數(shù)據(jù)結(jié)構(gòu)。

data.txt：

復(fù)制代碼代碼如下:

 service UserStorage
 {
     i32 Sum( 1: i32 arg_number1, 2: i32 arg_number2),
     string GetString()
 }

3.4 命令行下，用thrift編譯器，對它進行編譯：
run.bat：

復(fù)制代碼代碼如下:

 thrift-0.9.0.exe --gen csharp data.txt
 thrift-0.9.0.exe --gen js data.txt
 pause

3.5 建立一個名字為CSharpServer的C#控制臺工程，.net 4.0的。

3.6 為這個工程，添加現(xiàn)有項目：thrift庫目錄\thrift-0.9.0\lib\csharp\src\Thrift.csproj，然后引用這個項目。

3.7 把thrift編譯出來的UserStorage.cs（在gen-csharp目錄里），拖動到解決方案管理器里的CSharpServer項目的根目錄下，UserStorage.cs與Program.cs應(yīng)該在同一級。

3.8 在CSharpServer項目里創(chuàng)建一個UserStorage的處理類UserStorageHandle.cs：（它應(yīng)該與UserStorage.cs與Program.cs在同一級）

復(fù)制代碼代碼如下:

using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;

 namespace CSharpServer
 {
     public class UserStorageHandle : UserStorage.Iface
     {

         public UserStorageHandle()
         {

         }

         public int Sum(int arg_number1, int arg_number2)
         {
             int result = arg_number1 + arg_number2;
             Console.WriteLine(DateTime.Now.ToString() + " 收到請求：Sum，參數(shù)：arg_number1 = " + arg_number1.ToString() + "，arg_number2 = " + arg_number2.ToString() + "，返回：result = " + result.ToString());
             return result;
         }

         private static int Counter = 0;

         public string GetString()
         {
             int currentCounter = System.Threading.Interlocked.Increment(ref UserStorageHandle.Counter);
             Console.WriteLine(DateTime.Now.ToString() + " 收到請求：GetString，參數(shù)：沒有，返回：result = \"thrift is OK : " + currentCounter.ToString() + "\"");
             return "thrift is OK : " + currentCounter.ToString();
         }

     }
 }

3.9 主程序Program.cs：

復(fù)制代碼代碼如下:

using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using Thrift.Transport;
 using Thrift.Protocol;
 using Thrift.Server;
 using System.Net;

 namespace CSharpServer
 {
     class Program
     {
         private static HttpListener httpListener = null;
         private static THttpHandler httpServer = null;

         static void Main(string[] args)
         {
             string serviceUrl = "http://localhost:99/";
             try
             {
                 UserStorageHandle handle = new UserStorageHandle();
                 UserStorage.Processor processor = new UserStorage.Processor(handle);
                 TProtocolFactory protocolFactory = new TJSONProtocol.Factory();

                 Program.httpServer = new THttpHandler(processor, protocolFactory);

                 Program.httpListener = new HttpListener();
                 Program.httpListener.Prefixes.Add(serviceUrl);
                 Program.httpListener.Start();
                 IAsyncResult result = Program.httpListener.BeginGetContext(new AsyncCallback(WebRequestCallback), null);
                 Console.WriteLine("Thrift 服務(wù)成功啟動，網(wǎng)址是 " + serviceUrl);
             }
             catch (System.Exception ex)
             {
                 Console.WriteLine("發(fā)生錯誤：" + ex.Message);
                 Console.WriteLine("按回車鍵退出");
                 Console.ReadLine();
                 return;
             }
             Console.WriteLine("若需結(jié)束程序，請直接關(guān)閉窗口，或按回車。");
             Console.ReadLine();
         }

         public static void WebRequestCallback(IAsyncResult result)
         {
             if (Program.httpListener == null)
             {
                 Console.WriteLine("發(fā)生錯誤：HttpListener已經(jīng)被關(guān)閉");
                 Console.WriteLine("按回車鍵退出");
                 Console.ReadLine();
                 return;
             }

             HttpListenerContext httpListenerContext = Program.httpListener.EndGetContext(result);

             Program.httpListener.BeginGetContext(new AsyncCallback(WebRequestCallback), null);

             Program.httpServer.ProcessRequest(httpListenerContext);
         }

     }
 }

3.10 按F5，啟動CSharpServer項目。

3.11 新開一個VS2012（內(nèi)存不夠的趕快去買），建立一個叫JsProject的C# .net 4.0 Web空工程。

3.12 去jquery官網(wǎng)下載jquery-1.9.1.js（mini版也行，隨便）

3.13 把thrift編譯的js文件data_types.js與UserStorage.js，thrift庫的js庫文件（thrift庫目錄\thrift-0.9.0\lib\js\thrift.js），以及剛下載的jq文件jquery-1.9.1.js，全部拖動到解決方案資源管理器的JsProject項目的根目錄下：

data_types.js \ jquery-1.9.1.js \ thrift.js \ UserStorage.js 應(yīng)該與Web.config在同一級。

3.14 在根目錄下創(chuàng)建一個Test.html文件，Test.html 應(yīng)該與Web.config在同一級：

Test.html：

復(fù)制代碼代碼如下:

<!DOCTYPE html>
 <html xmlns="http://www.w3.org/1999/xhtml">
 <head>
 <meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>
     <title></title>
     <script type="text/javascript" src="jquery-1.9.1.js"></script>
     <script type="text/javascript" src="data_types.js"></script>
     <script type="text/javascript" src="thrift.js"></script>
     <script type="text/javascript" src="UserStorage.js"></script>

     <script>
         $(document).ready(function ()
         {
             var debugPosation = 0;
             try
             {
                 var transport = new Thrift.Transport("http://m.fzitv.net/");
                 var protocol = new Thrift.Protocol(transport);
                 var client = new UserStorageClient(protocol);

                 var result_GetString = client.GetString();
                 var result_Sum = client.Sum(255, 322);
             }
             catch (e)
             {
                 alert("出錯鳥：" + e.message);
             }
         });
     </script>
 </head>
 <body>
 </body>
 </html>