服务器Socket Interface是什么?
Socket接口是TCP/IP网络的API(Application Programming Interface,应用程序编程接口),Socket接口定义了许多函数或例程,程序员可以用它们来开发 TCP/IP网络上的应用程序。
请参阅以下资料:
socket非常类似于电话插座。以一个国家级电话网为例。电话的通话双方相当于相互通信的2个进程,区号是它的网络地址;区内一个单位的交换机相当于一台主机,主机分配给每个用户的局内号码相当于socket号。任何用户在通话之前,首先要占有一部电话机,相当于申请一个socket;同时要知道对方的号码,相当于对方有一个固定的socket。然后向对方拨号呼叫,相当于发出连接请求(假如对方不在同一区内,还要拨对方区号,相当于给出网络地址)。对方假如在场并空闲(相当于通信的另一主机开机且可以接受连接请求),拿起电话话筒,双方就可以正式通话,相当于连接成功。双方通话的过程,是一方向电话机发出信号和对方从电话机接收信号的过程,相当于向socket发送数据和从socket接收数据。通话结束后,一方挂起电话机相当于关闭socket,撤消连接。
在电话系统中,一般用户只能感受到本地电话机和对方电话号码的存在,建立通话的过程,话音传输的过程以及整个电话系统的技术细节对他都是透明的,这也与socket机制非常相似。socket利用网间网通信设施实现进程通信,但它对通信设施的细节毫不关心,只要通信设施能提供足够的通信能力,它就满足了。
至此,我们对socket进行了直观的描述。抽象出来,socket实质上提供了进程通信的端点。进程通信之前,双方首先必须各自创建一个端点,否则是没有办法建立联系并相互通信的。正如打电话之前,双方必须各自拥有一台电话机一样。在网间网内部,每一个socket用一个半相关描述:
(协议,本地地址,本地端口)
一个完整的socket有一个本地唯一的socket号,由操作系统分配。
最重要的是,socket 是面向客户/服务器模型而设计的,针对客户和服务器程序提供不同的socket 系统调用。客户随机申请一个socket (相当于一个想打电话的人可以在任何一台入网电话上拨号呼叫),系统为之分配一个socket号;服务器拥有全局公认的 socket ,任何客户都可以向它发出连接请求和信息请求(相当于一个被呼叫的电话拥有一个呼叫方知道的电话号码)。
socket利用客户/服务器模式巧妙地解决了进程之间建立通信连接的问题。服务器socket 半相关为全局所公认非常重要。读者不妨考虑一下,两个完全随机的用户进程之间如何建立通信?假如通信双方没有任何一方的socket 固定,就好比打电话的双方彼此不知道对方的电话号码,要通话是不可能的。
1、客户端连接一般是与用户绑定的,无用户数据的socket就算能区分连接也毫无意义。一般做法是客户端利用HTTP登录,登录服务器分析各个socket服务器的负载后发送给客户端应该连接哪个socket服务器,客户端拿到登录成功后的用户ID后再连接socket服务器,此用户ID就可以用于socket服务器区分客户端连接。
2、如果自建socket服务器,建议最好不用SSH、SSM之类的框架,可控性更高,更加轻量,但工作量稍显繁多,且复杂;建议使用Netty做scoket基础框架。
3、客户端服务端通信可以用json格式的文本行(字符流,以\r\n自动做粘包断包解码),还有自定义数据格式的字节流(比如 数据包内容长度+数据包内容,以数据包内容长度手动编写代码做粘包断包解码),还可以用时下流行的protobuf。
namespace SocketTest{ class Program { public static void SendMessage() { Socket socket = serverSocketAccept(); ConsoleWriteLine("Connected a client:{0}",socketRemoteEndPoint); socketSend(EncodingASCIIGetBytes("welcome to server")); //Thread thread = new Thread(ReceiveMessage); // threadStart(); } public static void ReceiveMessage(object obj) { Socket socket = (Socket)obj; byte[] data = new byte[1024]; int len = socketReceive(data); string dataString = EncodingASCIIGetString(data, 0, len); ConsoleWriteLine("Receive Data:{0} from {1}", dataString,socketRemoteEndPoint); //Thread thread = new Thread(SendMessage); //threadStart(socket); } static Socket serverSocket; static void Main(string[] args) { //定义接收数据长度变量 int recv; //定义接收数据的缓存 byte[] data = new byte[1024]; //定义侦听端口 IPEndPoint ipEnd = new IPEndPoint(IPAddressAny, 5566); //定义套接字类型 serverSocket = new Socket(AddressFamilyInterNetwork, SocketTypeStream, ProtocolTypeTcp); //连接 serverSocketBind(ipEnd); //开始侦听 serverSocketListen(10); //控制台输出侦听状态 ConsoleWrite("Waiting for a client"); //Socket client; while (true) { //一旦接受连接,创建一个客户端 Socket client = serverSocketAccept(); //获取客户端的IP和端口 IPEndPoint ipEndClient = (IPEndPoint)clientRemoteEndPoint; //输出客户端的IP和端口 ConsoleWriteLine("Connect with {0} at port {1}", ipEndClientAddress, ipEndClientPort); //定义待发送字符 string welcome = "Welcome to my server"; //数据类型转换 data = EncodingASCIIGetBytes(welcome); while (true) { try { //发送 clientSend(data, dataLength, SocketFlagsNone); //接收数据可以用线程也可以不用 //ReceiveMessage(client); Thread thread = new Thread(ReceiveMessage); threadStart(client); ////对data清零 //data = new byte[1024]; ////获取收到的数据的长度 //recv = clientReceive(data); ////如果收到的数据长度为0,则退出 //if (recv == 0) // break; ////输出接收到的数据 //ConsoleWriteLine(EncodingASCIIGetString(data, 0, recv)); //将接收到的数据再发送出去 // clientSend(data, recv, SocketFlagsNone); } catch (Exception) { clientClose(); serverSocketClose(); } } clientClose(); } //ConsoleWriteLine("Disconnect form{0}", ipEndClientAddress); serverSocketClose(); } }}
你的文件中的问题
// 会阻塞进程,直到有客户端连接上来为止
// 既然是直到有客户端连接上,那么就要弄明白哪个是与客户端连接的套接字
// sockClient就是与客户端连接的套接字
sockClient = accept(sockServer, (SOCKADDR)&addrClient, &len);
//接收并打印客户端数据
recv(sockClient, recvBuf, 100, 0);
printf("%s\n", recvBuf);
// 所以此处,应该把sockServer改为sockClient
send(/sockServer/sockClient, sendBuf, 100, 0);
PS:服务器客户端通信,是要保持服务器与客户端的连接。
而不能这样立即关闭,如果设置不对,立即关闭,缓冲区的数据是会丢失的。那客户端也就不会再收到数据了。
你可以加Sleep(10000);来测是通信过程
//关闭socket
closesocket(sockClient);
0条评论