1、流式域套接字

1>tcp服務端實現

#include<myhead.h>
int main(int argc, const char *argv[])
{//1、創建套接字int sfd = socket(AF_UNIX, SOCK_STREAM, 0);if(sfd == -1){perror("socket error");return -1;}//2、判斷套接字文件是否存在，如果存在則需要刪除if(access("./mysocket", F_OK) == 0){//說明存在，將該文件刪除if(unlink("./mysocket") == -1){perror("unlink error");return -1;}}//綁定套接字文件//2.1 填充地址信息結構體struct sockaddr_un sun;sun.sun_family = AF_UNIX;strcpy(sun.sun_path, "./mysocket");//2.2 綁定 if(bind(sfd, (struct sockaddr*)&sun, sizeof(sun)) == -1){perror("bind error");return -1;}printf("bind success\n");//3、監聽if(listen(sfd,128) == -1){perror("listen 128");return -1;}printf("listen success\n");//4、阻塞等待客戶端連接需求//定義容器接受客戶端地址信息struct sockaddr_un cun;socklen_t socklen = sizeof(cun);int newfd = -1;if((newfd = accept(sfd, (struct sockaddr*)&cun, &socklen)) == -1){perror("accept error");return -1;}printf("有新客戶發來連接請求\n");//5、數據收發char rbuf[128]= "";while(1){//清空bzero(rbuf, sizeof(rbuf));recv(newfd, rbuf, sizeof(rbuf), 0);printf("[%s]:%s\n",cun.sun_path, rbuf);//連接一個笑臉回復strcat(rbuf, "*_*");//發送回去send(newfd, rbuf, strlen(rbuf), 0);printf("發送成功\n");}//6、關閉套接字close(sfd);close(newfd);return 0;
}

客戶端實現

#include<myhead.h>int main(int argc, const char *argv[])
{//1、創建用于通信的套接字文件描述符int cfd = socket(AF_UNIX, SOCK_STREAM, 0);if(cfd == -1){perror("socket error");return -1;}printf("cfd = %d\n", cfd);          //3//判斷套接字文件是否存在，如果存在則需要刪除if(access("./mysocket1", F_OK) == 0){//說明存在，將該文件刪除if(unlink("./mysocket1") == -1){perror("unlink error");return -1;}}//2、綁定（非必須）//2.1 填充地址信息結構體struct sockaddr_un cun;cun.sun_family = AF_UNIX;strcpy(cun.sun_path, "./mysocket1");//2.2 綁定if(bind(cfd, (struct sockaddr*)&cun, sizeof(cun)) == -1){perror("bind error");return -1;}printf("bind success\n");//3、連接服務器//3.1填充要連接的服務器地址信息結構體struct sockaddr_un sun;sun.sun_family = AF_UNIX;   //地址族strcpy(sun.sun_path, "./mysocket");      //套接字文件//3.2 連接服務器if(connect(cfd, (struct sockaddr*)&sun, sizeof(sun))==-1){perror("connect error");return -1;}printf("connect success\n");//4、數據收發char wbuf[128] = "";while(1){//清空數據bzero(wbuf, sizeof(wbuf));printf("請輸入>>>");fgets(wbuf, sizeof(wbuf), stdin);   //從終端輸入wbuf[strlen(wbuf)-1] = 0;//將數據發送給服務器send(cfd, wbuf, strlen(wbuf), 0);printf("發送成功\n");//判斷發送的數據if(strcmp(wbuf, "quit") == 0){break;}//接收服務器發來的消息//清空數據bzero(wbuf, sizeof(wbuf));recv(cfd, wbuf, sizeof(wbuf), 0); printf("收到消息為：%s\n", wbuf);}//5、關閉套接字close(cfd);return 0;
}

2>報式域套接字

服務端實現：

#include<myhead.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("./linux1", F_OK) == 0){//說明存在，將該文件刪除if(unlink("./linux1") == -1){perror("unlink error");return -1;}}//2、綁定IP地址和端口號//2.1填充地址信息結構體struct sockaddr_un sun;sun.sun_family = AF_UNIX;          //地址族strcpy(sun.sun_path, "./linux1");//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 socklen = sizeof(cun);while(1){//清空數組bzero(rbuf, sizeof(rbuf));//接收數據recvfrom(sfd, rbuf, sizeof(rbuf), 0, (struct sockaddr*)&cun, &socklen);printf("收到消息為：%s\n", rbuf);//將消息加個笑臉回過去strcat(rbuf, "*_*");if(sendto(sfd, rbuf, strlen(rbuf), 0, (struct sockaddr*)&cun, socklen) == -1){perror("sendto error");return -1;}}//4、關閉套接字close(sfd);return 0;
}

客戶端實現：

#include<myhead.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("./linux2", F_OK) == 0){//說明存在，將該文件刪除if(unlink("./linux2") == -1){perror("unlink error");return -1;}}//2、綁定IP地址和端口號(如果要接收服務器消息必須綁定)struct sockaddr_un cun;cun.sun_family = AF_UNIX;strcpy(cun.sun_path, "./linux2");if(bind(cfd, (struct sockaddr*)&cun, sizeof(cun))==-1){perror("bind error");return -1;}//3、收發數據char wbuf[128] = "";//定義容器，記錄服務器的地址信息結構體struct sockaddr_un sun;sun.sun_family = AF_UNIX;strcpy(sun.sun_path,"./linux1");while(1){//清空數組bzero(wbuf, sizeof(wbuf));//從終端獲取數據printf("請輸入>>>");fgets(wbuf, sizeof(wbuf), stdin);wbuf[strlen(wbuf)-1] = 0;//將數據發送給服務器sendto(cfd, wbuf, sizeof(wbuf), 0, (struct sockaddr*)&sun, sizeof(sun));printf("發送成功\n");//接收服務器回復的消息bzero(wbuf, sizeof(wbuf));recvfrom(cfd, wbuf, sizeof(wbuf), 0, NULL, NULL);printf("收到消息為：%s\n", wbuf);}//4、關閉套接字close(cfd);return 0;
}

?