``` SOCK_STREAM ```#define INVALID_SOCKET (SOCKET)(~0) #define SOCKET_ERROR (-1)
时间: 2024-05-25 12:08:36 浏览: 172
`SOCK_STREAM`是一种基于TCP协议的面向连接的流式套接字类型,它提供了可靠的、双向的、面向连接的数据传输服务,常用于应用程序之间的数据交换和通信。与`SOCK_STREAM`相对应的还有`SOCK_DGRAM`类型,它是一种基于UDP协议的无连接的数据传输服务,常用于实时通信和广播等场景。
另外,`INVALID_SOCKET`是一个无效的socket句柄值,用于标识一个无效的socket对象;`SOCKET_ERROR`则表示一个函数返回失败的状态值,通常在调用socket相关函数时用于判断操作是否成功。
相关问题
#define _WINSOCK_DEPRECATED_NO_WARNINGS#include <stdio.h>#include <Winsock2.h>#ifndef MSG_NOSIGNAL#define MSG_NOSIGNAL 0#endif#pragma comment(lib,"ws2_32.lib")int main() { WORD wVersionRequested; WSADATA wsaData; int err; wVersionRequested = MAKEWORD(2, 2); err = WSAStartup(wVersionRequested, &wsaData); if (err != 0) { return 1; } if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2) { WSACleanup(); return 1; } SOCKET sockSrv = socket(AF_INET, SOCK_STREAM, 0); int optval = 1; setsockopt(sockSrv, SOL_SOCKET, SO_REUSEADDR, (const char*)&optval, sizeof(optval)); SOCKADDR_IN addrSrv; addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY); addrSrv.sin_family = AF_INET; addrSrv.sin_port = htons(6000); bind(sockSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR)); listen(sockSrv, 5); SOCKADDR_IN addrClient; int len = sizeof(SOCKADDR); SOCKET sockConn = INVALID_SOCKET; fd_set fdReads; while (1) { // 使用 select() 函数实现非阻塞接收客户端连接 FD_ZERO(&fdReads); FD_SET(sockSrv, &fdReads); int ret = select(sockSrv + 1, &fdReads, NULL, NULL, NULL); if (ret < 0) { break; } if (FD_ISSET(sockSrv, &fdReads)) { sockConn = accept(sockSrv, (SOCKADDR*)&addrClient, &len); char sendBuf[50] = { 0 }; sprintf(sendBuf, "Welcome %s to here!\n", inet_ntoa(addrClient.sin_addr)); send(sockConn, sendBuf, strlen(sendBuf) + 1, MSG_NOSIGNAL); } // 使用 select() 函数实现非阻塞接收客户端消息 FD_ZERO(&fdReads); if (sockConn != INVALID_SOCKET) { FD_SET(sockConn, &fdReads); } ret = select(sockConn + 1, &fdReads, NULL, NULL, NULL); if (ret < 0) { break; } if (FD_ISSET(sockConn, &fdReads)) { char recvBuf[50] = { 0 }; recv(sockConn, recvBuf, 50, 0); printf("Received from client: %s\n", recvBuf); // 将客户端发送的消息广播给所有连接的客户端 for (SOCKET i = 0; i < FD_SETSIZE; i++) { if (FD_ISSET(i, &fdReads)) { send(i, recvBuf, strlen(recvBuf) + 1, MSG_NOSIGNAL); } } } } closesocket(sockSrv); WSACleanup(); return 0;}
这是一个使用Winsock2库编写的TCP服务器代码,其主要功能是监听来自客户端的TCP连接并接收和转发客户端发送的消息。具体来说,代码实现了以下步骤:
1. 初始化Winsock2库,并创建一个TCP socket对象。
2. 将socket对象绑定到本地IP地址和端口号上,并开始监听来自客户端的连接请求。
3. 使用select()函数实现非阻塞接收客户端连接,并在连接建立时向客户端发送欢迎消息。
4. 使用select()函数实现非阻塞接收来自已连接的客户端的消息,并将其广播给所有其他已连接的客户端。
5. 在程序结束时关闭socket对象并释放Winsock2库资源。
总体来说,这段代码实现了一个简单的TCP聊天室的功能。
修改以下代码将视屏发送给服务端并将视频保存到本地#define _CRT_SECURE_NO_WARNINGS #include<iostream> #include <sstream> #include<string> #include <fstream> #include <vector> #include<winsock.h> #pragma
注:为了确保代码的正确性和安全性,以下是修改后的代码:
```cpp
#define _CRT_SECURE_NO_WARNINGS
#include <iostream>
#include <sstream>
#include <string>
#include <fstream>
#include <vector>
#include <winsock.h>
#pragma comment(lib,"ws2_32.lib")
void SaveVideo(const std::string& filePath, const std::vector<char>& videoData) {
std::ofstream file(filePath, std::ios::out | std::ios::binary);
if (file.is_open()) {
file.write(videoData.data(), videoData.size());
file.close();
std::cout << "Video saved successfully." << std::endl;
}
else {
std::cerr << "Failed to save video." << std::endl;
}
}
int main() {
WSADATA wsaData;
if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {
std::cerr << "Failed to initialize winsock." << std::endl;
return 1;
}
SOCKET clientSocket = socket(AF_INET, SOCK_STREAM, 0);
if (clientSocket == INVALID_SOCKET) {
std::cerr << "Failed to create socket." << std::endl;
WSACleanup();
return 1;
}
sockaddr_in serverAddress{};
serverAddress.sin_family = AF_INET;
serverAddress.sin_port = htons(12345); // 修改为服务端的端口号
serverAddress.sin_addr.s_addr = inet_addr("127.0.0.1"); // 修改为服务端的IP地址
if (connect(clientSocket, reinterpret_cast<sockaddr*>(&serverAddress), sizeof(serverAddress)) != 0) {
std::cerr << "Failed to connect to the server." << std::endl;
closesocket(clientSocket);
WSACleanup();
return 1;
}
std::string filePath = "video.mp4"; // 修改为要保存的视频文件路径
std::ifstream file(filePath, std::ios::in | std::ios::binary);
if (file.is_open()) {
std::vector<char> videoData((std::istreambuf_iterator<char>(file)), std::istreambuf_iterator<char>());
file.close();
// 发送视频数据到服务端
if (send(clientSocket, videoData.data(), videoData.size(), 0) == SOCKET_ERROR) {
std::cerr << "Failed to send video data." << std::endl;
}
else {
std::cout << "Video data sent successfully." << std::endl;
}
// 保存视频到本地
SaveVideo("received_video.mp4", videoData);
}
else {
std::cerr << "Failed to open video file." << std::endl;
}
closesocket(clientSocket);
WSACleanup();
return 0;
}
```
请确保以下几点:
1. 修改 `serverAddress.sin_port` 为服务端的端口号。
2. 修改 `serverAddress.sin_addr.s_addr` 为服务端的IP地址。
3. 修改 `filePath` 为要保存的视频文件路径。
4. 确保链接了 `ws2_32.lib` 库。
注意:这是一个简单的示例代码,仅展示了如何将视频数据发送到服务端并将其保存到本地。实际情况可能需要进行更多的错误处理和安全性考虑。
阅读全文