resources

https://pdos.csail.mit.edu/6.824/notes/crawler.go
https://pdos.csail.mit.edu/6.824/notes/l-rpc.txt
https://pdos.csail.mit.edu/6.824/notes/kv.go

RPC_concept

19 | 分布式通信之远程调用：我是你的千里眼（https://time.geekbang.org）

RPC_simple_example

http_RPC

package mainimport ("errors""fmt""net/http""net/rpc"
)type Args struct {A, B int
}type Quotient struct {Quo, Rem int
}type Arith intfunc (t *Arith) Multiply(args *Args, reply *int) error {*reply = args.A * args.Breturn 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.Bquo.Rem = args.A % args.Breturn nil
}func main() {arith := new(Arith)rpc.Register(arith)rpc.HandleHTTP()err := http.ListenAndServe(":1234", nil)if err != nil {fmt.Println(err.Error())}
}

client

package mainimport ("fmt""log""net/rpc"
)type Args struct {A, B int
}type Quotient struct {Quo, Rem int
}func main() {serverAddress := "127.0.0.1"client, err := rpc.DialHTTP("tcp", serverAddress+":1234")if err != nil {log.Fatal("dialing:", err)}// Synchronous callargs := Args{17, 8}var reply interr = client.Call("Arith.Multiply", args, &reply)if err != nil {log.Fatal("arith error:", err)}fmt.Printf("Arith: %d*%d=%d\n", args.A, args.B, reply)var quot Quotienterr = client.Call("Arith.Divide", args, &quot)if err != nil {log.Fatal("arith error:", err)}fmt.Printf("Arith: %d/%d=%d remainder %d\n", args.A, args.B, quot.Quo, quot.Rem)
}

http_TCP

server

这个客户端代码和http的客户端代码对比，唯一的区别一个是DialHTTP，一个是Dial(tcp)，其他处理一模一样。

package mainimport ("errors""fmt""net""net/rpc""os"
)type Args struct {A, B int
}type Quotient struct {Quo, Rem int
}type Arith intfunc (t *Arith) Multiply(args *Args, reply *int) error {*reply = args.A * args.Breturn 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.Bquo.Rem = args.A % args.Breturn nil
}func main() {arith := new(Arith)rpc.Register(arith)tcpAddr, err := net.ResolveTCPAddr("tcp", ":1234")checkError(err)listener, err := net.ListenTCP("tcp", tcpAddr)checkError(err)for {conn, err := listener.Accept()if err != nil {continue}rpc.ServeConn(conn)}}func checkError(err error) {if err != nil {fmt.Println("Fatal error ", err.Error())os.Exit(1)}
}

client

package mainimport ("fmt""log""net/rpc"
)type Args struct {A, B int
}type Quotient struct {Quo, Rem int
}func main() {service := "127.0.0.1:1234"client, err := rpc.Dial("tcp", service)if err != nil {log.Fatal("dialing:", err)}// Synchronous callargs := Args{17, 8}var reply interr = client.Call("Arith.Multiply", args, &reply)if err != nil {log.Fatal("arith error:", err)}fmt.Printf("Arith: %d*%d=%d\n", args.A, args.B, reply)var quot Quotienterr = client.Call("Arith.Divide", args, &quot)if err != nil {log.Fatal("arith error:", err)}fmt.Printf("Arith: %d/%d=%d remainder %d\n", args.A, args.B, quot.Quo, quot.Rem)
}

crawler.go

感觉这个例子太晦涩。有点强行把几个原理在一个例子讲明

6.824 RPC lesson2 2020(一）相关推荐

6.824 RPC lesson2 2020(二）
Use RPC to make a kv storage server Go example: kv.go on schedule page A toy key/value storage serve ...
6.824 Raft lesson4 2020(一）
raft实现距离上一篇文章一个月,因为6.824的课程看不懂,基础知识薄弱.现在了解一点Raft算法(自己动手实现一遍)还需要其他分布式相关的基础知识(实现一个分布式对象存储系统),然后再去继续学习 ...
6.824 MapReduce lab1 2020(一）
文章目录 MIT 6.824 分布式系统 lab1:MapReduce Notes wordcount's MapReduce Model look like a simple sequential ...
6.824-Distributed Transactions
Principles of Computer System Design An Introduction Chapter 9 Atomicity: All-or-Nothing and Before- ...
session.merge 缓存不更新_这几个缓存更新的设计你都知道吗？
前言 Hello,everybody,我是asong,上一篇文章我们一起聊一聊了面试中几个常见的缓存问题,今天我依然聊一聊缓存,不过今天我们聊的不是面试了,我们一起来看一看我们在系统中缓存更新的设计, ...
Windows 7 x64 SP1 安装 Windows Edge 浏览器
我需要在电脑上安装一个能录音录像的软件,找到了一个安装包但需要使用微软的 OneDrive 转存过来才能下载,我想直接使用浏览器同步 OneDrive ,因此需要安装 Microsoft Edge 浏 ...
go-elasticSearch实战篇，带你学会elasticSearch的增删改查
前言哈喽,everybody,这是go-elastic学习系列教程第二篇文章.上一篇我们学习了ElasticSearch基础,如果还不懂基础的,可以先看一看上一篇文章,传送门.这一篇我们开始实战,写 ...
go-ElasticSearch实战篇(二)
前言哈喽,everybody,这是go-elastic学习系列教程第二篇文章.????上一篇我们学习了ElasticSearch基础,如果还不懂基础的,可以先看一看上一篇文章,????传送门.这一篇 ...
咖说 | 富达：企业财资为何该考虑数字货币
" 收集一众行业大咖观点,探索区块链商业及应用.百家争鸣.百花齐放,说理.解密.预测和八卦,了解行业内幕,看咖说就够了! 投稿请联系 :tougao@conflux-chain.org 本文 ...

6.824 RPC lesson2 2020(一）

resources

RPC_concept

RPC_simple_example

http_RPC

client

http_TCP

server

client

crawler.go

6.824 RPC lesson2 2020(一）相关推荐

最新文章

热门文章