服务状态

示例: state

state 是另外一个元数据。 如果你在元数据中设置了state=inactive, 客户端将不能访问这些服务，即使这些服务是”活”着的。

你可以使用临时禁用一些服务，而不是杀掉它们， 这样就实现了服务的降级。 server.

你可以通过 rpcx-ui)来时实现禁用和启用的功能。

  1. // server.go
  2. func main() {
  3.     flag.Parse()
  5.     go createServer1(*addr1, "")
  6.     go createServer2(*addr2, "state=inactive")
  8.     select {}
  9. }
  11. func createServer1(addr, meta string) {
  12.     s := server.NewServer()
  13.     s.RegisterName("Arith", new(example.Arith), meta)
  14.     s.Serve("tcp", addr)
  15. }
  17. func createServer2(addr, meta string) {
  18.     s := server.NewServer()
  19.     s.RegisterName("Arith", new(Arith), meta)
  20.     s.Serve("tcp", addr)
  21. }
  1. // client.go
  2. xclient := client.NewXClient("Arith", client.Failover, client.RoundRobin, d, client.DefaultOption)
  3. defer xclient.Close()
  5. args := &example.Args{
  6.     A: 10,
  7.     B: 20,
  8. }
  10. for {
  11.     reply := &example.Reply{}
  12.     err := xclient.Call(context.Background(), "Mul", args, reply)
  13.     if err != nil {
  14.         log.Fatalf("failed to call: %v", err)
  15.     }
  17.     log.Printf("%d * %d = %d", args.A, args.B, reply.C)
  18.     time.Sleep(1e9)
  19. }