Python與Go結合的方法
Python和Go可以通過多種方式結合使用，通常采用跨語言通信或集成的方式。以下是幾種常見的方法：
使用CFFI或CGO進行綁定
Python可以通過CFFI（C Foreign Function Interface）調用Go編寫的庫，而Go可以通過CGO導出函數供Python調用。這種方法需要將Go代碼編譯為動態鏈接庫（.so或.dll文件），然后在Python中加載并調用。
在Go中編寫并導出函數：
package mainimport "C"//export Add
func Add(a, b int) int {return a + b
}func main() {}
編譯為動態庫：
go build -buildmode=c-shared -o libadd.so add.go
在Python中使用CFFI調用：
from cffi import FFIffi = FFI()
ffi.cdef("int Add(int a, int b);")
lib = ffi.dlopen("./libadd.so")result = lib.Add(2, 3)
print(result) # 輸出5
使用gRPC進行通信
gRPC是一個高性能的遠程過程調用框架，支持多種語言。可以在Go中實現gRPC服務端，在Python中實現客戶端，或反之。
定義proto文件：
syntax = "proto3";service Greeter {rpc SayHello (HelloRequest) returns (HelloReply) {}
}message HelloRequest {string name = 1;
}message HelloReply {string message = 2;
}
Go實現服務端：
package mainimport ("context""log""net""google.golang.org/grpc"pb "path/to/your/proto"
)type server struct{}func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {return &pb.HelloReply{Message: "Hello " + in.Name}, nil
}func main() {lis, err := net.Listen("tcp", ":50051")if err != nil {log.Fatalf("failed to listen: %v", err)}s := grpc.NewServer()pb.RegisterGreeterServer(s, &server{})s.Serve(lis)
}
Python實現客戶端：
import grpc
from proto import greeter_pb2, greeter_pb2_grpcchannel = grpc.insecure_channel('localhost:50051')
stub = greeter_pb2_grpc.GreeterStub(channel)
response = stub.SayHello(greeter_pb2.HelloRequest(name='World'))
print(response.message) # 輸出 "Hello World"
使用HTTP/REST API
Go可以提供一個HTTP服務，Python通過HTTP請求與之交互。這是最通用的方法之一。
Go實現HTTP服務：
package mainimport ("encoding/json""net/http"
)type Response struct {Message string `json:"message"`
}func handler(w http.ResponseWriter, r *http.Request) {resp := Response{Message: "Hello from Go"}json.NewEncoder(w).Encode(resp)
}func main() {http.HandleFunc("/", handler)http.ListenAndServe(":8080", nil)
}
Python使用requests調用：
import requestsresponse = requests.get("http://localhost:8080")
print(response.json()) # 輸出 {"message": "Hello from Go"}
使用消息隊列
通過消息隊列（如RabbitMQ、Kafka）可以實現Python和Go之間的異步通信。Python作為生產者發送消息，Go作為消費者處理消息，或反之。
Python使用pika發送消息：
import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='', routing_key='hello', body='Hello from Python')
connection.close()
Go使用amqp接收消息：
package mainimport ("log""github.com/streadway/amqp"
)func main() {conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")if err != nil {log.Fatal(err)}defer conn.Close()ch, err := conn.Channel()if err != nil {log.Fatal(err)}defer ch.Close()q, err := ch.QueueDeclare("hello", false, false, false, false, nil)if err != nil {log.Fatal(err)}msgs, err := ch.Consume(q.Name, "", true, false, false, false, nil)if err != nil {log.Fatal(err)}for d := range msgs {log.Printf("Received a message: %s", d.Body)}
}
使用共享內存或文件
對于簡單的數據交換，可以通過共享文件或內存實現。Python和Go都可以讀寫相同的文件或共享內存區域。
Python寫入文件：
with open("shared.txt", "w") as f:f.write("Hello from Python")
Go讀取文件：
package mainimport ("fmt""io/ioutil"
)func main() {data, err := ioutil.ReadFile("shared.txt")if err != nil {fmt.Println("Error reading file:", err)return}fmt.Println(string(data)) // 輸出 "Hello from Python"
}
這些方法各有優缺點，適用于不同的場景。CFFI/CGO適合高性能調用，gRPC適合復雜服務，HTTP/REST通用性強，消息隊列適合異步處理，共享文件簡單但效率較低。
