为了账号安全,请及时绑定邮箱和手机立即绑定

在写入服务器的情况下实现 RPC 客户端节点.js

在写入服务器的情况下实现 RPC 客户端节点.js

Go
拉丁的传说 2022-08-15 15:49:10
我使用Go实现RPC服务器。现在,我想使用Node编写客户端.js,如何从Node.js客户端进行RPC调用到Go服务器。这是用Go编写的服务器的代码。server.gopackage maintype HelloService struct{}func (p *HelloService) Hello(request string, reply *string) error {    *reply = "Hello " + request    return nil}func main() {    rpc.RegisterName("HelloService", new(HelloService))    // run rpc on port 1234    listener, err := net.Listen("tcp", ":1234")    if err != nil {        log.Fatal("ListenTCP error: ", err)    }    // use for-while for serve client    for {        conn, err := listener.Accept()        log.Println("New connection: ", conn)        if err != nil {            log.Fatal("Accept error: ", err)        }        go rpc.ServeConn(conn)    }} 
查看完整描述

1 回答

?
慕桂英4014372

TA贡献1871条经验 获得超13个赞

net/rpc 软件包使用编码/gob 作为默认的导线格式。它是一种特定于 Go 的二进制序列化格式,非常高效,但实际上,仅在 Go 应用程序之间进行通信时才有用。

但是,支持对数据使用不同的编解码器进行(反)序列化,并且 net/rpc/jsonrpc 包提供了 JSON-RPC 1.0 投诉编解码器实现。net/rpc

下面是一个使用它的示例,以及一个使用 jayson 包的 Node.js 客户端(没有什么特别的,只是我偶然发现的第一个支持 JSON-RPC 1.0 的客户端):

server.go

package main


import (

        "log"

        "net"

        "net/rpc"

        "net/rpc/jsonrpc"

)


type HelloService struct{}


func (p *HelloService) Hello(request string, reply *string) error {

        *reply = "Hello " + request

        return nil

}


func main() {

        rpc.RegisterName("HelloService", new(HelloService))

        listener, err := net.Listen("tcp", ":1234")

        if err != nil {

                log.Fatal("ListenTCP error: ", err)

        }

        for {

                conn, err := listener.Accept()

                if err != nil {

                        log.Fatal("Accept error: ", err)

                }

                log.Printf("New connection: %+v\n", conn.RemoteAddr())

                go jsonrpc.ServeConn(conn)

        }

}

client.js


const jayson = require("jayson");


const client = jayson.client.tcp({

        host: "172.17.0.2",

        port: "1234",

        version: 1,

});


client.request("HelloService.Hello", ["chuckx"], (err, response) => {

        if (err) throw err;

        if (response.error) throw response.error;

        console.log("response:", response.result);

});

输出

服务器客户端

$ go run server.go

2021/03/12 06:46:21 New connection: 172.17.0.3:51016

$ node client.js

response: Hello chuckx

请注意,该软件包不再接受新功能,因此最好使用gRPC之类的东西来获得更多功能和更好的跨语言兼容性。net/rpc


查看完整回答
反对 回复 2022-08-15
  • 1 回答
  • 0 关注
  • 176 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
微信客服

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号