package mainimport ( "fmt" "net" "net/rpc" "net/rpc/jsonrpc")type Goods struct{}//方法(必须是公有方法,且必须是两个参数)func (g *Goods) GetName(args string , res *string) error { *res = "args=" + args return nil}func main() { //注册rpc服务,并自定义服务名 err := rpc.RegisterName("Goods",new(Goods)) if err != nil { panic(err.Error()) } //监听端口,如果监听所有客户端则去掉ip listen, err := net.Listen("tcp", "127.0.0.1:7081") if err != nil { panic(err.Error()) } fmt.Println("启动服务...") for { conn, err := listen.Accept() // 接收客户端连接请求 if err != nil { continue } go jsonrpc.ServeConn(conn) }}