12篇學通C#網絡編程——第四篇 TCP應用編程

    年底了，人浮躁多了，沉不下去心研究技術了，不過昨天終於搶到了回家的票，很開心。

    言歸正卷，在WCF出來之后，可能我們玩這些原始的TCP越來越少了，我們知道WCF對TCP進行了再一次的包裝，第一反應給我們的或許是

同構系統用TCP，異構系統用HTTP，那么問題來了，異構系統到底可不可以用TCP呢？至少WCF是玩不了的，因為其他語言沒有針對.net的“服務

引用”，也沒有什么ChannelFactory給你去玩，如果你是一定要追求性能的話，原始的TCP會助你一臂之力的。

   我們知道最最原始的是玩Socket，由於Socket比較復雜，但是最靈活，C#里面提供了兩個簡化的包裝類：TcpListener和TcpClient。

一：TcpListener

   這個是作為服務器端程序而存在的，我們來看看如何使用這服務端。

1: 開啟監聽地址

TcpListener listener = new TcpListener(new System.Net.IPAddress(new byte[] { 127, 0, 0, 1 }), 2222);

listener.Start();

 

2：好了，已經開啟了，服務端程序開始監聽該端口的客戶端請求了，那么如何獲取該請求呢？簡單，listener的AcceptTcpClient屬性搞定。

var myclient = listener.AcceptTcpClient();

 3：我們知道TCP傳的是字節流，通過myclient.GetStream()就可以獲取一個NetworkStream，利用這個Stream就可以進行收發信息了。

 <1> 收操作：

BinaryReader sr = new BinaryReader(client.GetStream());

 //客戶端數據
 var data = sr.ReadString();

<2>發操作：也就是所謂的返回值

//處理完了之后要返回數據給客戶端
BinaryWriter sw = new BinaryWriter(client.GetStream());

sw.Write(string.Format("當前時間:{0},服務端已經處理完畢！", DateTime.Now));

 

　　這里要注意的地方就是AcceptTcpClient是阻塞線程的，直到收到客戶端請求才算建立了一個TCP連接，在服務端處理的過程中，后續的客戶端的請求將

會處理等待直到前一個請求處理完，說了這么多，就是每一個請求我們都建議開一個線程專門為其服務，類似這樣。

//接受客戶端的連接請求
var myclient = listener.AcceptTcpClient();

//用工作線程執行用戶的請求
Task.Factory.StartNew((obj) =>
{
    var client = obj as TcpClient;

    client.Close();

}, myclient);

好了，服務器端大概就是這個樣子，再有的就是一些相關屬性配置了，像wcf那樣什么opentime,sendtime啥的。

 

二：TcpClient

     客戶端也很簡單，只要我們Connect一下端口，然后通過NetworkStream再Send一些數據就OK了。

TcpClient client = new TcpClient();

client.Connect(new System.Net.IPAddress(new byte[] { 127, 0, 0, 1 }), 2222);

BinaryWriter bw = new BinaryWriter(client.GetStream());

bw.Write(string.Format("你好，我來請求你！ {0},當前線程:{1}", j, Thread.CurrentThread.ManagedThreadId));

三：模擬

     最后我們模擬下，客戶端開啟100個線程，每個線程請求100次，服務器端對每個線程都用工作線程去處理，是不是找到了netTcpBinding的

感覺，最后一個大家都懂的道理就是線程多了不是好事情。

服務端：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.IO;
using System.Threading.Tasks;
using System.Threading;
using System.Net;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            TcpListener listener = new TcpListener(new System.Net.IPAddress(new byte[] { 127, 0, 0, 1 }), 2222);

            listener.Start();

            //用專門的線程來接受請求
            Task.Factory.StartNew(() =>
            {
                //不間斷的接受客戶端請求
                while (true)
                {
                    //接受客戶端的連接請求
                    var myclient = listener.AcceptTcpClient();

                    //用工作線程執行用戶的請求
                    Task.Factory.StartNew((obj) =>
                    {
                        var client = obj as TcpClient;

                        BinaryReader sr = new BinaryReader(client.GetStream());

                        //客戶端數據
                        var data = sr.ReadString();

                        //客戶端ip
                        var ip = (IPEndPoint)client.Client.RemoteEndPoint;

                        Console.WriteLine("當前時間:{0},接受到了來自IP:{1}:{2},的請求，發來的數據為:{3}", DateTime.Now,
                                                                                                ip.Address, ip.Port, data);

                        Thread.Sleep(1000 * 5);

                        //處理完了之后要返回數據給客戶端
                        BinaryWriter sw = new BinaryWriter(client.GetStream());

                        sw.Write(string.Format("當前時間:{0},服務端已經處理完畢！", DateTime.Now));

                        client.Close();

                    }, myclient);
                }
            });

            Console.WriteLine("服務端已經啟動...");

            Console.Read();
        }
    }
}

客戶端：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.IO;
using System.Threading;
using System.Threading.Tasks;

namespace ConsoleApplication2
{
    class Program
    {
        static void Main(string[] args)
        {
            for (int i = 0; i < 100; i++)
            {
                Task.Factory.StartNew(() =>
                {
                    for (int j = 0; j < 100; j++)
                    {
                        TcpClient client = new TcpClient();

                        client.Connect(new System.Net.IPAddress(new byte[] { 127, 0, 0, 1 }), 2222);

                        BinaryWriter bw = new BinaryWriter(client.GetStream());

                        bw.Write(string.Format("你好，我來請求你！ {0},當前線程:{1}", j, Thread.CurrentThread.ManagedThreadId));

                        BinaryReader sr = new BinaryReader(client.GetStream());

                        var s = sr.ReadString();

                        Console.WriteLine("接受到數據:{0}", s);
                    }
                });
            }

            Console.Read();
        }
    }
}