C++/C socket编程实例

目录

• 基于TCP的socket编程
  • 服务器代码
  • 客户端代码
  • 运行结果
• 基于UDP的socket编程
  • 服务器代码
  • 客户端代码
  • 运行结果

基于TCP的socket编程

服务器代码

服务器端代码如下

//TCPServer.c

#include <stdio.h>

#include <string.h>

#include "winsock.h"

#include "windows.h"

#pragma comment(lib, "wsock32")

#define PORT 8888	//端口号

#define BACKLOG 5	//最大监听数

char serverAddr[16] = "192.168.0.3";//服务器端IP

int main()

{

	WSADATA wsaData;/*WSADATA 结构被用来保存函数 WSAStartup 返回的 Windows Sockets 初始化信息*/

	if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {

		/*

		使用 Socket 的程序在使用 Socket 之前必须调用 WSAStartup 函数, 当一个应用程序调用 WSAStartup 函数时，

		操作系统根据请求的 Socket 版本来搜索相应的 Socket 库，

		然后绑定找到的 Socket 库到该应用程序中。以后应用程序就可以调用所请求的 Socket 库中的其它 Socket 函数了。

		 */

		printf_s("WSAStartup失败.\n"); // 初始化失败

		exit(1);

	}

	SOCKET socketFD = 0;  //socket句柄

	int recvLen = 0;   //接收成功后的返回值

	SOCKET newFD = 0; 	//建立连接后的句柄

	char buf[4096] = { 0 }; //buff缓冲区

	SOCKADDR_IN addrServer, addrClient;

	socketFD = socket(AF_INET, SOCK_STREAM, 0); //建立socket

	if (INVALID_SOCKET == socketFD)

	{

		printf_s("创建socket失败\n");

		printf_s("SOCKET ERROR #%d\n", WSAGetLastError());

		return 0;

	}

	printf_s("创建socket成功\n");

	addrServer.sin_family = AF_INET;  /*该属性表示接收本机或其他机器传输*/

	addrServer.sin_port = htons(PORT); /*端口号*/

	addrServer.sin_addr.S_un.S_addr = inet_addr(serverAddr);/*服务器IP*/

	//连接方法： 传入句柄，目标地址，和大小

	if (0 > connect(socketFD, (SOCKADDR*)&addrServer, sizeof(addrServer)))

	{

		printf_s("连接服务器失败\n");

		printf_s("CONNECT ERROR #%d\n", WSAGetLastError());

	}

	else {

		printf("连接服务器成功\n");

		recv(socketFD, buf, sizeof(buf), 0); ////将接收数据打入buf，参数分别是句柄，储存处，最大长度，其他信息（设为0即可）。 

		printf("Recv:%s\n", buf);

	}

	return 0;

}

客户端代码

客户端代码如下

//TCPClient.c

#include <stdio.h>

#include <string.h>

#include "winsock.h"

#include "windows.h"

#pragma comment(lib, "wsock32")

#define PORT 8888	//端口号

#define BACKLOG 5	//最大监听数

char serverAddr[16] = "192.168.0.3";//服务器端IP

int main()

{

	WSADATA wsaData;/*WSADATA 结构被用来保存函数 WSAStartup 返回的 Windows Sockets 初始化信息*/

	if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {

		/*

		使用 Socket 的程序在使用 Socket 之前必须调用 WSAStartup 函数, 当一个应用程序调用 WSAStartup 函数时，

		操作系统根据请求的 Socket 版本来搜索相应的 Socket 库，

		然后绑定找到的 Socket 库到该应用程序中。以后应用程序就可以调用所请求的 Socket 库中的其它 Socket 函数了。

		 */

		printf_s("WSAStartup失败.\n"); // 初始化失败

		exit(1);

	}

	SOCKET socketFD = 0;  //socket句柄

	int recvLen = 0;   //接收成功后的返回值

	SOCKET newFD = 0; 	//建立连接后的句柄

	char buf[4096] = { 0 }; //buff缓冲区

	SOCKADDR_IN addrServer, addrClient;

	socketFD = socket(AF_INET, SOCK_STREAM, 0); //建立socket

	if (INVALID_SOCKET == socketFD)

	{

		printf_s("创建socket失败\n");

		printf_s("SOCKET ERROR #%d\n", WSAGetLastError());

		return 0;

	}

	printf_s("创建socket成功\n");

	addrServer.sin_family = AF_INET;  /*该属性表示接收本机或其他机器传输*/

	addrServer.sin_port = htons(PORT); /*端口号*/

	addrServer.sin_addr.S_un.S_addr = inet_addr(serverAddr);/*服务器IP*/

	//连接方法： 传入句柄，目标地址，和大小

	if (0 > connect(socketFD, (SOCKADDR*)&addrServer, sizeof(addrServer)))

	{

		printf_s("连接服务器失败\n");

		printf_s("CONNECT ERROR #%d\n", WSAGetLastError());

	}

	else {

		printf("连接服务器成功\n");

		recv(socketFD, buf, sizeof(buf), 0); ////将接收数据打入buf，参数分别是句柄，储存处，最大长度，其他信息（设为0即可）。 

		printf("Recv:%s\n", buf);

	}

	return 0;

}

运行结果

服务器端

客户端

基于UDP的socket编程

服务器代码

//UDPServer.c

#include <stdio.h>

#include <string.h>

#include "winsock.h"

#include "windows.h"

#pragma comment(lib, "wsock32")

#define PORT 8888	//端口号

#define BACKLOG 5	//最大监听数

int main()

{

	WSADATA wsaData;/*WSADATA 结构被用来保存函数 WSAStartup 返回的 Windows Sockets 初始化信息*/

	if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {

		/*

		使用 Socket 的程序在使用 Socket 之前必须调用 WSAStartup 函数, 当一个应用程序调用 WSAStartup 函数时，

		操作系统根据请求的 Socket 版本来搜索相应的 Socket 库，

		然后绑定找到的 Socket 库到该应用程序中。以后应用程序就可以调用所请求的 Socket 库中的其它 Socket 函数了。

		 */

		printf_s("WSAStartup失败.\n"); // 初始化失败

		exit(1);

	}

	SOCKET socketFD = 0;  //socket句柄

	int bufLen = 0;   //接收成功后的返回值

	char buf[4096] = { 0 }; //buff缓冲区

	int fromLen = sizeof(SOCKADDR);

	SOCKADDR_IN addrServer, addrClient;

	socketFD = socket(AF_INET, SOCK_DGRAM, 0); //建立socket

	if (INVALID_SOCKET == socketFD)

	{

		printf_s("创建socket失败\n");

		printf_s("SOCKET ERROR #%d\n", WSAGetLastError());

		return 0;

	}

	printf_s("创建socket成功\n");

	addrServer.sin_family = AF_INET;  /*该属性表示接收本机或其他机器传输*/

	addrServer.sin_port = htons(PORT); /*端口号*/

	addrServer.sin_addr.S_un.S_addr = htonl(INADDR_ANY); /*IP，括号内容表示本机IP*/

	//绑定地址结构体和socket

	if (bind(socketFD, (SOCKADDR*)&addrServer, sizeof(addrServer)))

	{

		printf_s("绑定失败\n");

		printf_s("BIND ERROR #%d\n", WSAGetLastError());

		return 0;

	}

	printf_s("绑定端口%d成功\n", PORT);

	while (true) {

		bufLen = recvfrom(socketFD, buf, sizeof(buf), 0, (SOCKADDR*)&addrClient, &fromLen);

		if (bufLen < 0) {

			printf_s("RECV ERROR#%d\n", WSAGetLastError());

			continue;

		}

		printf_s("收到来自客户端[%s:%d]的数据报:%s",inet_ntoa(addrClient.sin_addr), ntohs(addrClient.sin_port),buf);

		char send[] = { "服务器接收到客户数据报，这是返回信息" };

		memcpy_s(buf, sizeof(buf), send, sizeof(send));

		bufLen = sendto(socketFD, buf, sizeof(buf), 0, (SOCKADDR*)&addrClient, sizeof(addrClient));

		if (bufLen < 0) {

			printf_s("SEND ERROR#%d\n", WSAGetLastError());

			continue;

		}

	}

	closesocket(socketFD);

	WSACleanup();

	return 0;

}

客户端代码

//UDPClient.c

#include <stdio.h>

#include <string.h>

#include "winsock.h"

#include "windows.h"

#pragma comment(lib, "wsock32")

#define PORT 8888	//端口号

#define BACKLOG 5	//最大监听数

char serverAddr[16] = "192.168.0.3";

int main()

{

	WSADATA wsaData;/*WSADATA 结构被用来保存函数 WSAStartup 返回的 Windows Sockets 初始化信息*/

	if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {

		/*

		使用 Socket 的程序在使用 Socket 之前必须调用 WSAStartup 函数, 当一个应用程序调用 WSAStartup 函数时，

		操作系统根据请求的 Socket 版本来搜索相应的 Socket 库，

		然后绑定找到的 Socket 库到该应用程序中。以后应用程序就可以调用所请求的 Socket 库中的其它 Socket 函数了。

		 */

		printf_s("WSAStartup失败.\n"); // 初始化失败

		exit(1);

	}

	SOCKET socketFD = 0;  //socket句柄

	int bufLen = 0;   //接收成功后的返回值

	char buf[4096] = { 0 }; //buff缓冲区

	int fromLen = sizeof(SOCKADDR);

	SOCKADDR_IN addrServer, addrClient;

	socketFD = socket(AF_INET, SOCK_DGRAM, 0); //建立socket

	if (INVALID_SOCKET == socketFD)

	{

		printf_s("创建socket失败\n");

		printf_s("SOCKET ERROR #%d\n", WSAGetLastError());

		return 0;

	}

	printf_s("创建socket成功\n");

	addrServer.sin_family = AF_INET;  /*该属性表示接收本机或其他机器传输*/

	addrServer.sin_port = htons(PORT); /*端口号*/

	addrServer.sin_addr.S_un.S_addr = inet_addr(serverAddr); /*IP，括号内容表示本机IP*/

	char send[] = "这里是客户端，发送信息给服务器";

	memcpy_s(buf, sizeof(buf), send, sizeof(send));

	bufLen = sendto(socketFD, buf, sizeof(buf), 0, (SOCKADDR*)&addrServer, sizeof(addrServer));

	if (bufLen < 0) {

		printf_s("SEND ERROR#%d\n", WSAGetLastError());

		return 0;

	}

	bufLen= recvfrom(socketFD, buf, sizeof(buf), 0, (SOCKADDR*)&addrClient, &fromLen);

	if (bufLen < 0) {

		printf_s("RECV ERROR#%d\n", WSAGetLastError());

		return 0;

	}

	printf_s("收到来自服务器[%s:%d]的数据报:%s", inet_ntoa(addrClient.sin_addr), ntohs(addrClient.sin_port), buf);

	closesocket(socketFD);

	WSACleanup();

	return 0;

}

运行结果

服务器端



客户端