时间戳

首页 > 解决方案 > 如何使用套接字（unix）将数据从python发送到C

c - 如何使用套接字（unix）将数据从python发送到C

问题描述

我正在尝试创建一个 unix 套接字，以允许我的一些 c 代码与我的一些 python 代码对话。C 代码充当套接字，python 充当客户端。到目前为止，我已经能够创建套接字并将客户端连接到它，但我要么无法通过它发送数据，要么无法通过它在任一方向接收数据（我不知道问题出在哪里）。

我已经尝试更改要发送的数据的编码，我已经尝试一遍又一遍地发送数据，以防出现时间问题，这些似乎不是问题。

C服务器代码：

int makeSocket(struct sockaddr_un * addr, char* path){

  unlink(path);

  int sock;
  //struct sockaddr_un addr;
  sock = socket(AF_UNIX, SOCK_STREAM, 0);
  fcntl(sock, F_SETFL, O_NONBLOCK);
  addr->sun_family = AF_UNIX;
  strncpy(addr->sun_path, path, sizeof(addr->sun_path));
  size_t size = (offsetof(struct sockaddr_un, sun_path) + strlen(addr->sun_path));
  if (bind(sock, (struct sockaddr*) addr, size) < 0){
    printf("failed to bind\n");
  }
  listen(sock, 5);
  return sock;
}

//this isn't actually here but just so you can see it being created, its a global int
globSock = makeSocket("socket.soc");

然后在空闲回调中：

f (!connected){
    int len = sizeof(addr);
    if (connection = accept(globSock, (struct sockaddr*) &addr, &len) < 0){
      printf("Can't listen\n");
    } else {
      printf("connected\n");
      send(connection, "HI", strlen("HI"), 0);
      connected = 1;
    }
  } else {
    int rc;
    if (!recevd && ((rc = recv(connection,buffer,BUFFERSIZE,0)) < 0)){
      printf("nope %s\n", buffer);
    } else if (rc == 0) {
      connected = 0;
      printf("%s\n", buffer);
    } else {
      recevd = 1;
      printf("%s\n", buffer);
    }
  }

connected 和 recevd 是标志变量，buffer 是一个 char 数组（缓冲区大小为 100，只是一个#define）

Python客户端：

# -*- coding: utf-8 -*-
import socket
import os

print("Connecting...")
if os.path.exists("socket.soc"):
    client = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
    client.connect("socket.soc")
    print("Ready.")
    print("Ctrl-C to quit.")
    print("Sending 'DONE' shuts down the server and quits.")
    while True:
        try:
            x = input("> ")
            if "" != x:
                print("SEND:", x)
                client.send(x.encode('utf-8'))
                if "DONE" == x:
                    print("Shutting down.")
                    break
        except KeyboardInterrupt as k:
            print("Shutting down.")
            client.close()
            break
else:
    print("Couldn't Connect!")
    print("Done")

在 C 端，它反复打印“nope”（我还没有收到任何东西打印），在 python 端，它只是要求输入，你可以给它消息，它会'发送'它然后请求另一个等等...

标签： cpython-3.xsocketsunixraspberry-pi3

解决方案

问题在

if (connection = accept(globSock, (struct sockaddr*) &addr, &len) < 0){

它保存了连接中的比较而不是实际的套接字，解决方案是：

if ((connection = accept(globSock, (struct sockaddr*) &addr, &len)) < 0){

推荐阅读