Hprose 过滤器 - 协议转换

如果你对 Hprose 协议本身有所了解的话，你还可以直接在 Hprose 过滤器中对输入输出数据进行协议转换。

在 Hprose for PHP 中已经提供了现成的 JSONRPC 的过滤器。使用它，你可以将 Hprose 服务器变身为 Hprose + JSONRPC 双料服务器。也可以将 Hprose 客户端变身为 Hprose + JSONRPC 双料客户端。

main.go

package main
 
import (
    "fmt"
 
    "github.com/hprose/hprose-golang/rpc"
    "github.com/hprose/hprose-golang/rpc/filter/jsonrpc"
)
 
func hello(name string) string {
    return "Hello " + name + "!"
}
 
type HelloService struct {
    Hello1 func(string) (string, error) `name:"hello" userdata:"{\"jsonrpc\":true}"`
    Hello2 func(string) (string, error) `name:"hello"`
}
 
func main() {
    server := rpc.NewTCPServer("")
    server.AddFunction("hello", hello).AddFilter(
        jsonrpc.ServiceFilter{},
        LogFilter{"Server"},
    )
    server.Handle()
    client := rpc.NewClient(server.URI()).AddFilter(
        jsonrpc.NewClientFilter("2.0"),
        LogFilter{"Client"},
    )
    var helloService *HelloService
    client.UseService(&helloService)
    fmt.Println(helloService.Hello1("JSONRPC"))
    fmt.Println(helloService.Hello2("Hprose"))
    fmt.Println(helloService.Hello1("World"))
    client.Close()
    server.Close()
}

为了清楚的让大家看到通讯的实际内容，我在这里引用了前面的 LogFilter。

而且在这里我们还可以看到，在客户端使用了自定义的 userdata 标记，这个标记中包含了那段 JSON 数据表示开启 JSONRPC 模式，这个是 jsonrpc.ClientFilter 中定义的，您如果有兴趣，可以去看该结构体的实现。

下面我们来看运行结果：

Client: {"id":1,"jsonrpc":"2.0","method":"hello","params":["JSONRPC"]}
Server: {"id":1,"jsonrpc":"2.0","method":"hello","params":["JSONRPC"]}
Server: {"id":1,"jsonrpc":"2.0","result":"Hello JSONRPC!"}
Client: {"id":1,"jsonrpc":"2.0","result":"Hello JSONRPC!"}
Hello JSONRPC! <nil>
Client: Cs5"hello"a1{s6"Hprose"}z
Server: Cs5"hello"a1{s6"Hprose"}z
Server: Rs13"Hello Hprose!"z
Client: Rs13"Hello Hprose!"z
Hello Hprose! <nil>
Client: {"id":2,"jsonrpc":"2.0","method":"hello","params":["World"]}
Server: {"id":2,"jsonrpc":"2.0","method":"hello","params":["World"]}
Server: {"id":2,"jsonrpc":"2.0","result":"Hello World!"}
Client: {"id":2,"jsonrpc":"2.0","result":"Hello World!"}
Hello World! <nil>

从运行结果中我们看到，当客户端调用 Hello1 方法时，使用的是 JSONRPC 通讯方式，而调用 Hello2 方法时，使用的是 Hprose 通讯方式，但是都成功调用了服务器端的同一个 hello 方法。当然你还会发现，其实 Hprose 通讯数据量只有 JSONRPC 通讯数据量的一半，所以如果没有特殊需要，完全不必使用 JSONRPC 来代替 Hprose。Hprose 就是你最好的 RPC 首选。

Hprose 过滤器的功能就是这幺强大，而且不止于此。除了上面这些用法之外，你还可以结合 Hprose 服务器事件、Hprose 中间件来实现更为复杂的功能。不过这里就不再继续举例说明了。