问一下，怎么能让服务器主动向客户端发送数据

在HTTP中有一种长连接技术，可以模仿Socket通信实现服务器端主动向客户端浏览器发送数据。它的原理其实很简单：当服务器端接到客户端的询问请求后，将整个HTTP连接置于阻塞状态，即什么也不做，也不发送数据，也不关掉连接。直到客户端需要将最新数据返回给客户端时，将数据通过这个HTTP连接返回回去，并且关闭连接。这样，客户端看到的结果，就似乎是服务器端主动向客户端浏览器发送数据了。但是，关掉连接以后怎么办呢？这时候，可以通过客户端JS代码中的定时器，再次发起请求。这样，只有内容发生了变化，才会进行一次HTTP会话，所以整体效率比轮询方式要高出很多，同时还有了更好的及时性。

先发服务端的（Server)完整代码如下：

引入命名空间：

[csharp] view plain copy print

using SystemNetSockets;

using SystemNet;

using SystemThreading;

完整代码如下：

[csharp] view plain copy print

namespace SocketServer

{

class Program

{

private static byte[] result = new byte[1024];

private static int myProt = 8885; //端口

static Socket serverSocket;

static void Main(string[] args)

{

//服务器IP地址

IPAddress ip = IPAddressParse("127001");

serverSocket = new Socket(AddressFamilyInterNetwork, SocketTypeStream, ProtocolTypeTcp);

serverSocketBind(new IPEndPoint(ip, myProt)); //绑定IP地址：端口

serverSocketListen(10); //设定最多10个排队连接请求

ConsoleWriteLine("启动监听{0}成功", serverSocketLocalEndPointToString());

//通过Clientsoket发送数据

Thread myThread = new Thread(ListenClientConnect);

myThreadStart();

ConsoleReadLine();

}

/// <summary>

/// 监听客户端连接

/// </summary>

private static void ListenClientConnect()

{

while (true)

{

Socket clientSocket = serverSocketAccept();

clientSocketSend(EncodingASCIIGetBytes("Server Say Hello"));

Thread receiveThread = new Thread(ReceiveMessage);

receiveThreadStart(clientSocket);

}

}

/// <summary>

/// 接收消息

/// </summary>

/// <param name="clientSocket"></param>

private static void ReceiveMessage(object clientSocket)

{

Socket myClientSocket = (Socket)clientSocket;

while (true)

{

try

{

//通过clientSocket接收数据

int receiveNumber = myClientSocketReceive(result);

ConsoleWriteLine("接收客户端{0}消息{1}", myClientSocketRemoteEndPointToString(), EncodingASCIIGetString(result, 0, receiveNumber));

}

catch(Exception ex)

{

ConsoleWriteLine(exMessage);

myClientSocketShutdown(SocketShutdownBoth);

myClientSocketClose();

break;

}

}

}

}

}

以上是服务端（server）的完整代码。

客户端（Client）的完整代码如下：

引入命名空间：

[csharp] view plain copy print

using SystemNet;

using SystemNetSockets;

using SystemThreading;

完整代码：

[csharp] view plain copy print

namespace SocketClient

{

class Program

{

private static byte[] result = new byte[1024];

static void Main(string[] args)

{

//设定服务器IP地址

IPAddress ip = IPAddressParse("127001");

Socket clientSocket = new Socket(AddressFamilyInterNetwork, SocketTypeStream, ProtocolTypeTcp);

try

{

clientSocketConnect(new IPEndPoint(ip, 8885)); //配置服务器IP与端口

ConsoleWriteLine("连接服务器成功");

}

catch

{

ConsoleWriteLine("连接服务器失败，请按回车键退出！");

return;

}

//通过clientSocket接收数据

int receiveLength = clientSocketReceive(result);

ConsoleWriteLine("接收服务器消息：{0}",EncodingASCIIGetString(result,0,receiveLength));

//通过 clientSocket 发送数据

for (int i = 0; i < 10; i++)

{

try

{

ThreadSleep(1000); //等待1秒钟

string sendMessage = "client send Message Hellp" + DateTimeNow;

clientSocketSend(EncodingASCIIGetBytes(sendMessage));

ConsoleWriteLine("向服务器发送消息：{0}" + sendMessage);

}

catch

{

clientSocketShutdown(SocketShutdownBoth);

clientSocketClose();

break;

}

}

ConsoleWriteLine("发送完毕，按回车键退出");

ConsoleReadLine();

}

}

}

编译成功后，先运行 服务端（server），再运行客户端（client）即可达到通信效果。

效果如下图：

该程序已在局域网测试通过。（192168XX）

　　在“Message”后的框中输入欲发送信息的标题，其下的框中输入正文。如果有必要，选中“URL Button”(网址按钮)，在其后的框中输入网站说明，其下的框中输入网站地址。然后，再选是将此信息发送给“Offline Or Online Users”(所有在线和离线的用户)，还是只将它发送给“Online Users”(在线用户)。最后按“Broadcast Message”将信息发送出去。“Server Messages History”为以前所发送的所有信息的历史记录，选中相应记录后再按“Delete”按钮即可删除它，按“Copy”键可将它再复制到上面相应栏目中，以便再次发送。　　服务器端的信息发送后，客户端就会收到信息。

Socket通信：

作为服务器端:

//生成服务器端,监听服务器设定的端口

ServerSocket socketServer = new ServerSocket(端口号);

//建立客户端和服务器端的链接，这时再看客户端

Socket socket = socketServeraccept();

作为客户端:

//新建一个Socket，包含服务器端的IP和端口号，这样在服务器启动情况下可以建立和服务器的链接

Socket socket = new Socket（"IP地址","端口号"）;

这时,服务器端和客户端的连接已经建立,如果需要通信和传输数据的话分别在服务器端、客户端新建流对象，可以通过流对象实现双方之间的互通

有关流的内容自己看书体会下就能写出B/S结构的通信了。