用C语言实现利用TCP协议编写一个简单的文件服务器和客户端。 支持功能: 1. list:列表远端目录下的文件和目录信息(目录用方括号括起以示区分) 2. pwd: 查看远端当前目录 3. lpwd: 查看本地当前目录 4. cd xxxxx: 切换远端当前目录为xxxxx 5. lcd xxxxx: 切换本地当前目录为xxxxx 6. down xxxxx: 下载远端当前目录下的文件xxxxx到客户端的当前目录下 7. exit:断开连接并退出。
时间: 2023-07-14 15:14:28 浏览: 60
以下是基于TCP协议的简单文件服务器和客户端的代码实现,使用的是C语言:
服务器端代码:
```
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <dirent.h>
#define PORT 8888
#define MAX_SIZE 1024
int main()
{
int server_fd, new_socket;
struct sockaddr_in server_addr, client_addr;
int addr_len = sizeof(client_addr);
char buffer[MAX_SIZE] = {0};
char cwd[MAX_SIZE] = {0};
DIR *dir;
struct dirent *entry;
//创建套接字
if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0)
{
perror("socket failed");
exit(EXIT_FAILURE);
}
//设置地址重用
int opt = 1;
if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt)))
{
perror("setsockopt failed");
exit(EXIT_FAILURE);
}
//绑定地址
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = INADDR_ANY;
server_addr.sin_port = htons(PORT);
if (bind(server_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0)
{
perror("bind failed");
exit(EXIT_FAILURE);
}
//监听连接
if (listen(server_fd, 3) < 0)
{
perror("listen failed");
exit(EXIT_FAILURE);
}
//等待连接请求
printf("Server started. Waiting for connections...\n");
while (1)
{
if ((new_socket = accept(server_fd, (struct sockaddr *)&client_addr, (socklen_t *)&addr_len)) < 0)
{
perror("accept failed");
exit(EXIT_FAILURE);
}
printf("Connection established from %s:%d\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
//处理客户端请求
while (1)
{
memset(buffer, 0, MAX_SIZE);
int valread = read(new_socket, buffer, MAX_SIZE);
if (valread <= 0)
break;
if (strcmp(buffer, "list") == 0)
{
memset(buffer, 0, MAX_SIZE);
dir = opendir(cwd);
if (dir != NULL)
{
while ((entry = readdir(dir)) != NULL)
{
if (entry->d_type == DT_DIR)
sprintf(buffer + strlen(buffer), "[%s]\n", entry->d_name);
else
sprintf(buffer + strlen(buffer), "%s\n", entry->d_name);
}
closedir(dir);
}
else
{
sprintf(buffer, "Error: Failed to open directory.\n");
}
write(new_socket, buffer, strlen(buffer));
}
else if (strcmp(buffer, "pwd") == 0)
{
memset(buffer, 0, MAX_SIZE);
getcwd(buffer, MAX_SIZE);
strcat(buffer, "\n");
write(new_socket, buffer, strlen(buffer));
}
else if (strncmp(buffer, "cd", 2) == 0)
{
char *path = strtok(buffer + 3, "\n");
if (chdir(path) < 0)
{
sprintf(buffer, "Error: Failed to change directory.\n");
}
else
{
sprintf(buffer, "Directory changed to %s\n", path);
}
write(new_socket, buffer, strlen(buffer));
}
else if (strcmp(buffer, "exit") == 0)
{
close(new_socket);
printf("Connection closed from %s:%d\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
break;
}
else
{
sprintf(buffer, "Error: Invalid command.\n");
write(new_socket, buffer, strlen(buffer));
}
}
}
return 0;
}
```
客户端代码:
```
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#define PORT 8888
#define MAX_SIZE 1024
int main()
{
int sock = 0;
struct sockaddr_in serv_addr;
char buffer[MAX_SIZE] = {0};
char cwd[MAX_SIZE] = {0};
char input[MAX_SIZE] = {0};
//创建套接字
if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0)
{
perror("socket failed");
exit(EXIT_FAILURE);
}
//设置服务器信息
serv_addr.sin_family = AF_INET;
serv_addr.sin_port = htons(PORT);
if (inet_pton(AF_INET, "127.0.0.1", &serv_addr.sin_addr) <= 0)
{
perror("invalid address");
exit(EXIT_FAILURE);
}
//连接服务器
if (connect(sock, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0)
{
perror("connection failed");
exit(EXIT_FAILURE);
}
printf("Connected to server.\n");
//处理用户输入
while (1)
{
printf("> ");
fgets(input, MAX_SIZE, stdin);
input[strlen(input) - 1] = '\0';
if (strcmp(input, "list") == 0)
{
write(sock, input, strlen(input));
memset(buffer, 0, MAX_SIZE);
read(sock, buffer, MAX_SIZE);
printf("%s", buffer);
}
else if (strcmp(input, "pwd") == 0)
{
write(sock, input, strlen(input));
memset(buffer, 0, MAX_SIZE);
read(sock, buffer, MAX_SIZE);
printf("%s", buffer);
}
else if (strncmp(input, "cd", 2) == 0)
{
write(sock, input, strlen(input));
memset(buffer, 0, MAX_SIZE);
read(sock, buffer, MAX_SIZE);
printf("%s", buffer);
}
else if (strcmp(input, "exit") == 0)
{
write(sock, input, strlen(input));
close(sock);
printf("Disconnected from server.\n");
break;
}
else
{
printf("Error: Invalid command.\n");
}
}
return 0;
}
```
运行程序,在服务器端输入“./server”启动服务器,客户端输入“./client”连接服务器,输入相应命令进行文件操作。
相关推荐
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![rar](https://img-home.csdnimg.cn/images/20210720083606.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)