golang RPC使用

Crazy__Programmer · · 1403 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

github:https://github.com/ZhangzheBJUT/blog/blob/master/golang_rpc.md 



一 HTTP RPC

服务端代码

package main

import (
"errors"
"fmt"
"net/http"
"net/rpc"
)

const (
    URL = "192.168.2.172:12981"
)

type Args struct {
    A, B int
}

type Quotient struct {
    Quo, Rem int
}

type Arith int

func (t *Arith) Multiply(args *Args, reply *int) error {
    *reply = args.A * args.B
    return nil
}
func (t *Arith) Divide(args *Args, quo *Quotient) error{
    if args.B == 0 {
        return errors.New("divide by zero!")
    }

    quo.Quo = args.A / args.B
    quo.Rem = args.A % args.B

    return nil
}
func main() {

    arith := new(Arith)
    rpc.Register(arith)
    rpc.HandleHTTP()

    err := http.ListenAndServe(URL, nil)
    if err != nil {
        fmt.Println(err.Error())
    }
}

客户端代码

package main

import (
    "fmt"    
    "net/rpc”
)

const (
    URL = "192.168.2.172:12982"
)

func main() {

    client, err := rpc.DialHTTP("tcp", URL)
    if err != nil {
        fmt.Println(err.Error())
    }

    args := Args{2, 4}
    var reply int
    err = client.Call("Arith.Multiply", &args, &reply)

    if err != nil {
        fmt.Println(err.Error())
    } else {
        fmt.Println(reply)
    }
}   

二 JSON-RPC

服务器端代码

package main

import (
"errors"
"fmt"
"net"
"net/rpc"
"net/rpc/jsonrpc"
)

const (
    URL= "192.168.2.172:12981"
)

type Args struct {
    A, B int
}
type Quotient struct {
    Quo, Rem int
}

type Arith int

func (t *Arith) Multiply(args *Args, reply *int) error {
    *reply = args.A * args.B
    return nil
}
func (t *Arith) Divide(args *Args, quo *Quotient) error {
    if args.B == 0 {
        return errors.New("divide by zero!")
    }

    quo.Quo = args.A / args.B
    quo.Rem = args.A % args.B

    return nil
}
func main() {

    arith := new(Arith)
    rpc.Register(arith)

    tcpAddr, err := net.ResolveTCPAddr("tcp", URL)
    if err != nil {
        fmt.Println(err)
    }
    listener, err := net.ListenTCP("tcp", tcpAddr)

    for {
        conn, err := listener.Accept()
        if err != nil {
            continue
        }
        go jsonrpc.ServeConn(conn)
    }
}

客户端代码

package main

import (
    "fmt"    
    "net/rpc”
)

const (
    URL = "192.168.2.172:12982"
)

func main() {

    client, err := jsonrpc.Dial("tcp", URL)
    defer client.Close()

    if err != nil {
        fmt.Println(err)
    }

    args := Args{7, 2}
    var reply int
    err = client.Call("Arith.Multiply", &args, &reply)
    if err != nil {
        fmt.Println(err)
    }
    fmt.Println(reply)  
}

本文来自:CSDN博客

感谢作者:Crazy__Programmer

查看原文:golang RPC使用

1403 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传