因为UNIX和Win的socket大同小异,为了方便和大众化,这里先介绍Winsock编程。
socket 网络编程的难点在入门的时候就是对基本函数的了解和使用,因为这些函数的结构往往比较复杂,参数大部分都是结构体,令人难以记忆和理解。
但是一旦我们知道这些函数包括其参数的具体含义,socket网络编程也就变得不是那么复杂。这里不赘述 具体函数的详细含义,网络上有很多的文章,同时笔者建议大家参考
MSDN,对返回值,参数等会有更好的理解。
以下均为单线程的简单实例,多线程的请关注下一篇文章。
(一)
UDP:中文名是用户数据报协议,是OSI参考模型中的一种无连接的传输层协议,提供面向事物的简单不可靠信息传送服务,在网络良好的情况下也可能会出现丢包现象。
UDP通讯流程:
(Winsock的初始化:WSAStartup) //windows特有的
Server端:
socket:建立套接字
bind:发布端口(netstat -an可见已经发布的端口)
sendto/recv/recvfrom:收发数据
Client端:
socket:建立套接字
bind:发布端口(netstat -an可见已经发布的端口)
sendto/recv/recvfrom:收发数据
其他函数详见注释。
UDP--Client #define _CRT_SECURE_NO_WARNINGS #include <stdio.h> #include <iostream> #include <string> #include <winsock2.h> #pragma comment(lib,"ws2_32.lib") //编译器设置--链接库 using namespace std; const int PORT = 8009; int main() { int n; WSADATA wd; n = WSAStartup(MAKEWORD(2, 2), &wd); if (n) { cout << "WSAStartup函数错误!" << endl; return -1; } SOCKET sock = socket(AF_INET, SOCK_DGRAM, 0); //SOCK_DGRAM代表UDP if (INVALID_SOCKET == sock) { cout << "socket建立失败!" << endl; return -1; } sockaddr_in sa = { AF_INET }; //随机分配一个端口 (仅初始化一个值,让客户端自己分配端口) n = bind(sock, (sockaddr*)&sa, sizeof(sa)); if (n == SOCKET_ERROR) { cout << "bind函数失败!" << endl; cout << "错误码是:" << WSAGetLastError() << endl; return -1; } sockaddr_in sa1 = { AF_INET, htons(8009) }; //必须使用htons,因为网络字节序的缘故 sa1.sin_addr.S_un.S_addr = inet_addr("192.168.253.1");//指定要发往的IP和端口号 char s[256]; while (true) { fflush(stdin); gets(s); sendto(sock, s, strlen(s), 0,(sockaddr*)&sa1,sizeof(sa1)); //发送数据 } return 0; }
UDP-Server #include <cstdio> #include <iostream> #include <string> #include <winsock2.h> #pragma comment(lib,"ws2_32.lib") using namespace std; const int PORT = 8009; int main() { int n; WSADATA wd; n=WSAStartup(MAKEWORD(2, 2), &wd); if (n) { cout << "WSAStartup函数错误!" << endl; return -1; } SOCKET sock = socket(AF_INET, SOCK_DGRAM,0); if (INVALID_SOCKET == sock) { cout << "socket建立失败!" << endl; cout << "错误码是:" << WSAGetLastError() << endl; return -1; } sockaddr_in sa = { AF_INET, htons(PORT) }; n=bind(sock,(sockaddr*)&sa, sizeof(sa)); if (n == SOCKET_ERROR) { cout << "bind绑定端口失败!" << endl; cout << "错误码是:" << WSAGetLastError() << endl; return -1; } else { cout << "端口发布成功:" << PORT << endl; } char s[256]; while (true) { n = recv(sock, s, sizeof(s), 0); //recv返回的是实际copy的字节数 s[n] = '\0'; cout << s << endl; } return 0; }
(二)
TCP: 是一种面向连接(连接导向)的、可靠的、基于字节流的运输层(Transport layer)通信协议。
TCP通讯流程
(Winsock的初始化:WSAStartup)
Server端:
socket:建立套接字
bind:发布端口
listen:开始侦听
accept:接纳客户端连接(如同公司的前台)
send/recv/recvfrom:收发数据(如同公司的客户经理)
Client端:
socket:建立套接字
bind:发布端口(客户端可以不绑定或绑定0端口)
connect:连接到服务器
send/recv/recvfrom:收发数据(如同公司的客户经理)
一般通讯流程是按:CS双方1发1收对称的,一旦收发顺讯混乱软件就失控了。
(请求应答模式:Request/Reply)
TCP---Server #include <cstdio> #include <iostream> #include <string> #include <winsock2.h> #pragma comment(lib,"ws2_32.lib") using namespace std; const int PORT = 8009; int main() { int n; WSADATA wd; n=WSAStartup(MAKEWORD(2, 2), &wd); if (n) { cout << "WSAStartup函数错误!" << endl; return -1; } SOCKET sock = socket(AF_INET, SOCK_STREAM,0); if (INVALID_SOCKET == sock) { cout << "socket建立失败!" << endl; cout << "错误码是:" << WSAGetLastError() << endl; return -1; } sockaddr_in sa = { AF_INET, htons(PORT) }; n=bind(sock,(sockaddr*)&sa, sizeof(sa)); if (n == SOCKET_ERROR) { cout << "bind绑定端口失败!" << endl; cout << "错误码是:" << WSAGetLastError() << endl; return -1; } else { cout << "端口发布成功:" << PORT << endl; } listen(sock, 5); //第二个参数一般设置5 int nlen = sizeof(sa); SOCKET socka = accept(sock, (sockaddr*)&sa, &nlen); //会返回一个新的连接套接字 if (socka == INVALID_SOCKET) { cout << "accepth函数失败!" << endl; cout << "错误码是:" << WSAGetLastError() << endl; return -1; } cout << "有人连接进来:" << inet_ntoa(sa.sin_addr) << "--" << htons(sa.sin_port) << endl;//输出连接者的ip和端口 char s[256]; while ((n = recv(socka, s, sizeof(s)-1, 0)) > 0) //-1是留给‘\0’一个位置 { s[n] = '\0'; cout << s << endl; /* char k[256] = "你好啊"; if (strcmp(s,k)==0) cout << "你好你好,大家都好哈!" << endl;*/ } return 0; }
TCP---Client #define _CRT_SECURE_NO_WARNINGS #include <stdio.h> #include <iostream> #include <string> #include <winsock2.h> #pragma comment(lib,"ws2_32.lib") using namespace std; const int PORT = 8009; int main() { int n; WSADATA wd; n = WSAStartup(MAKEWORD(2, 2), &wd); if (n) { cout << "WSAStartup函数错误!" << endl; return -1; } SOCKET sock = socket(AF_INET, SOCK_STREAM, 0); if (INVALID_SOCKET == sock) { cout << "socket建立失败!" << endl; return -1; } sockaddr_in sa = { AF_INET }; //随机分配一个端口 n = bind(sock, (sockaddr*)&sa, sizeof(sa)); if (n == SOCKET_ERROR) { cout << "bind函数失败!" << endl; cout << "错误码是:" << WSAGetLastError() << endl; return -1; } sa.sin_addr.S_un.S_addr = inet_addr("192.168.253.1");//115.200.33.112 sa.sin_port = htons(PORT); n = connect(sock, (sockaddr*)&sa, sizeof(sa)); //指定端口发送数据 if (n == SOCKET_ERROR) { cout << "connect函数失败!" << endl; cout << "错误码是:" << WSAGetLastError() << endl; return -1; } char s[256]; while (true) { fflush(stdin); gets(s); send(sock, s, strlen(s), 0); } return 0; }
版权声明:本文为博主原创文章,未经博主允许不得转载。