1   ///<summary>
  2   /// 非同步TCP伺服器
  3   ///</summary>
  4   public class AsyncTcpServer : IDisposable
  5   {
  6     #region Fields
  7 
  8     private TcpListener listener;
  9     private List<TcpClientState> clients;
 10     private bool disposed = false;
 11 
 12     #endregion
 13
 
 
 14     #region Ctors
 15 
 16     ///<summary>
 17     /// 非同步TCP伺服器
 18     ///</summary>
 19     ///<param name="listenPort">監聽的埠</param>
 20     public AsyncTcpServer(int listenPort)
 21       : this(IPAddress.Any, listenPort)
 22     {
 23     }
 24 
 25     ///<summary>
 26     /// 非同步TCP伺服器
 

 27     ///</summary>
 28     ///<param name="localEP">監聽的終結點</param>
 29     public AsyncTcpServer(IPEndPoint localEP)
 30       : this(localEP.Address, localEP.Port)
 31     {
 32     }
 33 
 34     ///<summary>
 35     /// 非同步TCP伺服器
 36     ///</summary>
 37     ///<param name="localIPAddress">
 
監聽的IP地址</param>
 38     ///<param name="listenPort">監聽的埠</param>
 39     public AsyncTcpServer(IPAddress localIPAddress, int listenPort)
 40     {
 41       Address = localIPAddress;
 42       Port = listenPort;
 43       this.Encoding = Encoding.Default;
 44 
 45       clients = new List<TcpClientState>();
 46 
 47       listener = new TcpListener(Address, Port);
 48       listener.AllowNatTraversal(true);
 49     }
 50 
 51     #endregion
 52 
 53     #region Properties
 54 
 55     ///<summary>
 56     /// 伺服器是否正在執行
 57     ///</summary>
 58     public bool IsRunning { get; private set; }
 59     ///<summary>
 60     /// 監聽的IP地址
 61     ///</summary>
 62     public IPAddress Address { get; private set; }
 63     ///<summary>
 64     /// 監聽的埠
 65     ///</summary>
 66     public int Port { get; private set; }
 67     ///<summary>
 68     /// 通訊使用的編碼
 69     ///</summary>
 70     public Encoding Encoding { get; set; }
 71 
 72     #endregion
 73 
 74     #region Server
 75 
 76     ///<summary>
 77     /// 啟動伺服器
 78     ///</summary>
 79     ///<returns>非同步TCP伺服器</returns>
 80     public AsyncTcpServer Start()
 81     {
 82       if (!IsRunning)
 83       {
 84         IsRunning = true;
 85         listener.Start();
 86         listener.BeginAcceptTcpClient(
 87           new AsyncCallback(HandleTcpClientAccepted), listener);
 88       }
 89       return this;
 90     }
 91 
 92     ///<summary>
 93     /// 啟動伺服器
 94     ///</summary>
 95     ///<param name="backlog">
 96     /// 伺服器所允許的掛起連線序列的最大長度
 97     ///</param>
 98     ///<returns>非同步TCP伺服器</returns>
 99     public AsyncTcpServer Start(int backlog)
100     {
101       if (!IsRunning)
102       {
103         IsRunning = true;
104         listener.Start(backlog);
105         listener.BeginAcceptTcpClient(
106           new AsyncCallback(HandleTcpClientAccepted), listener);
107       }
108       return this;
109     }
110 
111     ///<summary>
112     /// 停止伺服器
113     ///</summary>
114     ///<returns>非同步TCP伺服器</returns>
115     public AsyncTcpServer Stop()
116     {
117       if (IsRunning)
118       {
119         IsRunning = false;
120         listener.Stop();
121 
122         lock (this.clients)
123         {
124           for (int i = 0; i < this.clients.Count; i++)
125           {
126             this.clients[i].TcpClient.Client.Disconnect(false);
127           }
128           this.clients.Clear();
129         }
130 
131       }
132       return this;
133     }
134 
135     #endregion
136 
137     #region Receive
138 
139     private void HandleTcpClientAccepted(IAsyncResult ar)
140     {
141       if (IsRunning)
142       {
143         TcpListener tcpListener = (TcpListener)ar.AsyncState;
144 
145         TcpClient tcpClient = tcpListener.EndAcceptTcpClient(ar);
146         byte[] buffer = new byte[tcpClient.ReceiveBufferSize];
147 
148         TcpClientState internalClient 
149           = new TcpClientState(tcpClient, buffer);
150         lock (this.clients)
151         {
152           this.clients.Add(internalClient);
153           RaiseClientConnected(tcpClient);
154         }
155 
156         NetworkStream networkStream = internalClient.NetworkStream;
157         networkStream.BeginRead(
158           internalClient.Buffer, 
159           0, 
160           internalClient.Buffer.Length, 
161           HandleDatagramReceived, 
162           internalClient);
163 
164         tcpListener.BeginAcceptTcpClient(
165           new AsyncCallback(HandleTcpClientAccepted), ar.AsyncState);
166       }
167     }
168 
169     private void HandleDatagramReceived(IAsyncResult ar)
170     {
171       if (IsRunning)
172       {
173         TcpClientState internalClient = (TcpClientState)ar.AsyncState;
174         NetworkStream networkStream = internalClient.NetworkStream;
175 
176         int numberOfReadBytes = 0;
177         try
178         {
179           numberOfReadBytes = networkStream.EndRead(ar);
180         }
181         catch
182         {
183           numberOfReadBytes = 0;
184         }
185 
186         if (numberOfReadBytes == 0)
187         {
188           // connection has been closed
189           lock (this.clients)
190           {
191             this.clients.Remove(internalClient);
192             RaiseClientDisconnected(internalClient.TcpClient);
193             return;
194           }
195         }
196 
197         // received byte and trigger event notification
198         byte[] receivedBytes = new byte[numberOfReadBytes];
199         Buffer.BlockCopy(
200           internalClient.Buffer, 0, 
201           receivedBytes, 0, numberOfReadBytes);
202         RaiseDatagramReceived(internalClient.TcpClient, receivedBytes);
203         RaisePlaintextReceived(internalClient.TcpClient, receivedBytes);
204 
205         // continue listening for tcp datagram packets
206         networkStream.BeginRead(
207           internalClient.Buffer, 
208           0, 
209           internalClient.Buffer.Length, 
210           HandleDatagramReceived, 
211           internalClient);
212       }
213     }
214 
215     #endregion
216 
217     #region Events
218 
219     ///<summary>
220     /// 接收到資料報文事件
221     ///</summary>
222     public event EventHandler<TcpDatagramReceivedEventArgs<byte[]>> DatagramReceived;
223     ///<summary>
224     /// 接收到資料報文明文事件
225     ///</summary>
226     public event EventHandler<TcpDatagramReceivedEventArgs<string>> PlaintextReceived;
227 
228     private void RaiseDatagramReceived(TcpClient sender, byte[] datagram)
229     {
230       if (DatagramReceived != null)
231       {
232         DatagramReceived(this, new TcpDatagramReceivedEventArgs<byte[]>(sender, datagram));
233       }
234     }
235 
236     private void RaisePlaintextReceived(TcpClient sender, byte[] datagram)
237     {
238       if (PlaintextReceived != null)
239       {
240         PlaintextReceived(this, new TcpDatagramReceivedEventArgs<string>(
241           sender, this.Encoding.GetString(datagram, 0, datagram.Length)));
242       }
243     }
244 
245     ///<summary>
246      
 

            
  
           

              
              
            
            
相關推薦
			   
            
            
            
 

    

    
    
C#非同步TCP伺服器完整實現
     
 
  1   ///<summary>
  2   /// 非同步TCP伺服器
  3   ///</summary>
  4   public class AsyncTcpServer : IDisposable
  5   {
  6     #region Fields
  7  

  
 

    

    
    
C#網路程式設計系列文章(一)之Socket實現非同步TCP伺服器
     
 
                
原創性宣告


文章系列目錄









程式碼下載地址

開篇
本人因為對於網路程式設計的喜愛，經常性的使用c#編寫各類伺服器(e.g TCP伺服器，UDP伺服器)，但是基本上都是搞著玩，網上也有很多講c#網路程式設計的文章，當然我也參考了很多作者寫的文章。看了這篇 

  
 

    

    
    
C#網路程式設計系列文章(三)之TcpListener實現非同步TCP伺服器
     
 using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.Net;
namespace NetFrame.Net.TC 

  
 

    

    
    
c++ string類的完整實現！！！
     
 class   sun   double   ref   basic   更新   方便   iterator   locate   

本文實現了c++ STL中的basic_string模板類，當然。通過typedef也就實現了string類和wstring類。限於篇幅，實現代碼中用到了標準庫的char_ 

  
 

    

    
    
C#非同步TCP程式設計
     
  
 
 一、基本知識 
 1、利用TcpListener類和TcpClient類在同步方式下接收、傳送資料以及監聽客戶端連線時，在操作沒有完成之前一直處於阻塞狀態。 
 2、非同步設計模式：非同步操作一般工作在一個單獨的執行緒中執行，呼叫非同步方法非同步執行某個操作時，可以同時繼續執行該非同步方法的後面的程 

  
 

    

    
    
【網路】TCP伺服器的實現
     
 
								
								            
						
                
socket程式設計基本概念
在TCP/IP協議中，IP地址+埠號標識個唯一的一個程序，“IP地址+埠號”就是socket
在TCP協議中，建立連線需要兩個程序各自有一個socket識別符號，這兩個s 

  
 

    

    
    
Linux 下c語言ftp伺服器簡單實現
     
 
                
     這個程式轉載自http://aijiekj.blog.163.com/blog/static/12986678920112321853230/
原來的程式沒有註釋，最近這段時間在學習網路程式設計這塊，就在網上找了個程式來學習，第一次找的程式下載下來後，編譯沒通過， 

  
 

    

    
    
【Python】使用socketserver建立一個非同步TCP伺服器
     
 
								
								            
						
                
概述
這篇文章是講解如何使用socketserver建立一個非同步TCP伺服器，其中Python版本為3.5.1。

socketserver主要的類
socketserver模組中的類主要有以下幾個 

  
 

    

    
    
[C++][執行緒池][完整實現]  轉：執行緒池原理及建立（C++實現）
     
 
                
文章的主要框架是參考這篇文件的，http://jacky-dai.iteye.com/blog/1090285,
關於作者 
張中慶，西安交通大學軟體所，在讀碩士，目前研究方向為分散式網路與移動中介軟體，對Linux極其愛好，可以通過[email protecte 

  
 

    

    
    
三、ESP8266LUA開發之建立TCP伺服器，實現socket通訊控制繼電器，串列埠，伺服器，客戶端收發資料小感悟
     
 
							
							
							8266做伺服器，實現TCP通訊


  注，實際燒錄的時候會因為註釋過多造成燒錄不進去的情況，這個時候需要刪除註釋！




先來測試8266建立伺服器，並分得IP


  燒錄時，先燒wifi.lua，然後再燒init.lua。


init.lua



 

  
 

    

    
    
非同步Socket Tcp伺服器實現（C#）
     
 /// <summary>
    /// 非同步SOCKET 伺服器
    /// </summary>
    public class AsyncServer : IDisposable
    {

        #region Fields
        /// < 

  
 

    

    
    
**c++基於tcp協議的socket程式設計實現一個簡單伺服器**
     
  
  
  
 c++基於tcp協議的socket程式設計實現一個簡單伺服器 基於tcp的通訊，可以利益socket套接字實現。通訊，顧名思義需要伺服器和客戶端兩者進行資訊互動。  通過流程圖我們可以看到程式設計實現伺服器和客戶端的步驟大致相同，而伺服器則更為複雜一些。本文之給出了一個簡單的伺服器程式設計和 

  
 

    

    
    
C#網路程式設計系列文章(二)之Socket實現同步TCP伺服器
     
 
                
原創性宣告
本文作者:小竹zz  本文地址http://blog.csdn.net/zhujunxxxxx/article/details/44258719 轉載請註明出處


文章系列目錄









本文介紹
在上一篇部落格中我說了，我將會介紹c#中使用Socke 

  
 

    

    
    
C#網路程式設計系列文章(五)之Socket實現非同步UDP伺服器
     
 
                
原創性宣告
本文作者：小竹zz 本文地址http://blog.csdn.net/zhujunxxxxx/article/details/44258719 轉載請註明出處


文章系列目錄









本文介紹
在.Net中，System.Net.Sockets 名稱 

  
 

    

    
    
一種基於Qt的可伸縮的全非同步C/S架構伺服器實現（五) 單層無中心叢集
     
 
                
五、單層無中心叢集
對40萬用戶規模以內的伺服器，使用星形的無中心連線是較為簡便的實現方式。分佈在各個物理伺服器上的服務程序共同工作，每個程序承擔若干連線。為了實現這個功能，需要解決幾個關鍵問題。
5.1、跨伺服器傳輸通道
        設計在高速區域網中的連線可直接採用 

  
 

    

    
    
（轉）基於C#的socket編程的TCP異步實現
     
 ont   .text   相關   llb   對象創建   length   ethos   dex   eof   一、摘要
　　本篇博文闡述基於TCP通信協議的異步實現。
二、實驗平臺
　　Visual Studio 2010
 
三、異步通信實現原理及常用方法
3.1 建立連接　
　　在同步模式中， 

  
 

    

    
    
C#--TCP例項（實現了client）
     
  
  
  
  
  如果你耐得住寂寞，這個聊天軟體你可以玩一年 
  
 這是客戶端的程式碼： 
 using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Thr 

  
 

    

    
    
TCP 伺服器/客戶端(實現下載)
     
  
 
 
 TCP/IP :       TCP/IP:在網路通訊中，TCP/IP是主流協議()       應用層：使用者自定義的協議（HTTP,EMAIL,）,用於使用者之間資料的傳送      &nbs 

  
 

    

    
    
go實現高效tcp伺服器（適合短連線）類似fasthttp，長連線的每個連線分配一個協程(標準庫中的http)
     
  

  package main
 
 
 import (
 
  "fmt"
 
  "net"
 
  "os"
 
  "time"
 )
 
 
 const (
 
  MAX_CONN_NUM = 10
 )
 
 
 
 //服務處理函式，如果處理過程過於複雜，可以啟動一定量的協程來做（協程 

  
 

    

    
    
Visual C++網路程式設計經典案例詳解 第2章 Winsock網路程式開發流程 TCP伺服器程式 介面初始化
     
 
                與TCP客戶端一樣
伺服器程式啟動時需要介面初始化
不管伺服器在初始化時
還應該同時完成套接字的建立以及地址繫結等處理工作

class CTCPDlg : public CDialog
{
// Construction
public:
    CTCPDlg(CWnd*