最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

使用C#來(lái)編寫(xiě)一個(gè)異步的Socket服務(wù)器

 更新時(shí)間:2015年07月12日 15:01:17   投稿:goldensun  
這篇文章主要介紹了使用C#來(lái)編寫(xiě)一個(gè)異步的Socket服務(wù)器,通過(guò)無(wú)阻塞機(jī)制來(lái)獲取更高的處理效率,需要的朋友可以參考下

介紹

我最近需要為一個(gè).net項(xiàng)目準(zhǔn)備一個(gè)內(nèi)部線程通信機(jī)制. 項(xiàng)目有多個(gè)使用ASP.NET,Windows 表單和控制臺(tái)應(yīng)用程序的服務(wù)器和客戶端構(gòu)成. 考慮到實(shí)現(xiàn)的可能性,我下定決心要使用原生的socket,而不是許多.NET中已經(jīng)提前為我們構(gòu)建好的組件, 像是所謂的管道, NetTcpClient 還有 Azure 服務(wù)總線.

這篇文章中的服務(wù)器基于System.Net.Sockets類異步方法. 這些允許你支持大量的socket客戶端, 而一個(gè)客戶端的連接是唯一的阻塞機(jī)制. 阻塞的時(shí)間是可以忽略不記得,所以服務(wù)器基本上是在當(dāng)做一個(gè)多線程socket服務(wù)器在運(yùn)作的.

背景

原生的socket在為你提供通信層面的完全控制權(quán)上具有優(yōu)勢(shì), 而在處理不同的數(shù)據(jù)類型是具有很大的靈活性. 你甚至可以通過(guò)socket發(fā)送序列化了的CLR對(duì)象,盡管我在這里不會(huì)那樣做. 這個(gè)項(xiàng)目將會(huì)想你展示如何在socket之間發(fā)送文本.
代碼的運(yùn)用

使用下面的代碼,你初始化了一個(gè)Server類,并運(yùn)行了Start()方法:
 

Server myServer = new Server();
myServer.Start();

如果你計(jì)劃在一個(gè)Windows表單中管理服務(wù)器的話,我建議使用一個(gè)BackgroundWorker, 因?yàn)閟ocket方法(一般會(huì)是ManualResentEvent) 將會(huì)阻塞GUI線程的運(yùn)行.

Server 類:
 

using System.Net.Sockets;
 
public class Server
{
  private static Socket listener;
  public static ManualResetEvent allDone = new ManualResetEvent(false);
  public const int _bufferSize = 1024;
  public const int _port = 50000;
  public static bool _isRunning = true;
 
  class StateObject
  {
    public Socket workSocket = null;
    public byte[] buffer = new byte[bufferSize];
    public StringBuilder sb = new StringBuilder();
  }
 
  // Returns the string between str1 and str2
  static string Between(string str, string str1, string str2)
  {
    int i1 = 0, i2 = 0;
    string rtn = "";
 
    i1 = str.IndexOf(str1, StringComparison.InvariantCultureIgnoreCase);
    if (i1 > -1)
    {
      i2 = str.IndexOf(str2, i1 + 1, StringComparison.InvariantCultureIgnoreCase);
      if (i2 > -1)
      {
        rtn = str.Substring(i1 + str1.Length, i2 - i1 - str1.Length);
      }
    }
    return rtn;
  }
 
  // Checks if the socket is connected
  static bool IsSocketConnected(Socket s)
  {
    return !((s.Poll(1000, SelectMode.SelectRead) && (s.Available == 0)) || !s.Connected);
  }
 
  // Insert all the other methods here.
}


ManualResetEvent 是一個(gè)實(shí)現(xiàn)了你的socket服務(wù)器中事件的.NET類. 我們需要這個(gè)項(xiàng)目在我們想要發(fā)布阻塞操作的時(shí)候向代碼發(fā)送信號(hào). 你可以試驗(yàn)一下用bufferSize來(lái)適配你的需求. 如果能預(yù)期到消息的大小, 使用byte單位來(lái)設(shè)置消息的大小參數(shù)bufferSize. port是偵聽(tīng)TCP的端口參數(shù). 要意識(shí)到為其它應(yīng)用程序伺服所使用的接口. 如果你想要能夠方便地停止服務(wù)器,你需要實(shí)現(xiàn)一些機(jī)制來(lái)將_isRunning設(shè)置成false. 這一般可以借助于使用一個(gè) BackgroundWorker做到, 其中你可以使用myWorker.CancellationPending替換_isRunning. 我提到_isRunning的原因是給你在處理取消操作的問(wèn)題上提供一個(gè)方向, 并向你展示偵聽(tīng)器可以方便的停止的.

Between() 和IsSocketConnected() 是輔助方法.


現(xiàn)在轉(zhuǎn)過(guò)來(lái)看看方法. 首先是Start()方法:
 

public void Start()
{
  IPHostEntry ipHostInfo = Dns.GetHostEntry(Dns.GetHostName());
  IPEndPoint localEP = new IPEndPoint(IPAddress.Any, _port);
  listener = new Socket(localEP.Address.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
  listener.Bind(localEP);
 
  while (_IsRunning)
  {
    allDone.Reset();
    listener.Listen(10);
    listener.BeginAccept(new AsyncCallback(acceptCallback), listener);
    bool isRequest = allDone.WaitOne(new TimeSpan(12, 0, 0)); // Blocks for 12 hours
 
    if (!isRequest)
    {
      allDone.Set();
      // Do some work here every 12 hours
    }
  }
  listener.Close();
}

這個(gè)方法初始化了偵聽(tīng)器socket, 并開(kāi)始等待用戶連接的到來(lái). 項(xiàng)目中主要的模式是使用異步委派. 異步委派是在調(diào)用者中的狀態(tài)改變時(shí)被異步調(diào)用的方法. isRequest 告訴你WaitOne 是否已經(jīng)因?yàn)橛锌蛻舳诉B接或者超時(shí)而退出.

如果你有大量的客戶端連接同時(shí)發(fā)生, 考慮提高Listen()方法的隊(duì)列參數(shù).


現(xiàn)在來(lái)看看下一個(gè)方法, acceptCallback . 這個(gè)方法由listener.BeginAccept異步調(diào)用. 當(dāng)方法完成執(zhí)行時(shí),偵聽(tīng)器會(huì)立即偵聽(tīng)新的客戶端.
 

static void acceptCallback(IAsyncResult ar)
{
  // Get the listener that handles the client request.
  Socket listener = (Socket)ar.AsyncState;
 
  if (listener != null)
  {
    Socket handler = listener.EndAccept(ar);
 
    // Signal main thread to continue
    allDone.Set();
 
    // Create state
    StateObject state = new StateObject();
    state.workSocket = handler;
    handler.BeginReceive(state.buffer, 0, _bufferSize, 0, new AsyncCallback(readCallback), state);
  }
}

acceptCallback 會(huì)派生出另外一個(gè)異步指派: readCallback. 這個(gè)方法會(huì)讀取來(lái)自socket的實(shí)際數(shù)據(jù). 我已經(jīng)為收發(fā)數(shù)據(jù)作了我自己的控制, 對(duì)于_bufferSize來(lái)說(shuō)是不變的. 所有發(fā)送到服務(wù)器的字符串都必須用<!--SOCKET--> 和 <!--ENDSOCKET-->包起來(lái). 同樣,客戶端在收到服務(wù)器的響應(yīng)式,必須解除響應(yīng)信息的包裹, 后者被<!--RESPONSE--> 和 <!--ENDRESPONSE-->包了起來(lái)。
 

static void readCallback(IAsyncResult ar)
{
  StateObject state = (StateObject)ar.AsyncState;
  Socket handler = state.workSocket;
 
  if (!IsSocketConnected(handler)) 
  {
    handler.Close();
    return;
  }
 
  int read = handler.EndReceive(ar);
 
  // Data was read from the client socket.
  if (read > 0)
  {
    state.sb.Append(Encoding.UTF8.GetString(state.buffer, 0, read));
 
    if (state.sb.ToString().Contains("<!--ENDSOCKET-->"))
    {
      string toSend = "";
      string cmd = ts.Strings.Between(state.sb.ToString(), "<!--SOCKET-->", "<!--ENDSOCKET-->");
           
      switch (cmd)
      {
        case "Hi!":
          toSend = "How are you?";
          break;
        case "Milky Way?":
          toSend = "No I am not.";
          break;
      }
 
      toSend = "<!--RESPONSE-->" + toSend + "<!--ENDRESPONSE-->";
 
      byte[] bytesToSend = Encoding.UTF8.GetBytes(toSend);
      handler.BeginSend(bytesToSend, 0, bytesToSend.Length, SocketFlags.None
        , new AsyncCallback(sendCallback), state);
    }
    else 
    {
      handler.BeginReceive(state.buffer, 0, _bufferSize, 0
          , new AsyncCallback(readCallback), state);
    }
  }
  else
  {
      handler.Close();
  }
}

readCallback 會(huì)派生另外一個(gè)方法, sendCallback, 它將會(huì)向客戶端發(fā)送請(qǐng)求. 如果客戶端沒(méi)有關(guān)閉連接, sendCallback 將會(huì)向socket發(fā)送信號(hào)以獲得更多的數(shù)據(jù).
 

static void sendCallback(IAsyncResult ar)
{
  StateObject state = (StateObject)ar.AsyncState;
  Socket handler = state.workSocket;
  handler.EndSend(ar);
 
  StateObject newstate = new StateObject();
  newstate.workSocket = handler;
  handler.BeginReceive(newstate.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(readCallback), newstate);
}

我會(huì)將寫(xiě)一個(gè)socket客戶端作為聯(lián)系留給讀者. socket客戶端應(yīng)該使用同異步調(diào)用同樣的編程模式. 我希望你能從這篇文章中收獲樂(lè)趣,并且會(huì)像一個(gè)socket程序員那樣付諸實(shí)踐!

要點(diǎn)

我在生產(chǎn)環(huán)境下使用了此代碼,其中的socket服務(wù)器是一個(gè)自由文本搜索引擎。 SQL Server缺乏對(duì)自由文本搜索支持(你可以使用自由文本索引,但它們是緩慢和昂貴的)。socket服務(wù)器負(fù)載了大量導(dǎo)向IEnumerables的文本數(shù)據(jù),并使用Linq來(lái)搜索文本。來(lái)自socket服務(wù)器的響應(yīng)從數(shù)百萬(wàn)行的Unicode文本數(shù)據(jù)中搜索時(shí)間在幾毫秒內(nèi)。我們還使用了三個(gè)分布式的Sphinx服務(wù)器(www.sphinxsearch.com)。socket服務(wù)器充當(dāng)了Sphinx服務(wù)器的高速緩存。如果你需要一個(gè)快速的自由文本搜索引擎,我強(qiáng)烈建議使用Sphinx。

相關(guān)文章

  • c#得到本月有幾周和這幾周的起止時(shí)間示例代碼

    c#得到本月有幾周和這幾周的起止時(shí)間示例代碼

    本篇文章主要是對(duì)c#得到本月有幾周和這幾周的起止時(shí)間的示例代碼進(jìn)行了介紹,需要的朋友可以過(guò)來(lái)參考下,希望對(duì)大家有所幫助
    2014-01-01
  • C#生成驗(yàn)證碼圖片的方法

    C#生成驗(yàn)證碼圖片的方法

    這篇文章主要為大家詳細(xì)介紹了C#生成驗(yàn)證碼圖片的方法,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2018-10-10
  • C#中的多態(tài)深入理解

    C#中的多態(tài)深入理解

    如果面試時(shí)主考官要求你用一句話來(lái)描述多態(tài),盡可能的精煉,你會(huì)怎么回答?當(dāng)然答案有很多,每個(gè)人的理解和表達(dá)不盡相同,但我比較趨向這樣描述:通過(guò)繼承實(shí)現(xiàn)的不同對(duì)象調(diào)用相同的方法,表現(xiàn)出不同的行為,稱之為多態(tài)
    2014-01-01
  • winform 實(shí)現(xiàn)控制輸入法

    winform 實(shí)現(xiàn)控制輸入法

    在工作中遇到這樣一個(gè)問(wèn)題,在系統(tǒng)使用過(guò)程中,輸入法會(huì)變灰導(dǎo)致無(wú)法使用輸入法輸入文字,就好像輸入法被禁用了沒(méi)有啟用似的。對(duì)此,在這里做個(gè)備錄
    2015-08-08
  • C#獲取全部目錄和文件的簡(jiǎn)單實(shí)例

    C#獲取全部目錄和文件的簡(jiǎn)單實(shí)例

    這篇文章介紹了C#獲取全部目錄和文件的簡(jiǎn)單實(shí)例,有需要的朋友可以參考一下
    2013-10-10
  • C#圖像處理之木刻效果實(shí)現(xiàn)方法

    C#圖像處理之木刻效果實(shí)現(xiàn)方法

    這篇文章主要介紹了C#圖像處理之木刻效果實(shí)現(xiàn)方法,可實(shí)現(xiàn)類似木刻效果的黑白照效果,需要的朋友可以參考下
    2015-04-04
  • C#?wpf實(shí)現(xiàn)任意控件更多調(diào)整大小功能

    C#?wpf實(shí)現(xiàn)任意控件更多調(diào)整大小功能

    這篇文章主要為大家詳細(xì)介紹了C#?wpf實(shí)現(xiàn)任意控件更多調(diào)整大小功能的相關(guān)知識(shí),文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
    2024-01-01
  • C#中String.PadRight方法的具體使用

    C#中String.PadRight方法的具體使用

    本文主要介紹了C#中String.PadRight方法的具體使用, 返回一個(gè)指定長(zhǎng)度的新字符串,其中在當(dāng)前字符串的結(jié)尾填充空格或指定的Unicode字符,下面就來(lái)詳細(xì)的了解一下
    2024-01-01
  • 不安裝excel使用c#創(chuàng)建excel文件

    不安裝excel使用c#創(chuàng)建excel文件

    這篇文章主要介紹了使用c#創(chuàng)建excel的示例,剛時(shí)給出了不安裝excel也可創(chuàng)建excel的方法,需要的朋友可以參考下
    2014-02-02
  • C#程序如何調(diào)用C++?dll詳細(xì)教程

    C#程序如何調(diào)用C++?dll詳細(xì)教程

    C#和C++形成的DLL有一層天然的屏障,并不能簡(jiǎn)單地互相調(diào)用,想要C#工程調(diào)用c++dll,需要先在其外部包裹上clr?c++的外殼,本篇文章給大家分享了C#調(diào)用C++?dll的詳細(xì)步驟和方法,有興趣的朋友可以參考學(xué)習(xí)下
    2018-07-07

最新評(píng)論

乌拉特中旗| 洛川县| 龙南县| 林甸县| 庆安县| 宁国市| 巫山县| 鄂托克旗| 东兴市| 中西区| 芒康县| 重庆市| 龙井市| 新兴县| 汉中市| 诸暨市| 平安县| 德安县| 云阳县| 宝鸡市| 托里县| 黄冈市| 永城市| 双牌县| 长宁县| 平乐县| 北宁市| 南木林县| 沙湾县| 泸溪县| 页游| 泸定县| 台中县| 兰西县| 双流县| 东丰县| 桂东县| 筠连县| 南华县| 鸡泽县| 克东县|