你得学会并且学得会的Socket编程基础知识(5)

【备注】因为服务器每隔两秒钟会发送新消息过来，所以在输入的时候，动作要稍快一点啦

本文最后探讨一个问题，就是如何让我们的服务器可以支持多个客户端

第九步：支持多个客户端

这个步骤只需要修改服务端程序即可

using System;

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

//额外导入的两个命名空间 using System.Net.Sockets; using System.Net;

namespace SocketServer {

class Program {

///

/// Socket Server 演示 /// 作者：陈希章 ///

///

//创建一个新的Socket,这里我们使用最常用的基于TCP的Stream Socket（流式套接字）

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

//将该socket绑定到主机上面的某个端口 //方法参考：

http://msdn.microsoft.com/zh-cn/library/system.net.sockets.socket.bind.aspx

socket.Bind(new IPEndPoint(IPAddress.Any, 4530));

//启动监听，并且设置一个最大的队列长度

//方法参考：

http://msdn.microsoft.com/zh-cn/library/system.net.sockets.socket.listen(v=VS.100).aspx socket.Listen(4);

//开始接受客户端连接请求 //方法参考：

http://msdn.microsoft.com/zh-cn/library/system.net.sockets.socket.beginaccept.aspx

socket.BeginAccept(new AsyncCallback(ClientAccepted), socket);

Console.WriteLine(\); Console.Read(); }

public static void ClientAccepted(IAsyncResult ar) {

var socket = ar.AsyncState as Socket;

//这就是客户端的Socket实例，我们后续可以将其保存起来 var client = socket.EndAccept(ar);

//给客户端发送一个欢迎消息

client.Send(Encoding.Unicode.GetBytes(\accept you request at \ + DateTime.Now.ToString()));

//实现每隔两秒钟给服务器发一个消息 //这里我们使用了一个定时器

var timer = new System.Timers.Timer(); timer.Interval = 2000D; timer.Enabled = true;

timer.Elapsed += (o, a) => {

//检测客户端Socket的状态 if(client.Connected) {

try {

client.Send(Encoding.Unicode.GetBytes(\ + DateTime.Now.ToString())); }

catch(SocketException ex) {

Console.WriteLine(ex.Message); } } else {

timer.Stop();

timer.Enabled = false; Console.WriteLine(\is disconnected, the timer is stop.\); } };

timer.Start();

//接收客户端的消息(这个和在客户端实现的方式是一样的） client.BeginReceive(buffer, 0, buffer.Length,

SocketFlags.None, new AsyncCallback(ReceiveMessage), client);

//准备接受下一个客户端请求

socket.BeginAccept(new AsyncCallback(ClientAccepted), socket); }

static byte[] buffer = new byte[1024];

public static void ReceiveMessage(IAsyncResult ar) {

try {

var socket = ar.AsyncState as Socket;

//方法参考：

http://msdn.microsoft.com/zh-cn/library/system.net.sockets.socket.endreceive.aspx

var length = socket.EndReceive(ar); //读取出来消息内容

var message = Encoding.Unicode.GetString(buffer, 0, length);

//显示消息

Console.WriteLine(message);

//接收下一个消息(因为这是一个递归的调用，所以这样就可以一直接收消息了）

socket.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveMessage), socket); }

catch(Exception ex){

Console.WriteLine(ex.Message); } } } }

最后调试起来看到的效果如下图