ICode9

精准搜索请尝试: 精确搜索
首页 > 系统相关> 文章详细

linux网络编程之本地套接字通信

2021-04-20 10:59:18  阅读:275  来源: 互联网

标签:serv lfd struct 编程 client linux 接字 include


本地套接字

  • 伪文件
  • 即可采用TCP通信又可采用UDP通信

采用TCP通信流程如下

服务器端

  1. 创建套接字

    int lfd=socket(AF_UNIX,SOCK_STREAM,0)

  2. 绑定一个套接字文件
    struct sockaddr_un serv;
    serv.sun_family=AF_UNIX;
    strcpy(serv.sun_path,“server.socket”);------现在还不存在
    bind(lfd,(struct sockaddr*)&serv,len);------绑定成功套接字文件被创建

  3. 设置监听

    listen()

  4. 等待连接请求

    struct sockaddr_un client;
    int len=sizeof(client);
    int cfd=accept(lfd,&client,&len);

  5. 通信

    send
    recv

  6. 断开连接

    close(cfd);
    close(lfd);

客户端

  1. 创建套接字

    int lfd=socket(AF_UNIX,SOCK_STREAM,0)

  2. 绑定一个 套接字文件

    struct sockaddr_un client;
    client.sun_family=AF_UNIX;
    strcpy(client.sun_path,“client.socket”);------现在还不存在
    bind(lfd,(struct sockaddr*)&client,len);------绑定成功套接字文件被创建

  3. 连接服务器

    struct sockaddr_un serv;
    serv.sun_family=AF_UNIX;
    strcpy(serv.sun_path,“server.socket”);------现在还不存在
    bind(lfd,(struct sockaddr*)&serv,len);------绑定成功套接字文件被创建
    connect(fd,&serv,sizeof(serv));

  4. 通信

send
recv
  1. 关闭连接

代码:

server.c

#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
#include<sys/types.h>
#include<sys/stat.h>
#include<string.h>
#include<sys/un.h>

int main(int argc,const char * argc[])
{
   int lfd=socket(AF_UNIX,SOCK_STREAM,0);
   if(lfd==-1)
   {
     perror("socket error");
     exit(1);
   }
   //如果套接字文件存在,删除套接字文件
   unlink("server.sock");
   //绑定
     struct sockaddr_un serv;
	 serv.sun_family=AF_UNIX;
	 strcpy(serv.sun_path,"server.sock");------现在还不存在
	 int ret=bind(lfd,(struct sockaddr*)&serv,len);------绑定成功套接字文件被创建
  if(ret==-1)
  {
     perror("bind error");
     exit(1);  
  }
 //监听
 ret=listen(lfd,128);
 if(ret==-1)
  {
     perror("listen error");
     exit(1);  
  }
 //等待接受连接请求
 struct sockaddr_un client;
 socklen_t len=sizeof(client);
int cfd=accept(lfd,(struct sockaddr*)&client,&len);
if(cfd==-1)
{
     perror("accept error");
     exit(1); 
}
printf("client bind file:%s\n",client.sun_path);
//通信
while(1)
{
   char buf[1024]={0};
   int recvlen=recv(cfd,buf,sizeof(buf),0);
   if(recvlen==-1)
   {
     perror("recv error");
     exit(1);
   }
  else if(recvlen==0)
  {
    printf("client disconnect....");
    close(cfd);
    break;
  }
  else
  {
     printf("recv buf:%s\n",buf);
     send(cfd,buf,recvlen,0);
  }
}
close(cfd);
close(lfd);
 return 0
}

client.c

#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
#include<sys/types.h>
#include<sys/stat.h>
#include<string.h>
#include<sys/un.h>

int main(int argc,const char * argc[])
{
   int fd=socket(AF_UNIX,SOCK_STREAM,0);
   if(fd==-1)
   {
     perror("socket error");
     exit(1);
   }
   //如果套接字文件存在,删除套接字文件
   unlink("server.sock");
   //绑定
     struct sockaddr_un client;
	 serv.sun_family=AF_UNIX;
	 strcpy(serv.sun_path,"client.sock");------现在还不存在
	 int ret=bind(lfd,(struct sockaddr*)&client,len);------绑定成功套接字文件被创建
   if(ret==-1)
  {
     perror("bind error");
     exit(1);  
  }
  struct sockaddr_un serv;
  serv.sun_family=AF_UNIX;
 strcpy(serv.sun_path,"server.sock");------现在还不存在
  
  connect(fd,(struct sockadr*)&serv,sizeof(serv));
  通信
  while(1)
  {
    char buf[1024]={0};
    fgets(buf,sizeof(buf),stdin);
    //接收数据
    recv(fd,buf,sizeof(buf),0);
    printf("recv buf:%s\n",buf);
    
  }	
  close(fd); 
  return 0;
 }

编译执行后,关闭客户端,服务器端,重新执行会报地址被占用的错误
修改:rm serv.sock rm client.sock 再重新执行即可
方法二;代码 修改

标签:serv,lfd,struct,编程,client,linux,接字,include
来源: https://blog.csdn.net/zxdrttu/article/details/115893181

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有