C-如何使用UNIX插座模拟Pub/sub(AF_UNIX，SOCK_DGR)

Question

我正在努力使这种简单的交流起作用。

我在不到五分钟的时间内就与ZMQ一起做到了。使用Unix插座做这很痛苦(显然是因为我缺乏信心(。

这是服务器：

#include <sys/socket.h>
#include <sys/un.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include "streamsocket.h"
char *socket_path = "/tmp/stream";
int socket_fd=0;
struct sockaddr_un addr;
int main(){
        socket_setup();
        while(1){
                socket_sendstr("a");
                sleep(1);
        }
}
void socket_setup(){
  int rc;
  memset(&addr, 0, sizeof(addr));
  addr.sun_family = AF_UNIX;
  strcpy(addr.sun_path, socket_path);
  if ( (socket_fd = socket(AF_UNIX, SOCK_DGRAM, 0)) == -1) {
    perror("socket error");
    exit(-1);
  }
  rc=bind(socket_fd, (struct sockaddr *) &addr, sizeof(addr));
  if(rc<0){
    perror("bind error");
    exit(-2);
  }
}
int socket_sendstr(char* buffer) {
  int len=strlen(buffer);
  // corrected after suggestion in answer below (rc->len)
  // int rc=write(socket_fd, buffer, rc);
  int rc=write(socket_fd, buffer, len);
  if (rc != len) {
      if (rc > 0) fprintf(stderr,"partial write");
      else {
        perror("write error");
        //exit(-1);
      }
  }
}

这是客户：

#include <sys/socket.h>
#include <sys/un.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
int main(){
        char * server_filename = "/tmp/stream";
        char * client_filename = "/tmp/stream-client";
        struct sockaddr_un server_addr;
        struct sockaddr_un client_addr;
        int rc;
        memset(&server_addr, 0, sizeof(server_addr));
        server_addr.sun_family = AF_UNIX;
        strncpy(server_addr.sun_path, server_filename, 104); 
        memset(&client_addr, 0, sizeof(client_addr));
        client_addr.sun_family = AF_UNIX;
        strncpy(client_addr.sun_path, client_filename, 104);
        // get socket
        int sockfd = socket(AF_UNIX, SOCK_DGRAM, 0);
        // bind client to client_filename
        rc = bind(sockfd, (struct sockaddr *) &client_addr, sizeof(client_addr));
        if(rc==-1) perror("bind error");
        // connect client to server_filename
        rc = connect(sockfd, (struct sockaddr *) &server_addr, sizeof(server_addr));
        if(rc==-1) perror("connect error");

        char buf[1024];
        int bytes=0;
        while(bytes = read(sockfd, buf, sizeof(buf))){
                printf("%sn",buf);
        }
        close(sockfd);
}

我做错了什么？

目前客户没有打印任何东西。

edit1：在服务器写入(，，rc(中正确的" rc"以写(，len(

edit2：因为客户也无法正常工作： socat unix -client：/tmp/stream-

所以我认为问题可能在服务器中。

Answer 1

int len=strlen(buffer);
  int rc=write(socket_fd, buffer, rc);

不 write 期望作为第三参数的长度获得；

Answer 2

您误解了数据报插座的工作方式，这不是Unix插座的本地 - 您将与UDP遇到同样的问题。

数据报插座完全无连接。数据报套接字上的connect()实际上并未建立任何连接，它只是设置了在套接字上发送的数据包的默认目的地。只是为了方便起见，因此您可以在始终发送到同一地址的情况下使用send而不是sendto。

如果客户端首先将数据包发送到服务器，则可以使服务器回复特定客户端，在这种情况下，您可以使用sendto回复与从recvfrom获得的相同地址。但是，如果您实际上想在客户端和服务器之间建立连接，但是，您需要使用流插座或Seqpacket套接字。在这种情况下，您还需要确保您也需要在服务器中执行正确的listen/accept序列。

实际上，如果您的服务器在尝试发送时未打印错误，我会感到惊讶。应该说write error: Transport endpoint is not connected。