租房專案獲取地區資訊服務-有解無憂

流程

獲取地域資訊流程

介面

# Request: 
method: GET
url: api/v1.0/areas
# data:
no input data

# Response:
# 回傳成功
{
    "errno": 0,
    "errmsg": "ok",
    "data": [
        {"aid": 1, "aname": "東城區"},
        {"aid": 2, "aname": "西城區"},
        ...
    ]
}
        
# 回傳失敗
{
	"errno": "400x", // 狀態碼
    "errmsg": "狀態錯誤資訊"
}

創建命令

$ micro new --type "srv" ihome/GetArea

修改名稱 example.proto 為 getarea.proto，上一級檔案夾名稱也由 example 改為 getarea

lpgit@lpgit-virtual-machine:~/go/src/ihome/GetArea/proto$ tree
.
└── getarea
    └── getarea.proto

1 directory, 1 files

Redis 的安裝

具體 Redis 的安裝與使用，請查看此文章： Redis 簡介與安裝

安裝 Redis

下載

$ wget http://download.redis.io/releases/redis-6.0.5.tar.gz

或者進入網址下載指定版本: http://download.redis.io/releases/

解壓

$ tar xzf redis-6.0.5.tar.gz

進入

$ cd redis-6.0.5

編譯

$ make

安裝

$ sudo make install

驗證

$ redis-cli
Could not connect to Redis at 127.0.0.1:6379: Connection refused
not connected>

啟動 Redis

將 redis 安裝包中的 redis.conf 檔案復制到專案中 ihome 服務的 conf 檔案夾當中

然后，修改 redis.conf 檔案

# 69 行左右
bind 127.0.0.1 當前主機ip
# 136 行左右修改為 yes，表示守護行程啟動
daemonize yes

在 ihome 服務中創建一個啟動檔案

$ sudo vim server.sh

檔案內容

redis-server ./conf/redis.conf

給檔案賦予啟動權限

$ chmod 777 server.sh

安裝 Go語言的 Redis api 驅動

$ go get -v -u github.com/gomodule/redigo/redis
$ go get -v -u github.com/garyburd/redigo

安裝 beego 的 cache 快取模塊

$ go get -v -u github.com/astaxie/beego/cache

撰寫 ptoro 檔案

syntax = "proto3";

package go.micro.srv.GetArea;

service Example {
  rpc GetArea(Request) returns (Response) {}
}

message Request {

}

message Response {
  // 回傳錯誤碼
  string ErrNo = 1;
  // 回傳錯誤資訊
  string ErrMsg = 2;
  // 回傳資料型別
  message Area {
    int32 Aid = 1;
    string Aname = 2;
  }
  // 用自定義型別回傳的陣列
  repeated Area Data = https://www.cnblogs.com/lpgit/p/3;
}

$ cd /home/lpgit/go/src/ihome/GetArea
$ protoc --proto_path=. --go_out=. --micro_out=. proto/getarea/getarea.proto

Web 端

修改 main.go 檔案：添加路由

// 獲取地區資訊
rou.GET("/api/v1.0/areas", handler.GetArea)

handler.go 增加 GetArea 函式

package handler

import (
	"context"
	"encoding/json"
	"github.com/julienschmidt/httprouter"
	"github.com/micro/go-grpc"
	getarea "ihome/GetArea/proto/getarea"
	"ihome/ihomeWeb/models"
	"ihome/ihomeWeb/utils"
	"net/http"
)

// 獲取地區資訊
func GetArea(w http.ResponseWriter, r *http.Request, _ httprouter.Params) {
	// 創建新的 gRPC 回傳句柄
	server := grpc.NewService()
	// 服務初始化
	server.Init()

	// 創建獲取地區的服務并且回傳句柄
	exampleClient := getarea.NewExampleService("go.micro.srv.GetArea", server.Client())
	// 呼叫函式并且回傳資料
	rsp, err := exampleClient.GetArea(context.TODO(), &getarea.Request{})
	if err != nil {
		return
	}
	// 創建回傳型別的切片
	var areas []models.Area
	// 回圈讀取服務回傳的資料
	for _, value := range rsp.Data {
		areas = append(areas, models.Area{Id: int(value.Aid), Name: value.Aname})
	}
	// 創建回傳資料 map
	response := map[string]interface{}{
		"errno":  rsp.ErrNo,
		"errmsg": rsp.ErrMsg,
		"data":   areas,
	}
	// 注意
	w.Header().Set("Content-Type", "application/json")

	// 將回傳的資料 map 發送給前端
	if err := json.NewEncoder(w).Encode(response); err != nil {
		http.Error(w, err.Error(), 503)
		return
	}
}

Server 端

修改 main.go 內容，之后每次都和下面一樣進行修改

package main

import (
	"github.com/micro/go-grpc"
	"github.com/micro/go-log"
	"github.com/micro/go-micro"
	"ihome/GetArea/handler"
    // 此處修改
	getarea "ihome/GetArea/proto/getarea"
)

func main() {
	// New Service
    // 此處修改：micro 改為 grpc
	service := grpc.NewService(
		micro.Name("go.micro.srv.GetArea"),
		micro.Version("latest"),
	)

	// Initialise service
	service.Init()

	// Register Handler
    // 此處修改 example 改為 getarea
    // handler.Example 改為 handler.Server
	getarea.RegisterExampleHandler(service.Server(), new(handler.Server))

	// Run service
	if err := service.Run(); err != nil {
		log.Fatal(err)
	}
}

handler 下 example.go 檔案

package handler

import (
	"context"
	"encoding/json"
	"github.com/astaxie/beego/cache"
	"github.com/astaxie/beego/orm"
	"ihome/ihomeWeb/models"
	"ihome/ihomeWeb/utils"
	"time"

	_ "github.com/astaxie/beego/cache/redis"
	_ "github.com/garyburd/redigo/redis"
	_ "github.com/gomodule/redigo/redis"
	getarea "ihome/GetArea/proto/getarea"
)

type Server struct{}

func (e *Server) GetArea(ctx context.Context, req *getarea.Request, rsp *getarea.Response) error {
	// 初始化 錯誤碼
	rsp.ErrNo = utils.RECODE_OK
	rsp.ErrMsg = utils.RecodeText(rsp.ErrNo)

	// 1. 從快取中獲取資料
	// 準備連接 redis 資訊
	redisConf := map[string]string{
		"key":   utils.G_server_name,
		"conn":  utils.G_redis_addr + ":" + utils.G_redis_port,
		"dbNum": utils.G_redis_dbnum,
	}

	// 將 map 轉化為 json
	redisConfJson, _ := json.Marshal(redisConf)
	// 創建 redis 句柄
	bm, err := cache.NewCache("redis", string(redisConfJson))
	if err != nil {
		rsp.ErrNo = utils.RECODE_DBERR
		rsp.ErrMsg = utils.RecodeText(rsp.ErrNo)
		return nil
	}
	// 獲取資料
	areaInfo := bm.Get("areaInfo")
	if areaInfo != nil {
		// 快取中有資料
		var areas []map[string]interface{}
		// 將獲取到的資料解碼
		json.Unmarshal(areaInfo.([]byte), &areas)

		for _, value := range areas {
			rsp.Data = https://www.cnblogs.com/lpgit/p/append(rsp.Data, &getarea.Response_Area{Aid: int32(value["aid"].(float64)), Aname: value["aname"].(string)})
		}
		return nil
	}

	// 2. 快取中沒有資料從 mysql 中查找資料
	o := orm.NewOrm()
	var areas []models.Area
	num, err := o.QueryTable("Area").All(&areas)
	if err != nil {
		rsp.ErrNo = utils.RECODE_DBERR
		rsp.ErrMsg = utils.RecodeText(rsp.ErrNo)
		return nil
	}
	if num <= 0 {
		rsp.ErrNo = utils.RECODE_NODATA
		rsp.ErrMsg = utils.RecodeText(rsp.ErrNo)
		return nil
	}

	// 3. 將查找到的資料存到快取中
	// 將獲取到的資料轉化為 json 格式
	areasJson, _ := json.Marshal(areas)
	err = bm.Put("areaInfo", areasJson, 3600*time.Second)
	if err != nil {
		rsp.ErrNo = utils.RECODE_DBERR
		rsp.ErrMsg = utils.RecodeText(rsp.ErrNo)
		return nil
	}

	// 4. 將查找到的資料 按照 proto 的格式 發送給前端
	for _, value := range areas {
		rsp.Data = append(rsp.Data, &getarea.Response_Area{Aid: int32(value.Id), Aname: value.Name})
	}
	return nil
}

李培冠博客

歡迎訪問我的個人網站：

李培冠博客：lpgit.com

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/328.html

標籤：Go

上一篇：[Go]GO語言實戰專案-gin框架上傳圖片檔案

下一篇：ent orm筆記2---schema使用(上)

租房專案 獲取地區資訊服務

流程

介面