go-micro微服務(wù)domain層開發(fā)示例詳解
更新時間：2023年01月10日 09:58:27 作者：夏沫的夢
這篇文章主要為大家介紹了go-micro微服務(wù)domain層開發(fā)示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
一 domain層介紹說明
- domain層專注于數(shù)據(jù)庫數(shù)據(jù)領(lǐng)域開發(fā)，我們把數(shù)據(jù)庫相關(guān)操作全部寫在domain層。
- model層：數(shù)據(jù)表字段定義與開發(fā)
- repository層：數(shù)據(jù)庫數(shù)據(jù)CURD操作
- service層：數(shù)據(jù)庫相關(guān)業(yè)務(wù)操作
- 對于復(fù)雜的業(yè)務(wù)操作，這樣可以使業(yè)務(wù)邏輯更加清晰，有利于后期開發(fā)與維護。
二 model層開發(fā)
- 在model目錄下新建 user.go 文件
package model
import (
"time"
)
type User struct {
//主鍵
ID int64 `gorm:"primary_key;not_null;auto_increment" json:"id"`
UserID int64 `gorm:"unique_index;not_null" json:"user_id"`
UserName string `gorm:"unique_index;not_null" json:"username"`
FirstName string `json:"first_name"`
LastName string `json:"last_name"`
PassWord string `json:"password"`
Permission int64 `json:"permission"`
CreateDate time.Time `json:"create_date"`
UpdateDate time.Time `json:"update_date"`
IsActive int64 `json:"is_active"`
Email string `json:"email"`
}
三 repository層開發(fā)
在repository層開發(fā)目錄下新建 user_repository.go 文件
repository層包含功能：
- InitTable 初始化數(shù)據(jù)表
- FindUserByName 根據(jù)用戶名稱查找用戶信息
- FindUserByID 根據(jù)用戶ID查找用戶信息
- CreateUser 創(chuàng)建用戶
- DeleteUserByID 根據(jù)用戶ID刪除用戶
- UpdateUser 更新用戶信息
- FindAll 查找所有用戶
- ResetPwd 重置密碼
- GetPermission 獲取權(quán)限
- UpdatePermission 修改權(quán)限
- EnableUser 啟用賬號
- DisableUser 禁用賬號
package repository
import (
"account/domain/model"
"github.com/jinzhu/gorm"
)
type IUserRepository interface {
// InitTable 初始化數(shù)據(jù)表
InitTable() error
// FindUserByName 根據(jù)用戶名稱查找用戶信息
FindUserByName(string) (*model.User, error)
// FindUserByID 根據(jù)用戶ID查找用戶信息
FindUserByID(int64) (*model.User, error)
// CreateUser 創(chuàng)建用戶
CreateUser(*model.User) (int64, error)
// DeleteUserByID 根據(jù)用戶ID刪除用戶
DeleteUserByID(int64) error
// UpdateUser 更新用戶信息
UpdateUser(*model.User) error
// FindAll 查找所有用戶
FindAll() ([]model.User, error)
// ResetPwd 重置密碼
ResetPwd(int64, string) error
// GetPermission 獲取權(quán)限
GetPermission(int64) (int64, error)
// UpdatePermission 修改權(quán)限
UpdatePermission(int64, int64) error
// EnableUser 啟用賬號
EnableUser(int64) error
// DisableUser 禁用賬號
DisableUser(int64) error
}
// NewUserRepository 創(chuàng)建UserRepository
func NewUserRepository(db *gorm.DB) IUserRepository {
return &UserRepository{mysqlDb: db}
}
type UserRepository struct {
mysqlDb *gorm.DB
}
// InitTable 初始化表
func (u *UserRepository) InitTable() error {
return u.mysqlDb.CreateTable(&model.User{}).Error
}
// FindUserByName 根據(jù)用戶名稱查找用戶信息
func (u *UserRepository) FindUserByName(name string) (user *model.User, err error) {
user = &model.User{}
return user, u.mysqlDb.Where("username=?", name).Find(user).Error
}
// FindUserByID 根據(jù)用戶ID查找用戶信息
func (u *UserRepository) FindUserByID(userID int64) (user *model.User, err error) {
user = &model.User{}
return user, u.mysqlDb.Where("user_id=?", userID).Find(user).Error
}
// CreateUser 創(chuàng)建用戶
func (u *UserRepository) CreateUser(user *model.User) (userID int64, err error) {
return user.ID, u.mysqlDb.Create(user).Error
}
// DeleteUserByID 刪除用戶
func (u *UserRepository) DeleteUserByID(userID int64) error {
return u.mysqlDb.Where("user_id=?", userID).Delete(&model.User{}).Error
}
// UpdateUser 更新用戶信息
func (u *UserRepository) UpdateUser(user *model.User) error {
return u.mysqlDb.Model(user).Update(&user).Error
}
// FindAll 查找所有用戶
func (u *UserRepository) FindAll() (userAll []model.User, err error) {
return userAll, u.mysqlDb.Find(&userAll).Error
}
// ResetPwd 重置密碼
func (u *UserRepository) ResetPwd(userID int64, Pwd string) error {
return u.mysqlDb.Where("user_id=?",userID).Update(model.User{PassWord:Pwd}).Error
}
// GetPermission 獲取權(quán)限
func (u *UserRepository) GetPermission(userID int64) (Permission int64, err error) {
var user model.User
return user.Permission,u.mysqlDb.Where("user_id=?",userID).Find(user).Error
}
// UpdatePermission 修改權(quán)限
func (u *UserRepository) UpdatePermission(userID int64, Permission int64) error {
return u.mysqlDb.Where("user_id=?",userID).Update(model.User{Permission:Permission}).Error
}
// EnableUser 啟用賬號
func (u *UserRepository) EnableUser(userID int64) error {
return u.mysqlDb.Where("user_id=?",userID).Update(&model.User{IsActive: 1}).Error
}
// DisableUser 禁用賬號
func (u *UserRepository) DisableUser(userID int64) error {
return u.mysqlDb.Where("user_id=?",userID).Update(&model.User{IsActive: 0}).Error
}
四 service層開發(fā)
在service目錄下新建 user_service.go 文件
service層包含功能：
- AddUser 插入用戶
- DeleteUser 刪除用戶
- UpdateUser 更新用戶
- FindUserByName 根據(jù)用戶名稱查找用戶信息
- FindUserByID 根據(jù)用戶ID查找用戶信息
- CheckPwd 比對賬號密碼是否正確
- ResetPwd 重置密碼
- GetPermission 獲取權(quán)限
- UpdatePermission 修改權(quán)限
- EnableUser 啟用賬號
- DisableUser 禁用賬號
package service
import (
"account/domain/model"
"account/domain/repository"
"errors"
"golang.org/x/crypto/bcrypt"
)
type IUserService interface {
// AddUser 插入用戶
AddUser(user *model.User) (int64, error)
// DeleteUser 刪除用戶
DeleteUser(int64) error
// UpdateUser 更新用戶
UpdateUser(user *model.User, isChangePwd bool) (err error)
// FindUserByName 根據(jù)用戶名稱查找用戶信息
FindUserByName(string) (*model.User, error)
// FindUserByID 根據(jù)用戶ID查找用戶信息
FindUserByID(int64) (*model.User, error)
// CheckPwd 比對賬號密碼是否正確
CheckPwd(userName string, pwd string) (isOk bool, err error)
// ResetPwd 重置密碼
ResetPwd(int64, string) error
// GetPermission 獲取權(quán)限
GetPermission(int64) (int64, error)
// UpdatePermission 修改權(quán)限
UpdatePermission(int64, int64) error
// EnableUser 啟用賬號
EnableUser(int64) error
// DisableUser 禁用賬號
DisableUser(int64) error
}
// NewUserService 創(chuàng)建實例
func NewUserService(userRepository repository.IUserRepository) IUserService {
return &UserService{UserRepository: userRepository}
}
type UserService struct {
UserRepository repository.IUserRepository
}
// GeneratePassword 加密用戶密碼
func GeneratePassword(userPassword string) ([]byte, error) {
return bcrypt.GenerateFromPassword([]byte(userPassword), bcrypt.DefaultCost)
}
// ValidatePassword 驗證用戶密碼
func ValidatePassword(userPassword string, hashed string) (isOk bool, err error) {
if err = bcrypt.CompareHashAndPassword([]byte(hashed), []byte(userPassword)); err != nil {
return false, errors.New("密碼比對錯誤")
}
return true, nil
}
// AddUser 插入用戶
func (u *UserService) AddUser(user *model.User) (userID int64, err error) {
pwdByte, err := GeneratePassword(user.PassWord)
if err != nil {
return user.ID, err
}
user.PassWord = string(pwdByte)
return u.UserRepository.CreateUser(user)
}
// DeleteUser 刪除用戶
func (u *UserService) DeleteUser(userID int64) error {
return u.UserRepository.DeleteUserByID(userID)
}
// UpdateUser 更新用戶
func (u *UserService) UpdateUser(user *model.User, isChangePwd bool) (err error) {
if isChangePwd {
pwdByte, err := GeneratePassword(user.PassWord)
if err != nil {
return nil
}
user.PassWord = string(pwdByte)
}
return u.UserRepository.UpdateUser(user)
}
// FindUserByName 根據(jù)用戶名稱查找用戶信息
func (u *UserService) FindUserByName(userName string) (user *model.User, err error) {
return u.UserRepository.FindUserByName(userName)
}
// FindUserByID 根據(jù)用戶名稱查找用戶信息
func (u *UserService) FindUserByID(userId int64) (user *model.User, err error) {
return u.UserRepository.FindUserByID(userId)
}
// CheckPwd 比對賬號密碼是否正確
func (u *UserService) CheckPwd(userName string, pwd string) (isOk bool, err error) {
user, err := u.UserRepository.FindUserByName(userName)
if err != nil {
return false, err
}
return ValidatePassword(pwd, user.PassWord)
}
// ResetPwd 重置密碼
func (u *UserService) ResetPwd(userID int64, pwd string) error {
return u.UserRepository.ResetPwd(userID,pwd)
}
// GetPermission 獲取權(quán)限
func (u *UserService) GetPermission(userID int64) (permission int64, err error) {
return u.UserRepository.GetPermission(userID)
}
// UpdatePermission 修改權(quán)限
func (u *UserService) UpdatePermission(userID int64, permission int64) error {
return u.UserRepository.UpdatePermission(userID,permission)
}
// EnableUser 啟用賬號
func (u *UserService) EnableUser(userID int64) error {
return u.UserRepository.EnableUser(userID)
}
// DisableUser 禁用賬號
func (u *UserService) DisableUser(userID int64) error {
return u.UserRepository.DisableUser(userID)
}
最后
至此，go-micro微服務(wù)domain層開發(fā)工作就正式完成，接下來就開始consul配置、注冊中心的代碼編寫了，更多關(guān)于go-micro微服務(wù)domain層的資料請關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
這篇文章主要介紹了Go?select使用與底層原理講解，select是Go提供的IO多路復(fù)用機制，可以用多個cas同時監(jiān)聽多個channl的讀寫狀態(tài)，相關(guān)內(nèi)容需要的朋友可以參考一下2022-07-07
golang包循環(huán)引用的幾種解決方案總結(jié)
golang有包循環(huán)引用問題,用過的應(yīng)該都知道,下面這篇文章主要給大家介紹了關(guān)于golang包循環(huán)引用的幾種解決方案,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2022-09-09
這篇文章主要介紹了go語言實現(xiàn)AES加密的方法,實例分析了Go語言的加密技巧,需要的朋友可以參考下2015-03-03
這篇文章主要介紹了Go語言聲明一個多行字符串的變量的方法和示例，非常簡單實用，有需要的小伙伴可以參考下。2015-04-04
這篇文章主要介紹了GO語言映射（Map）用法,以實例形式較為詳細的分析了針對映射的創(chuàng)建、填充、遍歷及修改等操作的技巧,需要的朋友可以參考下2014-12-12
這篇文章主要為大家介紹了go?defer延遲調(diào)用的使用場景示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-05-05
這篇文章主要為大家介紹了go語言編程實現(xiàn)遞歸函數(shù)示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-09-09
函數(shù)構(gòu)成代碼執(zhí)行的邏輯結(jié)構(gòu)。在Go語言中，函數(shù)的基本組成為：關(guān)鍵字func、函數(shù)名、參數(shù)列表、返回值、函數(shù)體和返回語句。2018-10-10
我放棄Python轉(zhuǎn)Go語言的9大理由（附優(yōu)秀書籍推薦）
這篇文章主要給大家介紹了關(guān)于我放棄Python轉(zhuǎn)Go語言的9大理由，以及給大家推薦了6本優(yōu)秀的go語言書籍，對同樣想學(xué)習(xí)golang的朋友們具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。2017-10-10
使用go net實現(xiàn)簡單的redis通信協(xié)議
本文主要介紹了go net實現(xiàn)簡單的redis通信協(xié)議，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-12-12