C# Socket實作簡單控制台案例

這篇文章主要為大家分享了C# Socket簡單的控制台案例，具有一定的參考價值，有興趣的小夥伴們可以參考一下

一、伺服器端

1. 實例化並設定socket實例物件

    a.建立ip位址和連接埠

#    b .綁定監聽位址

    c.設定允許同時存取數

2. 監聽連線

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

    b.利用循環等待連接並返回一個負責通信的socket實例

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

3. 接收客服的傳送過來的訊息

#    a.在監聽方法中啟動一個新的執行緒執行

    b.利用迴圈取得發送過來的訊息，呼叫取得訊息的方法需要傳遞一個位元組變數參數，作為容器。方法回傳值為int，表示取得有效的位元組數

##    c.如果有效位元組數為0則跳出迴圈

    d.接收訊息給客服的回傳訊息

4. 控制台程式伺服器端程式碼

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绑定监听地址
   serverSocket.Bind(point);
   Console.WriteLine("Listen Success");
   //设置同时连接个数
   serverSocket.Listen(10);

   //利用线程后台执行监听,否则程序会假死
   Thread thread = new Thread(Listen);
   thread.IsBackground = true;
   thread.Start(serverSocket);

   Console.Read();
  }

  /// <summary>
  /// 监听连接
  /// </summary>
  /// <param name="o"></param>
  static void Listen(object o)
  {
   var serverSocket = o as Socket;
   while (true)
   {
    //等待连接并且创建一个负责通讯的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)
   {
    //获取发送过来的消息容器
    byte[] buffer = new byte[1024 * 1024 * 2];
    var effective = send.Receive(buffer);
    //有效字节为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.建立ip位址和連接埠(伺服器的IP和連接埠)

##    b.與伺服器端建立連結

2. 接收伺服器傳送的訊息    a.啟動一個新的執行緒執行

    b.利用循環獲取發送過來的訊息，呼叫獲取訊息的方法需要傳遞一個位元組變數參數，作為容器。方法傳回值為int，表示取得的有效位元組數

    c.如果有效位元組數為0則跳出迴圈

##3. 傳送訊息給伺服器

    a. 呼叫socket物件的send()方法直接傳送

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!");
   //创建实例
   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);
   
   //不停的接收服务器端发送的消息
   Thread thread = new Thread(Recive);
   thread.IsBackground = true;
   thread.Start(socketClient);

   //不停的给服务器发送数据
   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)
   {
    //获取发送过来的消息
    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);
   }
  }
 }
}

以上是C# Socket實作簡單控制台案例的詳細內容。更多資訊請關注PHP中文網其他相關文章！