C# Socket實現(xiàn)控制臺的案例

這篇文章將為大家詳細講解有關(guān)C# Socket實現(xiàn)控制臺的案例，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

一、服務(wù)器端

1. 實例化并設(shè)置socket實例對象

a.創(chuàng)建ip地址和端口

b.綁定監(jiān)聽地址

c.設(shè)置一下允許同時訪問數(shù)

2. 監(jiān)聽連接

a.通過啟動一個新的線程執(zhí)行，這樣主線程不會假死(啟動線程，所帶的參數(shù)必須是object類型)

b.利用循環(huán)等待連接并返回一個負責通信的socket實例

c.返回的socket實例中可以獲取到所連接客服的IP地址

3. 接收客服的發(fā)送過來的消息

a.在監(jiān)聽方法中啟動一個新的線程執(zhí)行

b.利用循環(huán)獲取發(fā)送過來的消息，調(diào)用獲取消息的方法需要傳遞一個字節(jié)變量參數(shù)，作為容器。方法返回值為int，表示獲取到的有效字節(jié)數(shù)

c.如果有效字節(jié)數(shù)為0則跳出循環(huán)

d.接收到消息給客服的返回消息

4. 控制臺程序服務(wù)器端代碼

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;

namespace ServerSocket
{
 class Program
 {
  static void Main(string[] args)
  {
   Console.WriteLine("Hello World!");
   Socket serverSocket = new Socket(SocketType.Stream, ProtocolType.Tcp);
   IPAddress ip = IPAddress.Any;
   IPEndPoint point = new IPEndPoint(ip, 2333);
   //socket綁定監(jiān)聽地址
   serverSocket.Bind(point);
   Console.WriteLine("Listen Success");
   //設(shè)置同時連接個數(shù)
   serverSocket.Listen(10);

   //利用線程后臺執(zhí)行監(jiān)聽,否則程序會假死
   Thread thread = new Thread(Listen);
   thread.IsBackground = true;
   thread.Start(serverSocket);

   Console.Read();
  }

  /// <summary>
  /// 監(jiān)聽連接
  /// </summary>
  /// <param name="o"></param>
  static void Listen(object o)
  {
   var serverSocket = o as Socket;
   while (true)
   {
    //等待連接并且創(chuàng)建一個負責通訊的socket
    var send = serverSocket.Accept();
    //獲取鏈接的IP地址
    var sendIpoint = send.RemoteEndPoint.ToString();
    Console.WriteLine($"{sendIpoint}Connection");
    //開啟一個新線程不停接收消息
    Thread thread = new Thread(Recive);
    thread.IsBackground = true;
    thread.Start(send);
   }
  }

  /// <summary>
  /// 接收消息
  /// </summary>
  /// <param name="o"></param>
  static void Recive(object o)
  {
   var send = o as Socket;
   while (true)
   {
    //獲取發(fā)送過來的消息容器
    byte[] buffer = new byte[1024 * 1024 * 2];
    var effective = send.Receive(buffer);
    //有效字節(jié)為0則跳過
    if (effective == 0)
    {
     break;
    }
    var str = Encoding.UTF8.GetString(buffer,0, effective);
    Console.WriteLine(str);
　　　　　　　　　　 var buffers = Encoding.UTF8.GetBytes("Server Return Message");
　　　　　　　　　　 send.Send(buffers);

   }
  }
 }
}

二、客戶端

1. 實例化并進行連接socket實例對象

a.創(chuàng)建ip地址和端口(服務(wù)器的IP和端口)

b.與服務(wù)器端建立鏈接

2. 接收服務(wù)器發(fā)送的消息

a.啟動一個新的線程執(zhí)行

b.利用循環(huán)獲取發(fā)送過來的消息，調(diào)用獲取消息的方法需要傳遞一個字節(jié)變量參數(shù)，作為容器。方法返回值為int，表示獲取到的有效字節(jié)數(shù)

c.如果有效字節(jié)數(shù)為0則跳出循環(huán)

3. 給服務(wù)器發(fā)送消息

a. 調(diào)用socket對象的send()方法直接發(fā)送

4. 控制臺程序客戶端代碼

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;

namespace SocketClient
{
 class Program
 {
  static void Main(string[] args)
  {
   Console.WriteLine("Hello World!");
   //創(chuàng)建實例
   Socket socketClient = new Socket(SocketType.Stream, ProtocolType.Tcp);
   IPAddress ip = IPAddress.Parse("192.168.0.111");
   IPEndPoint point = new IPEndPoint(ip, 2333);
   //進行連接
   socketClient.Connect(point);
   
   //不停的接收服務(wù)器端發(fā)送的消息
   Thread thread = new Thread(Recive);
   thread.IsBackground = true;
   thread.Start(socketClient);

   //不停的給服務(wù)器發(fā)送數(shù)據(jù)
   int i = 0;
   while (true)
   {
    i++;
    var buffter = Encoding.UTF8.GetBytes($"Test Send Message:{i}");
    var temp = socketClient.Send(buffter);
    Thread.Sleep(1000);
   }
   
  }


  /// <summary>
  /// 接收消息
  /// </summary>
  /// <param name="o"></param>
  static void Recive(object o)
  {
   var send = o as Socket;
   while (true)
   {
    //獲取發(fā)送過來的消息
    byte[] buffer = new byte[1024 * 1024 * 2];
    var effective = send.Receive(buffer);
    if (effective == 0)
    {
     break;
    }
    var str = Encoding.UTF8.GetString(buffer, 0, effective);
    Console.WriteLine(str);
   }
  }
 }
}

關(guān)于C# Socket實現(xiàn)控制臺的案例就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。