网络进程通信
1.通过网络层“ip地址”可以唯一标识网络中的主机
2.传输层的“协议+端口”可以唯一标识主机中的应用程序
所以通过 ip地址+协议+端口 就可以确定标识网络的进程了,网络中的进程通信就可以利用这个标志与其它进程进行交互
socket
socket字面意思就是套接字
网络中的进程是通过socket来通信的
客户端和服务段通信流程图(借用网上的图片使用)
基本是流程就这样:
服务器:创建套接字->绑定协议地址族(ip地址,端口,通信协议)->监听客户端排队的最大连接个数->等待接收客户端连接->数据交互->关闭套接字
客户端:创建套接字-》连接服务器地址族-》进入数据交互-》关闭套接字
根据上面的思路,简单的示例如下:
SeverSocket
#include<stdio.h>
#include<windows.h>
#pragma comment(lib,"ws2_32.lib")
int main(){
//请求协议版本
WSADATA wsaData;
WSAStartup(MAKEWORD(2, 2), &wsaData);
if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2){
printf("请求协议版本失败!\n");
return -1;
}
//创建socket(协议版本,数据类型,协议)
SOCKET serverSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (serverSocket == -1){
printf("创建socket失败!\n");
WSACleanup();
return -2;
}
printf("创建socket成功!\n");
//创建协议地址族
SOCKADDR_IN addr = { 0 };
addr.sin_family = AF_INET;//协议版本
addr.sin_addr.S_un.S_addr = inet_addr("10.10.12.52");//ip地址
addr.sin_port = htons(10010);//端口,建议自定义端口使用10000之后的,以为之前的端口可能被其他应用程序占用
//绑定
int r = bind(serverSocket, (sockaddr*)&addr, sizeof addr);
if (r == -1){
printf("bind失败!\n");
closesocket(serverSocket);
WSACleanup();
return -2;
}
printf("bind成功!\n");
//监听
r = listen(serverSocket, 10);
if (r == -1){
printf("listen失败!\n");
closesocket(serverSocket);
WSACleanup();
return -2;
}
printf("listen成功!\n");
//等待客户端连接 客户端协议地址族
SOCKADDR_IN cAddr = { 0 };
int len = sizeof cAddr;
SOCKET clinetSocket = accept(serverSocket, (sockaddr*)&cAddr, &len);
if (clinetSocket == -1){
printf("服务器宕机了!\n");
//关闭socket
closesocket(serverSocket);
//清除协议信息
WSACleanup();
return -2;
}
printf("有客户端连接到服务器了:%s!\n", inet_ntoa(cAddr.sin_addr));
//通信
char buff[1024];
while (1){
r = recv(clinetSocket, buff, 1023, NULL);
if (r > 0){
buff[r] = 0;
printf(">>>>%s\n", buff);
}
}
getchar();
//system("pause");
return 0;
}
ClientSocket
#include<stdio.h>
#include<windows.h>
#pragma comment(lib,"ws2_32.lib")
int main(){
//1.请求协议版本
WSADATA wsaData;
WSAStartup(MAKEWORD(2, 2), &wsaData);
if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2){
printf("请求协议版本失败!\n");
return -1;
}
//2.创建socket
SOCKET clientSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (clientSocket == -1){
printf("创建socket失败!\n");
WSACleanup();
return -2;
}
printf("创建socket成功!\n");
//3.创建协议地址族
SOCKADDR_IN addr = { 0 };
addr.sin_family = AF_INET;
addr.sin_addr.S_un.S_addr = inet_addr("10.10.12.52");
addr.sin_port = htons(10010);
//4.连接服务器
int r = connect(clientSocket, (sockaddr*)&addr, sizeof addr);
if (r == -1){
printf("连接服务器失败!\n");
return -2;
}
printf("连接服务器成功!\n");
//5.通信
char buff[1024];
while (1){
memset(buff, 0, 1024);
printf("你想说什么:\n");
scanf("%s", buff);
send(clientSocket, buff, strlen(buff), NULL);
}
getchar();
//system("pause");
return 0;
}
运行结果:
可以在这个简单的例子基础上进行优化,实现多玩家的连接服务器,进行数据交互