golang - gob與rpc

来源:https://www.cnblogs.com/cloudgeek/archive/2018/07/21/9348267.html
-Advertisement-
Play Games

今天和大家聊聊golang中怎麼使用rpc,rpc數據傳輸會涉及到gob編碼,所以先講講gob,別擔心,就算你完全沒有接觸過gob與rpc,只要知道rpc的中文是遠程過程調用,剩下的我都能給你講明白(帶你入門不包你精通)! 一、數據結構編碼之gob gob全稱為:Go binary Golang自帶 ...


  今天和大家聊聊golang中怎麼使用rpc,rpc數據傳輸會涉及到gob編碼,所以先講講gob,別擔心,就算你完全沒有接觸過gob與rpc,只要知道rpc的中文是遠程過程調用,剩下的我都能給你講明白(帶你入門不包你精通)!

一、數據結構編碼之gob

  gob全稱為:Go binary

  Golang自帶的一個數據結構序列化編碼/解碼工具,也就是說gob可以講go中的一個數據結構序列化成某種東西,還能反序列化!序列化成啥我們後面來看,不管是變成一個字元串,變成二進位流,變成啥先不管,反正作用就是序列化。

  Gob使用時我們需要關註Encoder和Decoder對象,顧名思義,一個是編碼的時候用的,一個是解碼的時候用的,我們看一下怎麼獲取這兩個對象先:

 

  所以很明確,需要調用這兩個函數來獲取Encoder和Decoder對象。註意這裡的參數是io.Writer和io.Reader介面類型,我們在上一講介紹過這兩個介面,所以這裡需要的參數分別是實現了io.Writer和io.Reader介面類型的對象即可。

  Encoder和Decoder分別有一個主要的方法是:

 

  看到這裡我們已經可以得到如下結論:

  Gob 使用 io.Writer 介面,通過 NewEncoder() 函數創建 Encoder 對象通過調用 Encode()方法實現編碼操作;使用 io.Reader 介面,通過 NewDecoder() 函數創建 Decoder 對象並調用 Decode()方法完成解碼操作!

  接下來我們試著用一下這個Encoder和Decoder,就輕輕鬆松入門gob了,來看第一個例子

  例1:數據結構與bytes.Buffer之間的轉換(編碼成位元組切片)

 1package main
2
3import (
4    "bytes"
5    "fmt"
6    "encoding/gob"
7    "io"
8)
9
10//準備編碼的數據
11type P struct {
12    X, Y, Z int
13    Name    string
14}
15
16//接收解碼結果的結構
17type Q struct {
18    X, Y *int32
19    Name string
20}
21
22func main() {
23    //初始化一個數據
24    data := P{345"CloudGeek"}
25    //編碼後得到buf位元組切片
26    buf := encode(data)
27    //用於接收解碼數據
28    var q *Q
29    //解碼操作
30    q = decode(buf)
31    //"CloudGeek": {3,4}
32    fmt.Printf("%q: {%d,%d}\n", q.Name, *q.X, *q.Y)
33
34}
35
36func encode(data interface{}) *bytes.Buffer {
37    //Buffer類型實現了io.Writer介面
38    var buf bytes.Buffer
39    //得到編碼器
40    enc := gob.NewEncoder(&buf)
41    //調用編碼器的Encode方法來編碼數據data
42    enc.Encode(data)
43    //編碼後的結果放在buf中
44    return &buf
45}
46
47func decode(data interface{}) *Q {
48    d := data.(io.Reader)
49    //獲取一個解碼器,參數需要實現io.Reader介面
50    dec := gob.NewDecoder(d)
51    var q Q
52    //調用解碼器的Decode方法將數據解碼,用Q類型的q來接收
53    dec.Decode(&q)
54    return &q
55}

  例2:數據結構到文件的序列化和反序列化

 1package main
2
3import (
4    "encoding/gob"
5    "os"
6    "fmt"
7)
8
9//試驗用的數據類型
10type Address struct {
11    City    string
12    Country string
13}
14
15//序列化後數據存放的路徑
16var filePath string
17
18func main() {
19    filePath = "./address.gob"
20    encode()
21    pa := decode()
22    fmt.Println(*pa) //{Chengdu China}
23}
24
25//將數據序列號後寫到文件中
26func encode() {
27    pa := &Address{"Chengdu""China"}
28    //打開文件,不存在的時候新建
29    file, _ := os.OpenFile(filePath, os.O_CREATE|os.O_WRONLY, 0666)
30    defer file.Close()
31
32    //encode後寫到這個文件中
33    enc := gob.NewEncoder(file)
34    enc.Encode(pa)
35}
36
37//從文件中讀取數據並反序列化
38func decode() *Address {
39    file, _ := os.Open(filePath)
40    defer file.Close()
41
42    var pa Address
43    //decode操作
44    dec := gob.NewDecoder(file)
45    dec.Decode(&pa)
46    return &pa
47}

  上面2個例子都不難,我去掉了錯誤處理之類的代碼,儘量註釋了每塊代碼,耐心看完這2個例子應該就能體會gob的encode和decode精髓了。

理解gob是什麼的基礎上,如果你需要使用gob開發,建議詳細看一下官方文檔,瞭解一下更多的細節:https://golang.org/pkg/encoding/gob/

 

二、golang中的rpc入門

  如果你之前沒有做過基於rpc通信的開發工作,直接去網上查rpc相關的知識點的時候很可能會一臉蒙圈,rest api咋就那麼好理解,一個http請求過去就行了,rpc咋個回事,看不懂呀。。。

  所以我不會和多數教程一樣為了追求詳細或者展示自己技術多牛而去寫很長的例子,扯一堆專業的概念,我們先最快的方式體驗一下rpc調用的感覺!

  rpc服務端

 1package main
2
3import (
4    "net"
5    "net/rpc"
6    "net/http"
7)
8
9type Args struct {
10    A, B int
11}
12
13//定義一個算術類型,其實就是int
14type Arith int
15
16//實現乘法的方法綁定到Arith類型,先不管為什麼是這樣的形式
17func (t *Arith) Multiply(args *Args, reply *int) error {
18    *reply = args.A * args.B
19    return nil
20}
21
22func main() {
23    //得到一個Arith類型的指針實例
24    arith := new(Arith)
25    //註冊到rpc服務
26    rpc.Register(arith)
27    //掛到http服務上
28  &nb
您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 1 // C++函數和類 01-函數.cpp: 定義控制台應用程式的入口點。 2 // 3 4 #include "stdafx.h" 5 #include 6 #include 7 #include 8 #include 9 #include 10 using namespace std; 11 ... ...
  • c/c++ 用前序和中序,或者中序和後序,創建二叉樹 用前序和中序創建二叉樹 用後序和中序創建二叉樹 bintreemain.c "完整代碼" 編譯方法:g++ g nodestack.c nodequeue.c bintree.c bintreemain.c ...
  • static 用法 1.static 變數 static變數又稱為靜態變數,靜態變數保存在方法區靜態域中,一個類的靜態變數被其所有實例共用。 2.static方法 靜態方法不與包含它的任何對象關聯,即使沒有創建對象,也可使用,例: 1 public class StaticTest { 2 3 pu ...
  • ng-app="angular_app" 範圍 ng-controller="angular_controller" 控制器 ng-init="findAll()" 初始化方法 雙向數據綁定 就是angular的ng-model屬性同時具備了表單元素中的name與value兩個屬性,既可以提交表單數 ...
  • static 和 final 關鍵字 對實例變數賦初始值的影響 最近一直在看《深入理解Java虛擬機》,在看完了對象記憶體分配、Class文件格式之後,想深扒一下實例變數是如何被賦上初始值的這個問題的細節。 在2.3.1小節中講對象創建的時候,講到記憶體分配有兩種方式:一種是指針碰撞;另一種是空閑列表。 ...
  • python語言程式設計基礎 習題2.5 ​​​ ...
  • 大道至簡這本書總體來說比較通俗易懂,同時在說明自己觀點的時候引用了許多古代的例子,更加的形象生動有趣,可讀性很強。 前幾章的主要思想如下: 程式=演算法+結構+方法;編程的第一要務是先把事情分析清楚,把事件先後的邏輯關係和依賴關係搞清楚,然後再去寫代碼實現。代碼是不存在的,存在的只是思想。其實演算法是對 ...
  • 一、多進程 1.1 多進程的概念 由於GIL的存在,python中的多線程其實並不是真正的多線程,如果想要充分地使用多核CPU的資源,在python中大部分情況需要使用多進程。Python提供了非常好用的多進程包multiprocessing,只需要定義一個函數,Python會完成其他所有事情。藉助 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...