原文:
Linux 下 简单客户端服务器通讯模型(TCP)
服务器端：server.c
#include<stdio.h>
#include
<stdlib.h>
#include
<errno.h>
#include
<
string
.h>
#include
<sys/socket.h>
#include
<sys/types.h>
#include
<stdio.h>
#include
<unistd.h>
#include
<netdb.h>
#include
<netinet/
in
.h>
#define
ServerPort 6080
#define
MaxUser 8
typedef
struct
_server{
int
sock_fd;
int
new_fd;
struct
sockaddr_in my_addr;
} Server;
typedef
struct
_client{
int
sock_fd;
struct
sockaddr_in my_addr;
} Client;
static
Server *
server;
static
Client *
client;
void
socket_server_init(Server *
server){
server
-> my_addr.sin_family =
AF_INET;
server
-> my_addr.sin_port =
htons(ServerPort);
server
-> my_addr.sin_addr.s_addr =
INADDR_ANY;
bzero(
&(server -> my_addr.sin_zero),
8
);
}
int
socket_server_create_bind_listen(Server *
server){
int
sin_size,ret, on;
if
((server -> sock_fd = socket(AF_INET,SOCK_STREAM,
0
)) == -
1
){
perror(
"
faild to create socket :\n
"
);
return
-
1
;
}
on
=
1
;
ret
= setsockopt( server -> sock_fd, SOL_SOCKET, SO_REUSEADDR, &on,
sizeof
(on) );
if
(ret=bind(server ->
sock_fd,
(
struct
sockaddr *)&server ->
my_addr,
sizeof
(
struct
sockaddr))==-
1
){
perror(
"
failed to bind \n
"
);
return
-
1
;
}
if
(listen(server -> sock_fd,MaxUser)==-
1
){
perror(
"
failed to listen \n
"
);
return
-
1
;
}
return
1
;
}
void
server_send_msg(
int
fd){
char
buff[
1024
];
while
(
1
){
fgets(buff,
1024
,stdin);
if
(send(fd,buff,
1024
,
0
)==-
1
){
perror(
"
error to send :
"
);
break
;
}
}
}
void
server_wait_service(Server *server,Client *
client){
int
new_fd ,ret,sin_size;
char
buf[
1024
];
pthread_t tid;
sin_size
=
sizeof
(client ->
my_addr);
new_fd
= accept(server ->sock_fd,(
struct
sockaddr *)&client->my_addr,&
sin_size);
if
(new_fd <=
0
){
perror(
"
accept error :
"
);
}
else
{
ret
= pthread_create(&
tid,NULL,server_send_msg,new_fd);
if
(ret!=
0
){
perror(
"
error to create pthread
"
);
}
while
(
1
){
if
(recv(new_fd,buf,
sizeof
(buf),
0
)>
0
){
printf(
"
\nclient said:\t\t%s\n
"
,buf);
}
}
}
}
int
main(
int
arg,
char
*
argv[]){
server
= (Server *)malloc(
sizeof
(Server));
client
= (Client *)malloc(
sizeof
(Client));
socket_server_init(server);
if
(socket_server_create_bind_listen(server)){
server_wait_service(server,client);
}
return
0
;
}
客户端代码：client.c
#include<stdio.h>
#include
<stdlib.h>
#include
<errno.h>
#include
<
string
.h>
#include
<sys/socket.h>
#include
<sys/types.h>
#include
<stdio.h>
#include
<netdb.h>
#define
ServerPort 6080
typedef
struct
_server{
int
sock_fd;
int
new_fd;
struct
sockaddr_in my_addr;
} Server;
typedef
struct
_client{
int
sock_fd;
struct
sockaddr_in my_addr;
} Client;
Server
*
server;
Client
*
client;
void
socket_server_init(Server *
server){
server
-> my_addr.sin_family =
AF_INET;
server
-> my_addr.sin_port =
htons(ServerPort);
server
-> my_addr.sin_addr.s_addr =
INADDR_ANY;
bzero(
&(server -> my_addr.sin_zero),
8
);
}
void
socket_client_init(Client *
client){
client
-> my_addr.sin_family =
AF_INET;
client
-> my_addr.sin_port = htons(ServerPort+
10
);
client
-> my_addr.sin_addr.s_addr =
INADDR_ANY;
bzero(
&(client -> my_addr.sin_zero),
8
);
}
int
socket_client_create_connect(Server * server,Client *
client){
if
((client -> sock_fd = socket(AF_INET,SOCK_STREAM,
0
)) == -
1
){
perror(
"
failed to create client socket \n
"
);
return
-
1
;
}
else
if
(connect(client ->
sock_fd,
(
struct
sockaddr *)&server ->
my_addr,
sizeof
(server ->my_addr))==-
1
){
printf(
"
failed to connect the server \n
"
);
return
-
1
;
}
else
return
1
;
}
void
client_recv_msg(Client *
client){
char
buf[
1024
];
while
(
1
){
if
(recv(client->sock_fd,buf,
sizeof
(buf),
0
)>
0
){
printf(
"
\nserver said :\t\t%s\n
"
,buf);
}
else
break
;
}
}
int
main(
int
argc,
char
*
argv[]){
server
= (Server *)malloc(
sizeof
(Server));
client
= (Client *)malloc(
sizeof
(Client));
char
data[
1024
];
socket_server_init(server);
socket_client_init(client);
pthread_t tid;
if
(socket_client_create_connect(server,client)){
pthread_create(
&
tid, NULL,client_recv_msg, client);
while
(
1
){
fgets(data,
1024
,stdin);
if
(send(client->sock_fd,data,
1024
,
0
)==-
1
){
perror(
"
error to send :
"
);
break
;
}
}
}
return
0
;
}
Makefile:
all: server client
server: server.c
gcc
-o server server.c -
pthread
client: client.c
gcc
-o client client.c -
pthread
clean:
rm
-f server client
执行效果：
server:
root@ubuntu:/mnt/hgfs/E/Lessons/个人总结/chat# ./server
client said: hello
hehe
client said: g
client said: goodbay
client:
root@ubuntu:/mnt/hgfs/E/Lessons/个人总结/chat# ./client
hello
server said : hehe
s^Hg
goodbay
去年的代码，做个备份。
