TCP回射客户服务器模型(01 socket bind listen accept connect)

socket函数(安装电话机)
头文件:#include<sys/socket.h>
  int socket(int family,  int type, int protocol); //返回套接字描述符sockfd, 失败返回-1
参数

1、family:协议族PF_INET/AF_INET
2、type:套接字类型,流式套接字SOCK_STREAM,数据报套接字SOCK_DGRAM,原始套接字SOCK_RAW
3、protocol:协议类型(TCP/UDP/SCTP)

  bind函数:(绑定号码) int  bind(int sockfd , const struct sockaddr* addr , socklen_t  addrlen); //sockfd 参数是socket函数返回的套接字,addr要绑定的地址,地址长度
  listen函数:把一个未连接套接字转换成被动套接字   int listen(int sockfd , int backlog); //backlog 规定内核为此套接字排队的最大连接数。(已完成+未完成)

TCP回射客户服务器模型(01 socket bind listen accept connect)

  accept函数:用于从已完成连接队头返回第一个连接,如果已完成连接队列为空,则阻塞。

int  accept(int sockfd, strcut sockaddr* addr , socklen_t  addrlen); //  addr将返回对等方的套接字,addrlen:对等方地址长度

  最基本的回射客户程序实例,客户端从标准输入读取消息,然后写到已连接套接字,服务器收到后又将这些数据回射回来。

TCP回射客户服务器模型(01 socket bind listen accept connect)

首先是这个服务器程序的编写

#include<unistd.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<string.h>
#include<stdlib.h>
#include<stdio.h>
#include<errno.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#define ERR_EXIT(m)\
do\
{\
perror(m);\
exit(EXIT_FAILURE);\
}while(0)
int main(void)
{
int listenfd;
if((listenfd=socket(PF_INET,SOCK_STREAM,IPPROTO_TCP))<0)
ERR_EXIT("socket error");
//if((listenfd=socket(PF_INET,SOCK_STREAM,0))<0) struct sockaddr_in servaddr;//本地协议地址赋给一个套接字
memset(&servaddr,0,sizeof(servaddr));
servaddr.sin_family=AF_INET;
servaddr.sin_port=htons(5188);
servaddr.sin_addr.s_addr=htonl(INADDR_ANY);//表示本机任意地址
//servaddr.sin_addr.s_addr=inet_addr("127.0.0.1");
//inet_aton("127.0.0.1",&servaddr.sin_addr); if(bind(listenfd,(struct sockaddr*)&servaddr,sizeof(servaddr))<0)
ERR_EXIT("bind error");
if(listen(listenfd,SOMAXCONN)<0)//设置监听套接字(变为被动套接字)
ERR_EXIT("listen error"); struct sockaddr_in peeraddr;//对方套接字地址
socklen_t peerlen=sizeof(peeraddr);//一定要有初始值,否则accept会失败
int conn;//已连接套接字(主动套接字)
if((conn=accept(listenfd,(struct sockaddr*)&peeraddr,&peerlen))<0)
ERR_EXIT("accept error"); char recvbuf[1024];
while(1)
{
memset(recvbuf,0,sizeof(recvbuf));
int ret=read(conn,recvbuf,sizeof(recvbuf));
fputs(recvbuf,stdout);
write(conn,recvbuf,ret);
}
close(conn);
close(listen);
return 0;
}

射客户端的编写
connect函数:TCP客户用connect函数来建立与TCP服务器的连接
int connect(int sockfd,const struct sockaddr *servaddr,socklen_t addrlen);

#include<unistd.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<string.h>
#include<stdlib.h>
#include<stdio.h>
#include<errno.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#define ERR_EXIT(m)\
do\
{\
perror(m);\
exit(EXIT_FAILURE);\
}while(0)
int main(void)
{
int sock;//客户端创建套接字(默认主动模式)
if((sock=socket(PF_INET,SOCK_STREAM,IPPROTO_TCP))<0)
ERR_EXIT("socket error"); struct sockaddr_in servaddr;//本地协议地址赋给一个套接字
memset(&servaddr,0,sizeof(servaddr));
servaddr.sin_family=AF_INET;
servaddr.sin_port=htons(5188); servaddr.sin_addr.s_addr=inet_addr("127.0.0.1");//服务器段地址
//inet_aton("127.0.0.1",&servaddr.sin_addr);
//向服务器发起连接。
if(connect(sock,(struct sockaddr*)&servaddr,sizeof(servaddr))<0)
ERR_EXIT("connect");
char sendbuf[1024]={0};
char recvbuf[1024]={0};
while(fgets(sendbuf,sizeof(sendbuf),stdin)!=NULL)//默认有换行符
{
write(sock,sendbuf,strlen(sendbuf));
read(sock,recvbuf,sizeof(recvbuf)); fputs(recvbuf,stdout);
memset(sendbuf,0,sizeof(sendbuf));
memset(recvbuf,0,sizeof(recvbuf));
}
close(sock); return 0;
}
上一篇:mapreduce: 揭秘InputFormat--掌控Map Reduce任务执行的利器


下一篇:Java多线程的信号量