php-golang-rpc 简单的jsonrpc实践
golang代码：
package main
import (
"net"
"net/rpc"
"net/rpc/jsonrpc"
)
type App struct{}
type Res struct {
Code int `json:"code"`
Msg string `json:"msg"`
Data any `json:"data"`
}
func (*App) Hi(mp map[string]any, res *Res) error {
res.Code = 200
res.Msg = "成功"
var rmp = make(map[string]any, 0)
if v, ok := mp["name"].(string); ok {
rmp["name"] = "my name is " + v
} else {
rmp["name"] = "my name is unknown"
}
res.Data = rmp
return nil
}
func main() {
ln, err := net.Listen("tcp", ":6001")
if err != nil {
panic(err)
}
rpc.Register(new(App))
for {
conn, err := ln.Accept()
if err != nil {
continue
}
go func(conn net.Conn) {
jsonrpc.ServeConn(conn)
}(conn)
}
}
/**************************************************************/
php代码：
public function index()
{
//访问结构体 Calc 下 Compute 方法
$res = $this->Call("App.Hi",['name'=>'ceshi222']);
dd($res);
}
public function Call($method, $params) {
$conn = fsockopen('127.0.0.1', 6001, $errno, $errstr, 3);
if (!$conn) {
return false;
}
$err = fwrite($conn, json_encode(array(
'method' => $method,
'params' => array($params),
'id' => time(),
))."\n");
if ($err === false){
return false;
}
stream_set_timeout($conn, 0, 3000);
$line = fgets($conn);
if ($line === false) {
return NULL;
}
return json_decode($line,true);
}
/***********************************************/
php封装：
PHP 端的就送 rpc 调用：rpc_client.php
<?phpclass JsonRPC {private $conn;function __construct($host, $port) {$this->conn = fsockopen($host, $port, $errno, $errstr, 3);if (!$this->conn) {return false;}}public function Call($method, $params) {if (!$this->conn) {return false;}$err = fwrite($this->conn, json_encode(array('method' => $method,'params' => array($params),'id' => 0,)) . "\n");if ($err === false){return false;}stream_set_timeout($this->conn, 0, 3000);$line = fgets($this->conn);if ($line === false) {return NULL;}return json_decode($line, true);}
}
$client = new JsonRPC("127.0.0.1", 30002);
$r = $client->Call("ServiceCompute.Add", array('X' => 30, 'Y' => 40));
var_dump($r);