Socket服务端:

using System;

using System.Collections.Generic;

using System.Net;

using System.Net.Sockets;

using System.Text;

using System.Threading;

public class SocketServer

{

public static Socket listenSocket;//监听Socket

public static List<Socket> clientList = new List<Socket>();//客户端列表

static void Main(string[] args)

{

//创建监听Socket,并绑定ip

listenSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

IPEndPoint ip = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 5555);

listenSocket.Bind(ip);

//设定监听最大数量

listenSocket.Listen(100);

Thread thread = new Thread(Listen);

thread.IsBackground = true;

thread.Start();

Console.ReadKey();

}

static void Listen()

{

Console.WriteLine("开始监听");

while(true)

{

//开始监听，若监听到访问则创建一个Socket表示与其的连接

Socket newSocket = listenSocket.Accept();

Console.WriteLine("有客户端连接");

//告诉其他客户端，有客户端登录

foreach(Socket socket in clientList)

{

socket.Send(new UTF8Encoding().GetBytes(newSocket.RemoteEndPoint.ToString() + "已经上线"));

}

//添加至列表

clientList.Add(newSocket);

//创建线程监听客户端发来的消息

Thread thread = new Thread(ReceiveMsg);

thread.IsBackground = true;

thread.Start(newSocket);

}

}

static void ReceiveMsg(Object Obj_)

{

Socket socket = (Socket)Obj_;

while (true)

{

try

{

byte[] bs = new byte[1024];

socket.Receive(bs);

Console.WriteLine(socket.RemoteEndPoint.ToString() + ":" + new UTF8Encoding().GetString(bs) + "\n");

}

catch

{

Console.WriteLine("有客户端掉线");

clientList.Remove(socket);

return;

}

}

}

}

Socket客户端：

using System;

using System.Net;

using System.Net.Sockets;

using System.Text;

using System.Threading;

public class SockClient

{

public static Socket socket;

static void Main(string[] args)

{

//创建代表本地的socket

socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

//创建要连接的ip并尝试连接该ip

IPEndPoint ip = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 5555);

socket.Connect(ip);

Thread thread = new Thread(ReceiveServerMessage);

thread.IsBackground = true;

thread.Start();

while(true)

{

string content = Console.ReadLine();

//发送消息

socket.Send(new UTF8Encoding().GetBytes(content));

}

}

static void ReceiveServerMessage()

{

while(true)

{

//接收来自服务端的消息

byte[] bs = new byte[1024];

socket.Receive(bs);

Console.WriteLine(socket.RemoteEndPoint.ToString() + ":" + new UTF8Encoding().GetString(bs) + "\n");

}

}

}