协议转换

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

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

main.go

  1. package main
  2.  
  3. import (
  4.     "fmt"
  5.  
  6.     "github.com/hprose/hprose-golang/rpc"
  7.     "github.com/hprose/hprose-golang/rpc/filter/jsonrpc"
  8. )
  9.  
  10. func hello(name string) string {
  11.     return "Hello " + name + "!"
  12. }
  13.  
  14. type HelloService struct {
  15.     Hello1 func(string) (string, error) `name:"hello" userdata:"{\"jsonrpc\":true}"`
  16.     Hello2 func(string) (string, error) `name:"hello"`
  17. }
  18.  
  19. func main() {
  20.     server := rpc.NewTCPServer("")
  21.     server.AddFunction("hello", hello).AddFilter(
  22.         jsonrpc.ServiceFilter{},
  23.         LogFilter{"Server"},
  24.     )
  25.     server.Handle()
  26.     client := rpc.NewClient(server.URI()).AddFilter(
  27.         jsonrpc.NewClientFilter("2.0"),
  28.         LogFilter{"Client"},
  29.     )
  30.     var helloService *HelloService
  31.     client.UseService(&helloService)
  32.     fmt.Println(helloService.Hello1("JSONRPC"))
  33.     fmt.Println(helloService.Hello2("Hprose"))
  34.     fmt.Println(helloService.Hello1("World"))
  35.     client.Close()
  36.     server.Close()
  37. }

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

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

下面我们来看运行结果：


  1. Client: {"id":1,"jsonrpc":"2.0","method":"hello","params":["JSONRPC"]}
  2. Server: {"id":1,"jsonrpc":"2.0","method":"hello","params":["JSONRPC"]}
  3. Server: {"id":1,"jsonrpc":"2.0","result":"Hello JSONRPC!"}
  4. Client: {"id":1,"jsonrpc":"2.0","result":"Hello JSONRPC!"}
  5. Hello JSONRPC! <nil>
  6. Client: Cs5"hello"a1{s6"Hprose"}z
  7. Server: Cs5"hello"a1{s6"Hprose"}z
  8. Server: Rs13"Hello Hprose!"z
  9. Client: Rs13"Hello Hprose!"z
  10. Hello Hprose! <nil>
  11. Client: {"id":2,"jsonrpc":"2.0","method":"hello","params":["World"]}
  12. Server: {"id":2,"jsonrpc":"2.0","method":"hello","params":["World"]}
  13. Server: {"id":2,"jsonrpc":"2.0","result":"Hello World!"}
  14. Client: {"id":2,"jsonrpc":"2.0","result":"Hello World!"}
  15. Hello World! <nil>

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

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