用c语言编写一个聊天服务器和聊天的客户端,实现基本的即时聊天功能。服务器在一个端口上进行监听,接收客户端的连接请求;客户端连接到服务器,发布自己的消息;服务器接收客户端的消息并转发给其他客户端。可以是tcp
时间: 2024-03-16 08:45:51 浏览: 47
(续上)
客户端代码:
```c
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <pthread.h>
#define PORT 8888
#define BUFFER_SIZE 1024
int sock_fd;
char username[20];
void *recv_thread(void *arg)
{
char buffer[BUFFER_SIZE] = {0};
while (1)
{
int valread = read(sock_fd, buffer, BUFFER_SIZE);
if (valread <= 0)
{
printf("Server disconnected\n");
exit(EXIT_SUCCESS);
}
printf("%s\n", buffer);
memset(buffer, 0, BUFFER_SIZE);
}
}
int main(int argc, char *argv[])
{
struct sockaddr_in serv_addr;
char buffer[BUFFER_SIZE] = {0};
pthread_t thread_id;
// 创建套接字
if ((sock_fd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
{
perror("socket creation error");
exit(EXIT_FAILURE);
}
// 设置服务器地址
memset(&serv_addr, '0', sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_port = htons(PORT);
// 将IP地址从文本转换为二进制
if (inet_pton(AF_INET, "127.0.0.1", &serv_addr.sin_addr) <= 0)
{
perror("invalid address");
exit(EXIT_FAILURE);
}
// 连接服务器
if (connect(sock_fd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0)
{
perror("connection failed");
exit(EXIT_FAILURE);
}
// 获取用户名
printf("Enter your username: ");
fgets(username, 20, stdin);
username[strcspn(username, "\n")] = 0;
sprintf(buffer, "%s has joined the chatroom", username);
send(sock_fd, buffer, strlen(buffer), 0);
// 创建接收线程
pthread_create(&thread_id, NULL, recv_thread, NULL);
// 发送消息
while (1)
{
fgets(buffer, BUFFER_SIZE, stdin);
buffer[strcspn(buffer, "\n")] = 0;
sprintf(buffer, "%s: %s", username, buffer);
send(sock_fd, buffer, strlen(buffer), 0);
}
return 0;
}
```
以上代码实现了一个简单的聊天程序,可以实现客户端和服务器之间的即时聊天。需要注意的是,该代码只是一个简单的示例,实际使用时需要考虑更多的细节和异常处理。
阅读全文