C#实现Socket通信的解决方法

本文以实例详述了C#实现Socket通信的解决方法，具体实现步骤如下：

1、首先打开VS新建两个控制台应用程序：
ConsoleApplication_socketServer和ConsoleApplication_socketClient。
 
2、在ConsoleApplication_socketClient中输入以下代码：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets; 

namespace ConsoleApplication_socketClient
{
  class Program
  {
    static Socket clientSocket;
    static void Main(string[] args)
    {
      //将网络端点表示为IP地址和端口 用于socket侦听时绑定
      IPEndPoint ipep = new IPEndPoint(IPAddress.Parse("*.*.*.*"), 3001); //填写自己电脑的IP或者其他电脑的IP，如果是其他电脑IP的话需将ConsoleApplication_socketServer工程放在对应的电脑上。
      clientSocket = new Socket(ipep.AddressFamily,SocketType.Stream,ProtocolType.Tcp);
      //将Socket连接到服务器
      try
      {
        clientSocket.Connect(ipep);
        String outBufferStr;
        Byte[] outBuffer = new Byte[1024];
        Byte[] inBuffer = new Byte[1024];
        while (true)
        {
          //发送消息
          outBufferStr = Console.ReadLine();
          outBuffer = Encoding.ASCII.GetBytes(outBufferStr);
          clientSocket.Send(outBuffer, outBuffer.Length, SocketFlags.None); 

          //接收服务器端信息
          clientSocket.Receive(inBuffer, 1024, SocketFlags.None);//如果接收的消息为空 阻塞 当前循环
          Console.WriteLine("服务器说：");
          Console.WriteLine(Encoding.ASCII.GetString(inBuffer));
        }
      }
      catch
      {
        Console.WriteLine("服务未开启！");
        Console.ReadLine();
      }
    }
  }
}

3、在ConsoleApplication_socketServer中输入以下代码：

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

namespace ConsoleApplication_socketServer
{
  class Program
  {
    static Socket serverSocket;
    static Socket clientSocket;
    static Thread thread;
    static void Main(string[] args)
    {
      IPEndPoint ipep = new IPEndPoint(IPAddress.Any, 3001);
      serverSocket = new Socket(ipep.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
      serverSocket.Bind(ipep);
      serverSocket.Listen(10);
      while (true)
      {
        clientSocket = serverSocket.Accept();
        thread = new Thread(new ThreadStart(doWork));
        thread.Start();
      }
    }
    private static void doWork()
    {
      Socket s = clientSocket;//客户端信息
      IPEndPoint ipEndPoint = (IPEndPoint)s.RemoteEndPoint;
      String address = ipEndPoint.Address.ToString();
      String port = ipEndPoint.Port.ToString();
      Console.WriteLine(address + ":" + port + " 连接过来了");
      Byte[] inBuffer = new Byte[1024];
      Byte[] outBuffer = new Byte[1024];
      String inBufferStr;
      String outBufferStr;
      try
      {
        while (true)
        {
          s.Receive(inBuffer, 1024, SocketFlags.None);//如果接收的消息为空 阻塞 当前循环
          inBufferStr = Encoding.ASCII.GetString(inBuffer);
          Console.WriteLine(address + ":" + port + "说:");
          Console.WriteLine(inBufferStr);
          outBufferStr = Console.ReadLine();
          outBuffer = Encoding.ASCII.GetBytes(outBufferStr);
          s.Send(outBuffer, outBuffer.Length, SocketFlags.None);
        }
      }
      catch
      {
        Console.WriteLine("客户端已关闭！");
      }
    }
  }
}
 

4、先运行ConsoleApplication_socketServer，后运行ConsoleApplication_socketClient就可以通信了。

本例给出了基本的实现代码，读者可以根据自身的需求进一步完成个性化功能。