编程实现视频网络传输:利用socket接口,实现压缩视频的网络传输,用tcp协议,分别写出客户端与服务器端代码,C++
时间: 2024-01-01 12:03:47 浏览: 42
以下是一个利用socket接口,实现压缩视频的网络传输的C++示例代码,分别是客户端和服务器端的代码,使用TCP协议进行传输:
客户端代码:
```c++
#include <iostream>
#include <fstream>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
using namespace std;
int main(int argc, char *argv[]) {
// 创建socket
int sock = socket(AF_INET, SOCK_STREAM, 0);
if (sock == -1) {
cout << "Failed to create socket" << endl;
return 1;
}
// 服务器地址信息
struct sockaddr_in server_addr;
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = inet_addr("127.0.0.1"); // 服务器IP地址
server_addr.sin_port = htons(8888); // 服务器端口号
// 连接服务器
if (connect(sock, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
cout << "Failed to connect to server" << endl;
return 1;
}
// 打开压缩后的视频文件
ifstream video_file("compressed_video.mp4", ios::in | ios::binary);
if (!video_file.is_open()) {
cout << "Failed to open video file" << endl;
return 1;
}
// 循环读取视频数据并发送
char buffer[1024];
while (!video_file.eof()) {
video_file.read(buffer, sizeof(buffer));
int len = video_file.gcount();
if (len > 0) {
if (send(sock, buffer, len, 0) != len) {
cout << "Failed to send video data" << endl;
return 1;
}
}
}
// 关闭文件和socket
video_file.close();
close(sock);
return 0;
}
```
服务器端代码:
```c++
#include <iostream>
#include <fstream>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
using namespace std;
int main(int argc, char *argv[]) {
// 创建socket
int server_sock = socket(AF_INET, SOCK_STREAM, 0);
if (server_sock == -1) {
cout << "Failed to create socket" << endl;
return 1;
}
// 绑定IP地址和端口号
struct sockaddr_in server_addr;
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = htonl(INADDR_ANY); // 服务器IP地址
server_addr.sin_port = htons(8888); // 服务器端口号
if (bind(server_sock, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
cout << "Failed to bind to port" << endl;
return 1;
}
// 监听连接请求
if (listen(server_sock, 1) < 0) {
cout << "Failed to listen to socket" << endl;
return 1;
}
// 接受连接请求
struct sockaddr_in client_addr;
socklen_t client_addr_len = sizeof(client_addr);
int client_sock = accept(server_sock, (struct sockaddr *)&client_addr, &client_addr_len);
if (client_sock < 0) {
cout << "Failed to accept client connection" << endl;
return 1;
}
// 打开视频文件
ofstream video_file("received_video.mp4", ios::out | ios::binary);
if (!video_file.is_open()) {
cout << "Failed to open video file" << endl;
return 1;
}
// 循环接收视频数据并写入文件
char buffer[1024];
while (true) {
int len = recv(client_sock, buffer, sizeof(buffer), 0);
if (len <= 0) {
break;
}
video_file.write(buffer, len);
}
// 关闭文件和socket
video_file.close();
close(client_sock);
close(server_sock);
return 0;
}
```
在上述代码中,我们首先分别在客户端和服务器端创建了TCP socket,并连接到服务器或者绑定本地IP地址和端口号,并开始监听连接请求。接下来,在客户端我们打开压缩后的视频文件,并循环读取视频数据并发送到服务器,在服务器端我们打开要保存接收到的视频数据的文件,并循环接收数据并写入到文件中。最后,我们关闭了文件和socket。