package main  
  
import (  
    "fmt"  
    "log"    "net"    "net/rpc")  
  
type HelloService struct{}  
  
func (p *HelloService) Hello(request string, reply *string) error {  
    *reply = "hello:" + request  
    return nil  
}  
  
func main() {  
    // 注册 HelloService    rpc.RegisterName("HelloService", new(HelloService))  
  
    // 创建 TCP 监听器  
    listener, err := net.Listen("tcp", ":1234")  
    if err != nil {  
       log.Fatal("ListenTCP error:", err)  
    }  
  
    fmt.Println("RPC server listening on :1234")  
  
    // 等待并处理连接  
    for {  
       conn, err := listener.Accept()  
       if err != nil {  
          log.Fatal("Accept error:", err)  
       }  
       go rpc.ServeConn(conn)  
    }  
}

package main  
  
import (  
    "fmt"  
    "log"    "net/rpc")  
  
func main() {  
    client, err := rpc.Dial("tcp", "localhost:1234")  
    if err != nil {  
       log.Fatal("dialing:", err)  
    }  
  
    var reply string  
    err = client.Call("HelloService.Hello", "xxx", &reply)  
    if err != nil {  
       log.Fatal(err)  
    }  
  
    fmt.Println(reply)  
}