c/c++ linux 进程间通信系列2，使用UNIX_SOCKET

linux 进程间通信系列2，使用UNIX_SOCKET

1，使用stream，实现进程间通信

2，使用DGRAM，实现进程间通信

关键点：使用一个临时的文件，进行信息的互传。

  s_un.sun_family = AF_UNIX;
  strcpy(s_un.sun_path, "/tmp/afunix_text");

使用stream，server端：

#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/un.h>

#define FILEPATH "/tmp/afunix_text"

int main(){
  int s0, sock;
  sockaddr_un s_un;
  sockaddr_un s_un_accept;
  socklen_t addrlen;

  s0 = socket(AF_UNIX, SOCK_STREAM, 0);
  if(s0 < 0){
    perror("socket");
    return 1;
  }

  s_un.sun_family = AF_UNIX;
  strcpy(s_un.sun_path, FILEPATH);

  if(bind(s0, (sockaddr*)&s_un, sizeof(s_un)) != 0){
    perror("bind");
    return 1;
  }

  if(listen(s0, 5) != 0){
    perror("listen");
    return 1;
  }

  addrlen = sizeof(s_un_accept);
  sock = accept(s0, (sockaddr*)&s_un_accept, &addrlen);
  if(sock < 0){
    perror("accept");
    return 1;
  }

  printf("after accept
");

  write(sock, "the msg is send from server", 27);
  close(sock);
  close(s0);

  unlink(FILEPATH);

  return 0;
}

github源代码

使用stream，client端：

#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/un.h>

int main(){
  int sock;
  sockaddr_un s_un;
  int n;
  char buf[128];

  sock = socket(AF_UNIX, SOCK_STREAM, 0);
  if(sock < 0){
    perror("socket");
    return 1;
  }

  s_un.sun_family = AF_UNIX;
  strcpy(s_un.sun_path, "/tmp/afunix_text");

  if(connect(sock, (sockaddr*)&s_un, sizeof(s_un)) != 0){
    perror("connect");
    return 1;
  }
  printf("after connect
");
  memset(buf, 0, sizeof(buf));
  n = read(sock, buf, sizeof(buf));
  if(n < 0){
    perror("read");
    return 1;
  }

  printf("%s
", buf);
  close(sock);
  return 0;
}

github源代码

使用dgram，发送端：

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

int main(){
  int sock;
  sockaddr_un addr;
  socklen_t addrlen;

  sock = socket(AF_UNIX, SOCK_DGRAM, 0);
  addr.sun_family = AF_UNIX;
  strcpy(addr.sun_path, "/tmp/afu_dgram");

  int n = sendto(sock, "HELLO
", 6, 0, (sockaddr*)&addr, sizeof(addr));
  printf("send data
");
  close(sock);
  return 0;
}

github源代码

使用dgram，接收端：

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

int main(){
  int sock;
  sockaddr_un addr;
  socklen_t addrlen;
  char buf[1024];
  int n;

  sock = socket(AF_UNIX, SOCK_DGRAM, 0);

  addr.sun_family = AF_UNIX;
  strcpy(addr.sun_path, "/tmp/afu_dgram");

  bind(sock, (sockaddr*)&addr, sizeof(addr));

  while(1){
    memset(buf, 0, sizeof(buf));
    n = recv(sock, buf, sizeof(buf) - 1, 0);
    printf("recv:%s
", buf);
  }

  close(sock);
  return 0;
}

github源代码

c/c++ 学习互助QQ群：877684253

本人微信：xiaoshitou5854