返回
北京兄弟连IT
置顶
该校与厚学网暂未合作,平台不保证课程的真实有效性,如有侵权等争议,请及时与厚学网联系处理
招生热线:400-656-1390

学校地址:北京市昌平区回龙观文华西路育荣教育园区兄弟连IT教育

兄弟连分享Go语言培训分享之RPC使用

119 2018-08-29 14:56:18

学习笔记

  Go语言作为服务器编程语言,很适合处理日志、数据打包、虚拟机处理、文件系统、分布式系统、数据库等;网络编程方面,Go语言广泛应用于Web应用、API应用、下载应用等;除此之外,Go语言还可用于内存数据库和云平台领域,目前国外很多云平台都是采用Go开发。

 

  兄弟连Go语言+区块链培训课程共计22周学习时长,划分为9个学习阶段,即区块链主流语言-Go语言开发实战、区块链后端技术体系-Go语言高并发和服务器开发、Go开发区块链公链(区块链密码学、分布式编程、共识算法、基本概念,Golan公链开发)、以-太 坊与智能合约与DAPP开发、区块链分布式应用开发、区块链系统框架开发-超级账本与区块链3.0EOSGo与区块链面试强化和企业级项目实战。

 HTTP RPC

服务端代码

 

package main

 

import (

"errors"

"fmt"

"net/http"

"net/rpc"

)

 

const (

    

)

 

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 (

    

)

 

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 (

    

)

 

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 (

    

)

 

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)  

}

文中图片素材来源网络,如有侵权请联系删除
来源:北京兄弟连IT
热门课程 全部课程

热门动态

申请免费试听

只要一个电话

我们为您免费回电

立即申请