python - 在 Windows 操作系统上使用 Go 和 Python 实现客户端-服务器模型

Question

我正在开发一个 GUI 应用程序，UI 是使用 python(+kivy) 开发的，核心是使用 GoLang 实现的。

我的应用程序涉及将数据从 UI 传递到 Core，为此我使用管道。以下是客户端和服务器代码片段。

客户端.py:

p = win32pipe.CreateNamedPipe(r'\\.\pipe\test_pipe',
                              win32pipe.PIPE_ACCESS_DUPLEX,
                              win32pipe.PIPE_TYPE_MESSAGE |win32pipe.PIPE_WAIT,
                              1, 65536, 65536,300,None)

win32pipe.ConnectNamedPipe(p, None)


data = "Hello Pipe"  
win32file.WriteFile(p, bytes(data,"UTF-8")) 

服务器.go:

ln, err := npipe.Listen(`\\.\pipe\test_pipe`)
if err != nil {
    // handle error
}


for {
    conn, err := ln.Accept()
    if err != nil {
        // handle error
        continue
    }

    // handle connection like any other net.Conn
    go func(conn net.Conn) {
        r := bufio.NewReader(conn)
        msg, err := r.ReadString('\n')
        if err != nil {
            // handle error
            return
        }
        fmt.Println(msg)

    }(conn)
}

使用上面的代码，我无法在它们之间建立连接。我的应用程序涉及客户端和服务器之间的双工通信

感谢任何形式的帮助!!

Answer 1

我找不到使用管道的解决方案，所以我转向了套接字，并且能够通过套接字进行通信。以下是代码片段

客户端.py

import socket
import struct

# create a socket object
requestCore = socket.socket(
                socket.AF_INET, socket.SOCK_STREAM) 
responseCore = socket.socket(
                socket.AF_INET, socket.SOCK_STREAM) 

# get local machine name
host = socket.gethostname()                           
port = 8100                                           

# bind to the port
requestCore.bind((host, port))                                  
# queue up to 5 requests
requestCore.listen(5)                                           
client,addr = requestCore.accept()

port = 9999
responseCore.connect((host, port))

while True:
    msg = input("User Input: ")
    client.send(bytes(msg.encode('UTF-8')))

    msgFrmServ = responseCore.recv(64)
    print("message from Server",msgFrmServ)

client.close()
responseCore.close()

server.go

package main 

import "net" 
import "fmt" 
import "bufio" 
import "os"
import "bytes"

func main() {   

    hostname,_ := os.Hostname()

    // connect to this socket   
    readconn, _ := net.Dial("tcp", hostname+":8100")   
    reader := bufio.NewReader(readconn)     

    ln, _ := net.Listen("tcp", hostname+":9999")   
    writeconn, _ := ln.Accept()    // accept connection on port   

    for { 
        text := make([]byte,64)
        reader.Read(text)
        text = bytes.Trim(text,"\x00")
        fmt.Println(string(text))

        Acktext := "Core Acknowledge: " + string(text)
        writeconn.Write([]byte(Acktext))
    } 
}

上面的代码片段适用于我的应用程序。