//實(shí)例化rpc遠(yuǎn)程調(diào)用的方法所屬對(duì)象
arith := new(Arith)
//注冊(cè)對(duì)象
rpc.Register(arith)
//把rpc監(jiān)聽 對(duì)應(yīng)到http處理器。即指定http請(qǐng)求addr+port時(shí)，調(diào)用的方法
rpc.HandleHTTP()
//獲取監(jiān)聽地址
l, e := net.Listen("tcp", ":1234")
if e != nil {
	log.Fatal("listen error:", e)
}
//開啟一個(gè)go程，持續(xù)處理監(jiān)聽數(shù)據(jù)
go http.Serve(l, nil)

//連接 rpc的http服務(wù)端
client, err := rpc.DialHTTP("tcp", serverAddress + ":1234")
if err != nil {
	log.Fatal("dialing:", err)
}
//同步調(diào)用
// 實(shí)例化rpc傳入?yún)?shù)
args := &server.Args{7,8}
//聲明rpc 回復(fù)參數(shù)。傳入和回復(fù)參數(shù)，必須與調(diào)用方法中的參入類型一致
var reply int
//調(diào)用rpc注冊(cè)的方法
err = client.Call("Arith.Multiply", args, &reply)
if err != nil {
	log.Fatal("arith error:", err)
}
fmt.Printf("Arith: %d*%d=%d", args.A, args.B, reply)
//或：異步調(diào)用
// Asynchronous call
quotient := new(Quotient)
divCall := client.Go("Arith.Divide", args, quotient, nil)
replyCall := <-divCall.Done	// will be equal to divCall

//注冊(cè)路由和對(duì)應(yīng)的handler
http.HandleFunc("/json", func(rw http.ResponseWriter, r *http.Request) {
//聲明一個(gè)客戶端連接對(duì)象   
var conn io.ReadWriteCloser = struct {
      io.Writer
      io.ReadCloser
   }{
      ReadCloser: r.Body,
      Writer:     rw,
   }
//也可以使用如下方法獲取接管客戶端連接，http處理器不在管理該鏈接，使用完畢后需要自行關(guān)閉鏈接
// conn, _, err := rw.(http.Hijacker).Hijack()
  // if err != nil {
   //   log.Print("rpc hijacking fail: ", err.Error())
    //  return
   // }
   io.WriteString(conn, "HTTP/1.0 rpc-ok\n\n")
   //server.ServeConn(conn)
 //rpc.ServeRequest,指定編碼器，以同步的方式處理請(qǐng)求一次，編碼器內(nèi)不關(guān)閉鏈接，由http服務(wù)處理。適用于http形式的請(qǐng)求，因?yàn)閔ttp是無狀態(tài)的，每次請(qǐng)求都是一個(gè)新的鏈接
//rpc.ServeCodec,指定編碼器，for循環(huán)接收客戶端鏈接的消息，每次消息處理開啟一個(gè)go程，相當(dāng)于異步處理，直到客戶端關(guān)閉或解碼錯(cuò)誤，跳出循環(huán)，關(guān)閉連接。適用客戶端，一次連接多次發(fā)送數(shù)據(jù)
   rpc.ServeRequest(jsonrpc.NewServerCodec(conn))})
//監(jiān)聽http請(qǐng)求
http.ListenAndServe("127.0.0.1:1234", nil)

//聲明和注冊(cè)rpc方法對(duì)象
//獲取監(jiān)聽信息
lis, err := net.Listen("tcp", ":8082")
	if err != nil {
		log.Fatal(err)
}
//循環(huán)讀取監(jiān)聽到的數(shù)據(jù)
for {
	//獲取一個(gè)客戶端連接
   conn, err := lis.Accept()
   if err != nil {
      continue
   }
   //開啟一個(gè)go程序，使用自定義編碼器處理當(dāng)前獲取連接
   go s.Server.ServeCodec(jsonrpc.NewServerCodec(conn))
}

//連接服務(wù)端
conn, err := net.Dial("tcp", ":8082")if err != nil {
	log.Fatal(err)
}
defer conn.Close()
//使用json編碼器新建客戶端
client := &Client{rpc.NewClientWithCodec(jsonrpc.NewServerCodec(conn))}
//聲明rpc方法中傳入和輸出的參數(shù)
resq := message.ArithRequest{A: 20, B: 5}
resp := message.ArithResponse{}
//調(diào)用rpc方法
err = client.Call("ArithService.Add", &resq, &resp)
log.Printf("Arith.Add(%v, %v): %v ,Error: %v", resq.A, resq.B, resp.C, err)