C# Socket implements simple console case

This article mainly shares a simple console case of C# Socket, which has certain reference value. Interested friends can refer to it

1. Server side

1. Instantiate and set the socket instance object

a. Create an ip address and port

b .Bind the listening address

c.Set the number of simultaneous accesses allowed

2. Monitor the connection

a.Pass Start a new thread for execution so that the main thread will not freeze (start the thread, and the parameters must be of object type)

b. Use a loop to wait for the connection and return a socket instance responsible for communication

c. The IP address of the connected customer service can be obtained from the returned socket instance

3. Receive the message sent by the customer service

a. Start a new thread for execution in the listening method

b. Use a loop to obtain the sent message. When calling the method to obtain the message, you need to pass a byte variable parameter as a container. The return value of the method is int, indicating the number of valid bytes obtained

c. If the number of valid bytes is 0, jump out of the loop

d. Return the message to customer service after receiving the message

4. Console program server-side code

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);

   }
  }
 }
}

2. Client

1. Instantiate and connect the socket instance object

a. Create an ip address and port (the IP and port of the server)

b. Connect with the server Establish a link

2. Receive messages sent by the server

a. Start a new thread for execution

b. Use Loop to obtain the sent message. When calling the method to obtain the message, you need to pass a byte variable parameter as a container. The method return value is int, indicating the number of valid bytes obtained

c. If the number of valid bytes is 0, jump out of the loop

3. Send a message to the server

a. Call the send() method of the socket object to send directly

4. Console program client code

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);
   }
  }
 }
}

The above is the detailed content of C# Socket implements simple console case. For more information, please follow other related articles on the PHP Chinese website!