Fork

Example:broadcast

Broadcast is a method of XClient and you can use it to send a request to all servers that contains this service.

If all servers return response whithout an error, Broadcast will return OK for this XClient. If any of servers returns an error, Broadcast returns an error of those errors.

  2. func main() {
  3.     ……
  5.     xclient := client.NewXClient("Arith", client.Failover, client.RoundRobin, d, client.DefaultOption)
  6.     defer xclient.Close()
  8.     args := &example.Args{
  9.         A: 10,
  10.         B: 20,
  11.     }
  13.     for {
  14.         reply := &example.Reply{}
  15.         err := xclient.Broadcast(context.Background(), "Mul", args, reply)
  16.         if err != nil {
  17.             log.Fatalf("failed to call: %v", err)
  18.         }
  20.         log.Printf("%d * %d = %d", args.A, args.B, reply.C)
  21.         time.Sleep(1e9)
  22.     }
  24. }

By smallnest updated 2018-03-27 11:12:10

原文:

http://doc.rpcx.site/part3/broadcast.html