- 论坛徽章:
- 0
|
我在Redhat9上写了一个sokcet通信的程序，但不会写交互通信，就是send()和recv()同时在服务器和客户端的代码，我想做到服务器和客户端建立连接后自由的会话，就像聊天一样。请会的DX补全代码。大家一起学习进步！服务器端使用了多线程技术，但有些问题。
gcc -g -o socket_server socket_server.c -lpthread
gcc -g -o socket_client socket_client.c
//服务器端代码，socket_server.c
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <sys/wait.h>
#include <pthread.h>
#define SERVPORT 3333 /*服务器监听端口号 */
#define BACKLOG 10 /* 最大同时连接请求数 */
#define MAXDATASIZE 100 /*每次最大数据传输量 */
static void *communicate(void *arg);
pthread_mutex_t mutex;/* 互斥体 */
char buf[MAXDATASIZE];/* 接受缓冲 */
char msg[MAXDATASIZE];/* 发送缓冲 */
main()
{
int sockfd, client_fd; /*sock_fd：监听socket; client_fd：数据传输socket */
pthread_t tid[BACKLOG];/* 线程数组 */
int pthindex = 0;/* 线程索引 */
int sin_size, i;
struct sockaddr_in my_addr; /* 本机地址信息 */
struct sockaddr_in remote_addr; /* 客户端地址信息 */
if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
{
perror("socket创建出错！"); exit(1);
}
my_addr.sin_family=AF_INET;
my_addr.sin_port=htons(SERVPORT);
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);
}
if(listen(sockfd, BACKLOG) == -1)
{
perror("listen出错！");
exit(1);
}
pthread_mutex_init(&mutex, NULL);
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\n", inet_ntoa(remote_addr.sin_addr));
if(pthread_create(&tid[pthindex++], NULL,communicate, (void *)client_fd))
{
perror("创建线程失败!");
exit(1);
}
close(client_fd);
}
for(i=0; i <= pthindex; i++)
{
if(pthread_join( tid[i],NULL ))
{
perror("等待线程结束失败!");
exit(1);
}
}
}
//线程调用函数
static void *communicate(void *arg)
{
/* 子进程代码段 */
int recvbytes; /* 接受数据字节 */
int client_fd = (int)arg;
int i = 0;
while(i++ < 10)
{
if(send(client_fd, "Welcome, you are connected!\n", 26, 0) == -1)
perror("send出错！");
//while(1)
//{ //send message.
//pthread_mutex_lock(&mutex);
//printf("socket server:please input your message.\n");
//scanf("%s", msg);
//printf("server print:%s\n", *msg);
//if(send(client_fd, msg, MAXDATASIZE, 0) == -1)
//perror("send出错！");
//pthread_mutex_unlock(&mutex);
//}
}
close(client_fd);
return NULL;
}
//客户端代码，socket_client.c
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <netdb.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <sys/socket.h>
#define SERVPORT 3333
#define MAXDATASIZE 100 /* 每次最大数据传输量 */
main(int argc, char *argv[])
{
int sockfd, recvbytes;
char buf[MAXDATASIZE];
struct hostent *host;
struct sockaddr_in serv_addr;
char msg[MAXDATASIZE];
char szexit[4];//用来匹配"exit"的字符串
if(argc < 2)
{
fprintf(stderr,"Please enter the server's hostname!\n");
exit(1);
}
if((host=gethostbyname(argv[1]))==NULL)
{
herror("gethostbyname出错！");
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(SERVPORT);
serv_addr.sin_addr = *((struct in_addr *)host->h_addr);
bzero(&(serv_addr.sin_zero),8);/* memset(&serv_addr.sin_zero,0,8); */
if(connect(sockfd, (struct sockaddr *)&serv_addr, sizeof(struct sockaddr)) == -1)
{
perror("connect出错！");
exit(1);
}
while(1)
{
//receive message.
if((recvbytes=recv(sockfd, buf, MAXDATASIZE, 0)) ==-1)
{
perror("recv出错！");
exit(1);
}
buf[recvbytes] = '\0';
if(recvbytes > 0)
printf("Received: %s\n",buf);
}
close(sockfd);
}
[[i] 本帖最后由 willing_wlmq 于 2005-12-15 12:57 编辑 [/i]] |
|
免费注册
发表于 2005-12-15 12:55
