初探net/rpc

服务端

package main

import (
    "net"
    "net/rpc"
)

type HelloWorldService struct{}

func (h *HelloWorldService) Hello(args string, reply *string) error {
    *reply = "hello," + args
    return nil
}
func main() {
    //1.监听
    listen, err := net.Listen("tcp", "localhost:1234")
    if err != nil {
       panic(err)
    }
    //2.注册rpc服务
    _ = rpc.RegisterName("HelloWorldService", &HelloWorldService{})
    //3.将tcp监听接管为rpc服务
    accept, _ := listen.Accept()
    rpc.ServeConn(accept)
}

客户端

package main

import (
    "fmt"
    "net/rpc"
)

func main() {
    //1.创建客户端连接
    dial, _ := rpc.Dial("tcp", "localhost:1234")
    //2.调用远程服务端方法
    var reply string
    err := dial.Call("HelloWorldService.Hello", "lkpalu", &reply)
    if err != nil {
       panic(err)
    }
    fmt.Println(reply)
}