用c语言中写出客户端和服务端代码利用udp协议引入txt文档进行机器人一问一答,而不是直接把文档的所有内容打印出来。
时间: 2024-01-22 08:17:20 浏览: 112
C语言编写的、用UDP传送的客户、服务端
3星 · 编辑精心推荐
以下是一个简单的使用UDP协议实现机器人一问一答的客户端和服务端代码,其中机器人的问题和答案存储在一个txt文件中,每次客户端发送一个问题给服务端,服务端会在txt文件中查找对应的答案并返回给客户端。注意,此代码仅为演示用途,实际应用需要加入更多的错误处理和安全性检查。
## 服务端代码
```c
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <fcntl.h>
#define BUF_SIZE 1024
#define SERVER_PORT 8888
void error_handling(char *message);
int main(int argc, char *argv[])
{
int serv_sock;
char buf[BUF_SIZE];
struct sockaddr_in serv_addr, clnt_addr;
socklen_t clnt_addr_size;
int str_len;
// 打开问题答案txt文件
int fd = open("qa.txt", O_RDONLY);
if (fd < 0) {
error_handling("open() error");
}
// 创建UDP套接字
serv_sock = socket(PF_INET, SOCK_DGRAM, 0);
if (serv_sock == -1) {
error_handling("socket() error");
}
// 初始化服务器地址结构体
memset(&serv_addr, 0, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
serv_addr.sin_port = htons(SERVER_PORT);
// 绑定套接字和地址
if (bind(serv_sock, (struct sockaddr*)&serv_addr, sizeof(serv_addr)) == -1) {
error_handling("bind() error");
}
while (1) {
clnt_addr_size = sizeof(clnt_addr);
// 接收客户端发送的问题
str_len = recvfrom(serv_sock, buf, BUF_SIZE, 0, (struct sockaddr*)&clnt_addr, &clnt_addr_size);
if (str_len == -1) {
error_handling("recvfrom() error");
}
// 在txt文件中查找对应的答案
char question[BUF_SIZE];
strncpy(question, buf, str_len);
lseek(fd, 0, SEEK_SET);
char line[BUF_SIZE], *answer = NULL;
while (read(fd, line, BUF_SIZE) > 0) {
if (strncmp(question, line, str_len) == 0 && line[str_len] == ':') {
answer = line + str_len + 1;
break;
}
}
// 发送答案给客户端
if (answer == NULL) {
strcpy(buf, "Sorry, I don't know the answer.");
str_len = strlen(buf);
} else {
strncpy(buf, answer, BUF_SIZE);
str_len = strlen(answer);
}
if (sendto(serv_sock, buf, str_len, 0, (struct sockaddr*)&clnt_addr, clnt_addr_size) == -1) {
error_handling("sendto() error");
}
}
close(serv_sock);
close(fd);
return 0;
}
void error_handling(char *message)
{
fputs(message, stderr);
fputc('\n', stderr);
exit(1);
}
```
## 客户端代码
```c
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#define BUF_SIZE 1024
#define SERVER_PORT 8888
void error_handling(char *message);
int main(int argc, char *argv[])
{
int sock;
char buf[BUF_SIZE];
struct sockaddr_in serv_addr;
socklen_t serv_addr_size;
int str_len;
// 创建UDP套接字
sock = socket(PF_INET, SOCK_DGRAM, 0);
if (sock == -1) {
error_handling("socket() error");
}
// 初始化服务器地址结构体
memset(&serv_addr, 0, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
serv_addr.sin_port = htons(SERVER_PORT);
while (1) {
// 从标准输入读取问题
fputs("Input question(Q to quit): ", stdout);
fgets(buf, BUF_SIZE, stdin);
if (strcmp(buf, "q\n") == 0 || strcmp(buf, "Q\n") == 0) {
break;
}
// 发送问题给服务器
str_len = sendto(sock, buf, strlen(buf), 0, (struct sockaddr*)&serv_addr, sizeof(serv_addr));
if (str_len == -1) {
error_handling("sendto() error");
}
// 接收服务器返回的答案
serv_addr_size = sizeof(serv_addr);
str_len = recvfrom(sock, buf, BUF_SIZE, 0, (struct sockaddr*)&serv_addr, &serv_addr_size);
if (str_len == -1) {
error_handling("recvfrom() error");
}
buf[str_len] = 0;
printf("Answer: %s\n", buf);
}
close(sock);
return 0;
}
void error_handling(char *message)
{
fputs(message, stderr);
fputc('\n', stderr);
exit(1);
}
```
阅读全文