思维导图
代码实现
TCP域套接字服务器
#include <header.h>
#include <math.h>
int main(int argc, const char *argv[])
{
//为通信创建一个端点
int sfd=socket(AF_UNIX,SOCK_STREAM,0);
//参数1：说明使用的三ipv4通信域
//参数2：说明使用的三TCP面向连接的通信方式
//参数3: 由于参数2中已经指定通信方式，填0即可
if(sfd==-1)
{
perror("socket error");
return -1;
}
printf("socket succeess sfd=%d\n",sfd);//3
//判断要绑定的套接字文件是否存在
if(access("./unix",F_OK)==0)
{
//文件存在删除，不存在创建
if(unlink("./unix")==-1)
{
perror("unix error");
return -1;
}
}
//绑定ip和端口号
//准备地址信息结构体
struct sockaddr_un sun;
sun.sun_family = AF_UNIX; //通信域
strcpy(sun.sun_path,"./unix");//套接字文件路经
//绑定工作
if(bind(sfd,(struct sockaddr*)&sun,sizeof(sun))==-1)
{
perror("bind error");
return -1;
}
printf("bind success\n");
//将套接字设置成被动监听状态
if(listen(sfd,128)==-1)
{
perror("listen error");
return -1;
}
//阻塞等待客户端连接
//定义用于接受客户端信息的容器
struct sockaddr_un cun;
socklen_t addrlen = sizeof(cun);
int newfd=accept(sfd,(struct sockaddr*)&cun,&addrlen);
if(newfd==-1)
{
perror("accept error");
return -1;
}
printf("[%s]发送连接请求\n",cun.sun_path);
char rbuf[128]="";
while(1)
{
bzero(rbuf,sizeof(rbuf));
int retval=recv(newfd,rbuf,sizeof(rbuf),0);
if(retval==0)
{
printf("客户端已经下线\n");
break;
}
printf("[%s]:%s\n",cun.sun_path,rbuf);
strcat(rbuf,"#_#");
send(newfd,rbuf,strlen(rbuf),0);
printf("发送成\n");
}
close(newfd);
close(sfd);
return 0;
}
TCP域套接字客户端
#include <header.h>
int main(int argc, const char *argv[])
{
//创建用于通信的套接字文件描述符
int cfd =socket(AF_UNIX,SOCK_STREAM,0);
if(cfd==-1)
{
perror("socket error");
return -1;
}
printf("cfd=%d\n",cfd);
//判断要绑定的套接字文件是否存在
if(access("./lins",F_OK)==0)
{
//文件存在删除，不存在创建
if(unlink("./lins")==-1)
{
perror("lins error");
return -1;
}
}
//填充客户端地址信息结构体
struct sockaddr_un cun;
cun.sun_family=AF_UNIX;
strcpy(cun.sun_path,"./lins");
//绑定
if(bind(cfd,(struct sockaddr*)&cun,sizeof(cun))==-1)
{
perror("bind error");
return -1;
}
printf("bind success\n");
//准备对端地址信息结构体
struct sockaddr_un sun;
sun.sun_family=AF_UNIX;
strcpy(sun.sun_path,"./unix");
//连接服务器
if(connect(cfd,(struct sockaddr*)&sun,sizeof(sun))==-1)
{
perror("connect error");
return -1;
}
printf("connect success");
//数据收发
char wbuf[128]="";
char rbuf[128]="";
while(1)
{
//从终端上获取要发送的数据
fgets(wbuf,sizeof(wbuf),stdin);
wbuf[strlen(wbuf)-1]=0;
//将数据发送给服务器
send(cfd,wbuf,strlen(wbuf),0);
printf("发送成功\n");
//接收服务器发来的消息
bzero(rbuf,sizeof(rbuf));
recv(cfd,rbuf,sizeof(rbuf),0);
printf("服务器发来的消息为:%s\n",rbuf);
}
//关闭套接字
close(cfd);
return 0;
}
TCP域套接字服务器
#include<header.h>
int main(int argc, const char *argv[])
{
//1、创建用于通信的套接字文件描述符
int sfd = socket(AF_UNIX, SOCK_DGRAM, 0);
if(sfd == -1)
{
perror("socket error");
return -1;
}
printf("sfd = %d\n", sfd);//3
//判断要绑定的套接字文件是否存在
if(access("./unix",F_OK)==0)
{
//文件存在删除，不存在创建
if(unlink("./unix")==-1)
{
perror("unix error");
return -1;
}
}
//2、绑定IP地址和端口号
//2.1 填充地址信息结构体
struct sockaddr_un sun;
sun.sun_family = AF_UNIX;
strcpy(sun.sun_path,"./unix");
//2.2 绑定
if(bind(sfd, (struct sockaddr*)&sun, sizeof(sun)) ==-1)
{
perror("bind error");
return -1;
}
printf("bind success\n");
//3、数据收发
char rbuf[128] = "";
//准备接受对端的地址信息
struct sockaddr_un cun;
socklen_t addrlen = sizeof(cun);
while(1)
{
//清空容器
bzero(rbuf,sizeof(rbuf));
//读取数据
//read(sfd, rbuf, sizeof(rbuf));
recvfrom(sfd, rbuf, sizeof(rbuf), 0, (struct sockaddr*)&cun, &addrlen);
printf("收到消息为：%s\n", rbuf);
//将收到的消息，加个笑脸回过去
strcat(rbuf, "*_*");
//if(write(sfd, rbuf, strlen(rbuf))==-1)
if(sendto(sfd, rbuf, strlen(rbuf), 0, (struct sockaddr*)&cun, sizeof(cun))==-1)
{
perror("write error");
return -1;
}
printf("发送成功\n");
}
//4、关闭套接字
close(sfd);
return 0;
}
TCP域套接字客户端
#include<header.h>
int main(int argc, const char *argv[])
{
//1、创建用于通信的套接字文件描述符
int cfd = socket(AF_UNIX, SOCK_DGRAM, 0);
if(cfd == -1)
{
perror("socket error");
return -1;
}
printf("cfd = %d\n", cfd); //3
//判断要绑定的套接字文件是否存在
if(access("./lins",F_OK)==0)
{
//文件存在删除，不存在创建
if(unlink("./lins")==-1)
{
perror("lins error");
return -1;
}
}
//2.1 填充地址信息结构体
struct sockaddr_un cun;
cun.sun_family = AF_UNIX;
strcpy(cun.sun_path,"./lins");
//2.2 绑定
if(bind(cfd, (struct sockaddr*)&cun, sizeof(cun)) ==-1)
{
perror("bind error");
return -1;
}
printf("bind success\n");
//3、数据收发
char wbuf[128] = "";
//填充服务器的地址信息结构体
struct sockaddr_un sun;
sun.sun_family = AF_UNIX;
strcpy(sun.sun_path,"./unix");
char rbuf[128] = "";
while(1)
{
//清空容器
bzero(wbuf,sizeof(wbuf));
bzero(rbuf, sizeof(rbuf));
//从终端上获取信息
fgets(wbuf, sizeof(wbuf), stdin);
wbuf[strlen(wbuf)-1] = 0;
//讲消息发送给服务器
sendto(cfd, wbuf, strlen(wbuf), 0, (struct sockaddr*)&sun, sizeof(sun));
printf("发送成功\n");
//接受服务器发来的消息
recvfrom(cfd, rbuf, sizeof(rbuf), 0,NULL, NULL);
printf("收到服务器消息为：%s\n", rbuf);
}
//4、关闭套接字
close(cfd);
return 0;
}
