server.go

  1. package main
  2. import (
  3. "errors"
  4. "fmt"
  5. "net"
  6. "net/rpc"
  7. "net/rpc/jsonrpc"
  8. "os"
  9. )
  10. type Args struct {
  11. A, B int
  12. }
  13. type Quotient struct {
  14. Quo, Rem int
  15. }
  16. type Arith int
  17. func (t *Arith) Multiply(args *Args, reply *int) error {
  18. *reply = args.A * args.B
  19. return nil
  20. }
  21. func (t *Arith) Divide(args *Args, quo *Quotient) error {
  22. if args.B == 0 {
  23. return errors.New("divide by zero")
  24. }
  25. quo.Quo = args.A / args.B
  26. quo.Rem = args.A % args.B
  27. return nil
  28. }
  29. func main() {
  30. arith := new(Arith)
  31. rpc.Register(arith)
  32. tcpAddr, err := net.ResolveTCPAddr("tcp", ":1234")
  33. checkError(err)
  34. listener, err := net.ListenTCP("tcp", tcpAddr)
  35. checkError(err)
  36. for {
  37. conn, err := listener.Accept()
  38. if err != nil {
  39. continue
  40. }
  41. jsonrpc.ServeConn(conn)
  42. }
  43. }
  44. func checkError(err error) {
  45. if err != nil {
  46. fmt.Println("Fatal error ", err.Error())
  47. os.Exit(1)
  48. }
  49. }

client.go

  1. package main
  2. import (
  3. "fmt"
  4. "log"
  5. "net/rpc/jsonrpc"
  6. "os"
  7. )
  8. type Args struct {
  9. A, B int
  10. }
  11. type Quotient struct {
  12. Quo, Rem int
  13. }
  14. func main() {
  15. if len(os.Args) != 2 {
  16. fmt.Println("Usage: ", os.Args[0], "server:port")
  17. log.Fatal(1)
  18. }
  19. service := os.Args[1]
  20. client, err := jsonrpc.Dial("tcp", service)
  21. if err != nil {
  22. log.Fatal("dialing:", err)
  23. }
  24. // Synchronous call
  25. args := Args{17, 8}
  26. var reply int
  27. err = client.Call("Arith.Multiply", args, &reply)
  28. if err != nil {
  29. log.Fatal("arith error:", err)
  30. }
  31. fmt.Printf("Arith: %d*%d=%d\n", args.A, args.B, reply)
  32. var quot Quotient
  33. err = client.Call("Arith.Divide", args, &quot)
  34. if err != nil {
  35. log.Fatal("arith error:", err)
  36. }
  37. fmt.Printf("Arith: %d/%d=%d remainder %d\n", args.A, args.B, quot.Quo, quot.Rem)
  38. }

测试:
运行服务端: go run server.go
运行客户端: go run client.go 127.0.0.1:1234
输出:
Arith: 17*8=136
Arith: 17/8=2 remainder 1