商业源码 问一下，怎么能让服务器主动向客户端发送数据
在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结构的通信了。
0条评论