Fabric區塊鏈瀏覽器（3）

来源:https://www.cnblogs.com/lianshuiwuyi/archive/2023/08/30/17667387.html
-Advertisement-
Play Games

本文是區塊鏈瀏覽器系列的第五篇，項目完整代碼在[這裡](https://github.com/mengbin92/browser/tree/main)。 在[上一篇文章](https://mengbin.top/2023-08-20-browser2/)中給瀏覽器增加了簡單的用戶認證，至此瀏覽器的基 ...


本文是區塊鏈瀏覽器系列的第五篇，項目完整代碼在這裡。

在上一篇文章中給瀏覽器增加了簡單的用戶認證，至此瀏覽器的基本功能就已經大致完成了。

在這片文章中，我將使用kratos對區塊鏈瀏覽器器進行重構，使之同時支持http和gRPC。

1. 項目結構

項目結構如下：

$ tree
.
├── api                                     
│   └── browser
│       └── v1
│           ├── block_grpc.pb.go
│           ├── block_http.pb.go
│           ├── block.pb.go
│           ├── block.proto
│           ├── browser_grpc.pb.go
│           ├── browser_http.pb.go
│           ├── browser.pb.go
│           └── browser.proto
├── cmd
│   └── example
│       ├── main.go
│       ├── wire_gen.go
│       └── wire.go
├── configs
│   └── config.yaml
├── Dockerfile
├── go.mod
├── go.sum
├── internal
│   ├── biz
│   │   ├── account.go
│   │   ├── biz.go
│   │   ├── README.md
│   │   └── repo.go
│   ├── conf
│   │   ├── conf.pb.go
│   │   └── conf.proto
│   ├── data
│   │   ├── account.go
│   │   ├── data.go
│   │   └── README.md
│   ├── db
│   │   ├── db.go
│   │   ├── mysql
│   │   │   └── mysql.go
│   │   ├── pg
│   │   │   └── pg.go
│   │   └── sqlite3
│   │       └── sqlite3.go
│   ├── server
│   │   ├── grpc.go
│   │   ├── http.go
│   │   └── server.go
│   ├── service
│   │   ├── block.go
│   │   ├── browser.go
│   │   ├── global.go
│   │   ├── README.md
│   │   ├── service.go
│   │   └── utils.go
│   └── utils
│       ├── putils.go
│       └── utils.go
├── LICENSE
├── Makefile
├── openapi.yaml
├── README.md
└── third_party
    ├── errors
    │   └── errors.proto
    ├── google
    │   ├── api
    │   │   ├── annotations.proto
    │   │   ├── client.proto
    │   │   ├── field_behavior.proto
    │   │   ├── httpbody.proto
    │   │   └── http.proto
    │   └── protobuf
    │       ├── any.proto
    │       ├── api.proto
    │       ├── compiler
    │       │   └── plugin.proto
    │       ├── descriptor.proto
    │       ├── duration.proto
    │       ├── empty.proto
    │       ├── field_mask.proto
    │       ├── source_context.proto
    │       ├── struct.proto
    │       ├── timestamp.proto
    │       ├── type.proto
    │       └── wrappers.proto
    ├── openapi
    │   └── v3
    │       ├── annotations.proto
    │       └── openapi.proto
    ├── README.md
    └── validate
        ├── README.md
        └── validate.proto

26 directories, 66 files
  • api 定義介面
    • block.prot：區塊上傳和區塊解析的介面
    • browser：用戶認證相關介面，包括用戶註冊、用戶登錄以及刷新token
  • cmd：本地調試使用，基於wire實現
  • configs：存放項目的配置文件
  • internal：業務邏輯實現
    • biz：類似DTO，封裝資料庫操作
    • conf：定義項目配置項
    • data：數據處理，目前主要是處理用戶認證相關數據
    • db：資料庫操作實現
    • server：註冊http和gRPC服務
    • service：實現瀏覽器業務邏輯
    • utils：工具類
  • third_party：依賴的第三方庫，主要是protobuf相關的第三方庫

2. api介面定義

block.proto中定義區塊上傳和解析操作：

syntax = "proto3";

package api.browser.v1;

option go_package = "mengbin92/browser/api/browser/v1;v1";

import "google/api/annotations.proto";

service Block {
  rpc UpChaincode(UploadRequest) returns (UploadResponse) {
    option (google.api.http) = {
      post : "/v1/block/up"
      body : "*"
    };
  };
  rpc ParseBlock(ParseRequest) returns (ParseResponse) {
    option (google.api.http) = {
      get : "/v1/block/parse"
    };
  }
}

message UploadRequest {
  string name = 1;
  bytes content = 2;
}

message UploadResponse {
  bool result = 1;
  string name = 2;
}

message ParseRequest {
  enum BlockOperation {
    BLOCK = 0;
    HEADER = 1;
    DATA = 2;
    CONFIG = 3;
    CHAINCODE = 4;
    ACTIONS = 5;
    TRANSACTION = 6;
    INPUT = 7;
    RWSET = 8;
    CHANNEL = 9;
    ENDORSEMENTS = 10;
    CREATOR = 11;
    METADATA = 12;
  }
  string name = 1;
  BlockOperation operation = 2;
}

message ParseResponse { bytes data = 1; }

message Endorser {
  string MSP = 1;
  string Name = 2;
}
message Endorsers { repeated Endorser endorsers = 1; }

browser.proto定義用戶註冊、登錄和token刷新操作：

syntax = "proto3";

package api.browser.v1;

option go_package = "mengbin92/browser/api/browser/v1;v1";

import "google/protobuf/timestamp.proto";
import "google/api/annotations.proto";

service Browser {
  rpc GetToken(Login) returns (LoginResponse) {
    option (google.api.http) = {
      post : "/v1/user/login"
      body : "*"
    };
  };
  rpc Regisger(Login) returns (LoginResponse) {
    option (google.api.http) = {
      post : "/v1/user/register"
      body : "*"
    };
  };
  rpc RefreshToken(RefreshRequest) returns (LoginResponse) {
    option (google.api.http) = {
      get : "/v1/user/refresh/{id}"
    };
  };
}

message User {
  uint64 id = 1;
  string name = 2;
  string password = 3;
  string salt = 4;
  google.protobuf.Timestamp create_at = 5;
  google.protobuf.Timestamp update_at = 6;
  google.protobuf.Timestamp delete_at = 7;
}

message LoginResponse {
  string token = 1;
  int64 expire = 2;
  uint64 id = 3;
  string username = 4;
}

message Login {
  string username = 1;
  string password = 2;
}

message RefreshRequest { uint64 id = 1; }

在項目根目錄下執行下麵命令即可完成框架生成：

# 生成對應的go文件
$ make api
# 生成service文件
$ kratos proto server api/browser/v1/block.proto -t internal/service
$ kratos proto server api/browser/v1/browser.proto -t internal/service

3. biz介紹

biz定義了用戶認證相關的介面，供service調用，介面內容如下：

type AccountRepo interface {
    // 用戶註冊
	Register(context.Context, string, string) (*v1.LoginResponse, error)
    // 用戶登錄，用於獲取token
	Login(context.Context, string, string) (*v1.LoginResponse, error)
    // 刷新token
	RefreshToken(context.Context, uint64) (*v1.LoginResponse, error)
}

4. conf介紹

conf定義項目的配置項，也是通過protobuf定義的：

syntax = "proto3";

package browser.api;

option go_package = "mengbin92/browser/internal/conf;conf";

import "google/protobuf/duration.proto";

message Bootstrap {
  Server server = 1;
  Log log = 2;
  Data data = 3;
}

message Server {
  message HTTP {
    string network = 1;
    string addr = 2;
    google.protobuf.Duration timeout = 3;
  }
  message GRPC {
    string network = 1;
    string addr = 2;
    google.protobuf.Duration timeout = 3;
  }
  enum AuthType{
    TOKENAUTH = 0;
    BASICAUTH = 1;
    NOAUTH = 2;
  }
  HTTP http = 1;
  GRPC grpc = 2;
  TLS tls = 3;
  // 2: no auth; 1: basic auth; default: 0, token auth
  AuthType auth_type = 4;
  Auth auth = 5;
}

message TLS {
  // 是否啟用tls
  bool enbale = 1;
  // 證書路徑
  string cert = 2;
  // 對應私鑰路徑
  string key = 3;
}

message Log {
  // 日誌級別設置
  // 支持debug(-1)、info(0)、warn(1)、error(2)、dpanic(3)、panic(4)、fatal(5)
  int32 level = 1;
  // 日誌輸出格式，支持json or console
  string format = 2;
}

message Database {
  // 資料庫類型：mysql、sqlite3、postgres
  string driver = 1;
  string source = 2;
  // 最大空閑連接數
  int64 max_idle_conn = 3;
  // 最大連接數
  int64 max_open_conn = 4;
  // 連接空閑超時參數
  google.protobuf.Duration conn_max_lifetime = 5;
}
message Redis {
  string network = 1;
  string addr = 2;
  string password = 3;
  int32 db = 4;
  google.protobuf.Duration dial_timeout = 5;
  google.protobuf.Duration read_timeout = 6;
  google.protobuf.Duration write_timeout = 7;
}

message Data {
  Database database = 1;
  Redis redis = 2;
}

message Auth {
  // jwt 秘鑰，暫未啟用
  string jwt_secret = 1;
  // token過期時間
  google.protobuf.Duration expire = 2;
}

5. data介紹

data中定義了AccountRepo結構，主要實現了biz中與資料庫交互的業務邏輯：

type AccountRepo struct {
	data      *Data
	log       *log.Helper
	jwtSecret string
	expire    time.Duration
}

func NewAccountRepo(data *Data, logger log.Logger, auth *conf.Auth) biz.AccountRepo {
	return &AccountRepo{
		data:      data,
		log:       log.NewHelper(logger),
		jwtSecret: auth.JwtSecret,
		expire:    auth.Expire.AsDuration(),
	}
}

func genSalt() string {
	uid, _ := uuid.NewRandom()
	return uid.String()
}

func (ar *AccountRepo) Register(ctx context.Context, username, password string) (*v1.LoginResponse, error) {
	salt := genSalt()
	u := &User{
		Name:     username,
		Password: utils.CalcPassword(password, salt),
		Salt:     salt,
	}
	if err := ar.data.db.Save(u).Error; err != nil {
		ar.log.Errorf("save user data error: %s", err.Error())
		return nil, errors.Wrap(err, "save user error")
	}

	now := time.Now()
	tokenString, err := ar.genToken(uint64(u.ID), now)
	if err != nil {
		ar.log.Errorf("create token error: %s", err.Error())
		return nil, errors.Wrap(err, "create token error")
	}

	return &v1.LoginResponse{
		Token:    tokenString,
		Expire:   now.Add(ar.expire).Unix(),
		Id:       uint64(u.ID),
		Username: u.Name,
	}, nil
}
func (ar *AccountRepo) Login(ctx context.Context, username, password string) (*v1.LoginResponse, error) {
	user, err := ar.getUserByName(ctx, username)
	if err != nil {
		ar.log.Errorf("get user from data error: %s", err.Error())
		return nil, errors.Wrap(err, "GetUserByName error")
	}

	if utils.CalcPassword(password, user.Salt) != user.Password {
		ar.log.Error("user name or password is incorrect")
		return nil, errors.New("user name or password is incorrect")
	}
	now := time.Now()
	tokenString, err := ar.genToken(user.Id, now)
	if err != nil {
		ar.log.Errorf("create token error: %s", err.Error())
		return nil, errors.Wrap(err, "create token error")
	}

	return &v1.LoginResponse{
		Token:    tokenString,
		Expire:   now.Add(ar.expire).Unix(),
		Id:       user.Id,
		Username: user.Name,
	}, nil
}
func (ar *AccountRepo) RefreshToken(ctx context.Context, id uint64) (*v1.LoginResponse, error) {
	user, err := ar.getUserById(ctx, id)
	if err != nil {
		ar.log.Errorf("get user from data error: %s", err.Error())
		return nil, errors.Wrap(err, "GetUserByName error")
	}

	now := time.Now()
	tokenString, err := ar.genToken(user.Id, now)
	if err != nil {
		ar.log.Errorf("create token error: %s", err.Error())
		return nil, errors.Wrap(err, "create token error")
	}

	return &v1.LoginResponse{
		Token:    tokenString,
		Expire:   now.Add(ar.expire).Unix(),
		Id:       user.Id,
		Username: user.Name,
	}, nil
}

6. service介紹

service主要實現api中定義的介面：

  • block.go：

    type BlockService struct {
	pb.UnimplementedBlockServer
}

func NewBlockService() *BlockService {
	return &BlockService{}
}

func (s *BlockService) UpChaincode(ctx context.Context, req *pb.UploadRequest) (*pb.UploadResponse, error) {
    // 與gin實現版本類似，客戶端上傳區塊數據存儲到服務端
	return &pb.UploadResponse{
		Result: true,
		Name:   req.Name,
	}, nil
}
func (s *BlockService) ParseBlock(ctx context.Context, req *pb.ParseRequest) (*pb.ParseResponse, error) {
    // 與gin實現版本邏輯類似，這裡就不再贅述了
	return &pb.ParseResponse{}, nil
}

  • browser.go：

    type BrowserService struct {
	account *biz.AccountUsecase
	pb.UnimplementedBrowserServer
}

func NewBrowserService(repo *biz.AccountUsecase, logger klog.Logger) *BrowserService {
	log = klog.NewHelper(logger)
	return &BrowserService{
		account: repo,
	}
}

func (s *BrowserService) GetToken(ctx context.Context, req *pb.Login) (*pb.LoginResponse, error) {
	return s.account.Login(ctx, req.Username, req.Password)
}
func (s *BrowserService) Regisger(ctx context.Context, req *pb.Login) (*pb.LoginResponse, error) {
	return s.account.Register(ctx, req.Username, req.Password)
}
func (s *BrowserService) RefreshToken(ctx context.Context, req *pb.RefreshRequest) (*pb.LoginResponse, error) {
	return s.account.RefreshToken(ctx, req.Id)
}
孟斯特

聲明：本作品採用署名-非商業性使用-相同方式共用 4.0 國際 (CC BY-NC-SA 4.0)進行許可，使用時請註明出處。
Author: mengbin
blog: mengbin
Github: mengbin92
cnblogs: 戀水無意


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • CSS基礎-3D變形
    原子化 CSS 框架 我記得很久之前有時候為了少寫些css，我們通常會有如下的樣板代碼 .block { display: block; } .flex { display:flex } .flex-center { align-items: center; justify-content: cen ...
  • 系統設計(架構師)指南1從零擴展到百萬用戶
    前言 前面說了很多Kafka的性能優點，有些童鞋要說了，這Kafka在企業開發或者企業級應用中要怎麼用呢？今天咱們就來簡單探究一下。 1、 使用 Kafka 進行消息的非同步處理 Kafka 提供了一個可靠的消息傳遞機制，使得企業能夠將不同組件之間的通信解耦，實現高效的非同步處理。在企業級應用中，可以通 ...
  • 演算法筆記 ① acwing C++基礎語法 | 全課程內容
    ## 2023年8月23日 ### #include `cstdio` 有兩個函數 printf，scanf 用於輸出和輸入 ```txt int : %d float : %f double : %lf char : %c long long : %lld ``` `iostream` 有 cin ...
  • Python 基礎面試第三彈
    1. 獲取當前目錄下所有文件名 import os def get_all_files(directory): file_list = [] # os.walk返回一個生成器，每次迭代時返回當前目錄路徑、子目錄列表和文件列表 for root, dirs, files in os.walk(dire ...
  • Go 數組
    數組用於在單個變數中存儲相同類型的多個值，而不是為每個值聲明單獨的變數。 聲明數組 在Go中，有兩種聲明數組的方式： 1. 使用`var`關鍵字： 語法 `var array_name = [length]datatype{values} // 這裡定義了長度` 或者 `var array_name ...
  • 各個數據類型的內置方法（字元串和列表）
    # 各個數據類型的內置方法 ## 整形和浮點型的內置方法 ```python # 1、定義： # 1.1 整型int的定義 age=10 # 本質age = int(10) # 1.2 浮點型float的定義 salary=3000.3 # 本質salary=float(3000.3) # 註意：名 ...
  • 關於指針與引用傳遞的效率問題
    # 引言 * 引用是C++的特性，指針是C語言的特性 * 關於這兩種特性的運行效率，人云亦云，好多人都說引用傳遞效率更高 * 以至於一些面試官在自己都不清楚的前提下麵試別人 * 筆者有幸遇到過，由於看過底層彙編，在面試官對我說引用效率更高的時候，導致我一度懷疑自己的記憶力 * 下麵我們就看看引用在匯 ...
  • Builder Pattern —— Structure Class
    # Core 建造者模式又稱為`生成器模式`，主要用於對複雜對象的構建、初始化，它可以將多個簡單的組件對象按順序一步步組裝起來，最終構建成一個複雜的成品對象。 與工廠系列模式不同的是，建造者模式的主要目的在於把煩瑣的**構建過程**從不同對象中抽離出來，使其脫離並獨立於產品類與工廠類，最終實現**用 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 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 ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類