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就可以通信了。

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