基于C/S模式的简单聊天程序

该简单聊天程序采用了C/S模式，即客户端/服务器模式。客户端通过与服务器建立连接，实现与其他客户端的聊天交流。

服务器端程序：

1. 建立服务器端socket，监听客户端连接请求。

2. 接收客户端连接请求，并建立连接。

3. 接收客户端发来的消息，广播给所有已连接的客户端。

4. 关闭连接。

客户端程序：

1. 建立客户端socket，连接服务器。

2. 发送消息给服务器。

3. 接收服务器广播的消息，显示在客户端界面上。

4. 关闭连接。

下面是服务器端程序的实现：

#include <stdio.h>  
#include <stdlib.h>  
#include <string.h>  
#include <unistd.h>  
#include <sys/types.h>  
#include <sys/socket.h>  
#include <netinet/in.h>  
#include <arpa/inet.h>  
  
#define PORT 1234  
#define BACKLOG 5  
#define MAXDATASIZE 100  
  
int main()  
{  
    int sockfd, client_fd;             
    struct sockaddr_in my_addr;         
    struct sockaddr_in remote_addr;     
    int sin_size;  
    char buf[MAXDATASIZE];  
    int recvbytes;  
  
    if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {  
        perror("socket");  
        exit(1);  
    }  
    printf("socket success!,sockfd=%d\n",sockfd);  
  
    my_addr.sin_family = AF_INET;         
    my_addr.sin_port = htons(PORT);     
    my_addr.sin_addr.s_addr = INADDR_ANY; 
    bzero(&(my_addr.sin_zero), 8);  
  
    if (bind(sockfd, (struct sockaddr *)&my_addr, sizeof(struct sockaddr))== -1) {  
        perror("bind");  
        exit(1);  
    }  
    printf("bind success!\n");  
  
    if (listen(sockfd, BACKLOG) == -1) {  
        perror("listen");  
        exit(1);  
    }  
    printf("listening....\n");  
  
    while(1) {  
        sin_size = sizeof(struct sockaddr_in);  
        if ((client_fd = accept(sockfd, (struct sockaddr *)&remote_addr, &sin_size)) == -1) {  
            perror("accept");  
            continue;  
        }  
        printf("received a connection from %s:%d\n", inet_ntoa(remote_addr.sin_addr), ntohs(remote_addr.sin_port));  
        if (!fork()) {  
            if (send(client_fd, "Welcome to my server\n", 22, 0) == -1)  
                perror("send");  
            while (recvbytes=recv(client_fd, buf, MAXDATASIZE, 0)) {  
                buf[recvbytes] = '\0';  
                printf("received a message from %s:%d :%s\n", inet_ntoa(remote_addr.sin_addr), ntohs(remote_addr.sin_port), buf);  
                if (send(client_fd, buf, recvbytes, 0) == -1)  
                    perror("send");  
            }  
            close(client_fd);  
            exit(0);  
        }  
        close(client_fd);  
    }  
    close(sockfd);  
    return 0;  
}  

下面是客户端程序的实现：

#include <stdio.h>  
#include <stdlib.h>  
#include <string.h>  
#include <unistd.h>  
#include <sys/types.h>  
#include <sys/socket.h>  
#include <netinet/in.h>  
#include <arpa/inet.h>  
  
#define PORT 1234  
#define MAXDATASIZE 100  
  
int main(int argc, char *argv[])  
{  
    int sockfd, recvbytes;  
    char buf[MAXDATASIZE];  
    struct sockaddr_in serv_addr;  
  
    if (argc < 2) {  
        fprintf(stderr, "Please enter the server's hostname!\n");  
        exit(1);  
    }  
  
    if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {  
        perror("socket");  
        exit(1);  
    }  
  
    serv_addr.sin_family = AF_INET;  
    serv_addr.sin_port = htons(PORT);  
    serv_addr.sin_addr.s_addr = inet_addr(argv[1]);  
    bzero(&(serv_addr.sin_zero), 8);  
  
    if (connect(sockfd, (struct sockaddr *)&serv_addr, sizeof(struct sockaddr)) == -1) {  
        perror("connect");  
        exit(1);  
    }  
  
    if ((recvbytes=recv(sockfd, buf, MAXDATASIZE, 0)) == -1) {  
        perror("recv");  
        exit(1);  
    }  
    buf[recvbytes] = '\0';  
    printf("%s", buf);  
  
    while(1){  
        printf("Enter message to send:\n");  
        fgets(buf, MAXDATASIZE, stdin);  
        if (send(sockfd, buf, strlen(buf), 0) == -1) {  
            perror("send");  
            exit(1);  
        }  
        if ((recvbytes = recv(sockfd, buf, MAXDATASIZE, 0)) == -1) {  
            perror("recv");  
            exit(1);  
        }  
        buf[recvbytes] = '\0';  
        printf("Received: %s",buf);  
    }  
    close(sockfd);  
    return 0;  
}  

运行服务器端程序后，服务器会一直监听客户端请求。运行客户端程序，输入服务器的IP地址，即可与服务器建立连接，开始聊天。