tmaic saas 正在参加 2021 年度 OSC 中国开源项目评选,请投票支持!
tmaic saas 在 2021 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
2021 年度 OSC 中国开源项目评选 正在火热进行中,快来投票支持你喜欢的开源项目!
2021 年度 OSC 中国开源项目评选 >>> 中场回顾
tmaic saas 获得 2021 年度 OSC 中国开源项目评选「最佳人气项目」 !
授权协议 未知
开发语言 Google Go
操作系统 跨平台
软件类型 开源软件
所属分类 大数据数据存储
开源组织
地区 国产
投 递 者 pangfei
适用人群 未知
收录时间 2022-03-10

软件简介

tmaic saas 多租户(Multi-Tenant ),即一个Tenant,一个Database“的数据存储方式。隔离级别最高、最安全,说到底是要解决数据存储的问题,golang语言saas框架唯数不多的框架之一。

软件架构

数据模型

以下是例子

package models

import (
	"github.com/pangxianfei/framework/helpers/m"
	"github.com/pangxianfei/framework/helpers/ptr"
	"github.com/pangxianfei/framework/helpers/zone"
	"github.com/pangxianfei/framework/model"
)
type User struct {
    model.BaseModel
    ID        *uint      `gorm:"column:user_id;primary_key;auto_increment"`
    Name      *string    `gorm:"column:user_name;type:varchar(100)"`
    Email     *string    `gorm:"column:user_email;type:varchar(100);unique_index;not null"`
    Password  *string    `gorm:"column:user_password;type:varchar(100);not null"`
    CreatedAt *zone.Time `gorm:"column:user_created_at"`
    UpdatedAt zone.Time  `gorm:"column:user_updated_at"`
    DeletedAt *zone.Time `gorm:"column:user_deleted_at"`
}

func (user *User) TableName() string {
    return user.SetTableName("user")
}

func (user *User) SetNameAttribute(value interface{}) {
    user.Name = user.Email
}

func (user *User) GetUpdatedAtAttribute(value interface{}) interface{} {
    return user.UpdatedAt //查询后这里可以其他处理,如格式化处理,如果是时间time 可以格式成 2020-10-01 18:00:20
}

生成公钥文件

tmaic.CreateRsaKey()

系统函数

加密解密函数

公钥加密

s,_:= tmaic.Encryption("Golang使用RSA进行公钥加密私钥解密,私钥加密公钥解密的实现")

私钥解密

dd,_ := tmaic.Decrypt(s)

私钥加密

s,_:= tmaic.PrivateEncryption("Golang使用RSA进行公钥加密私钥解密,私钥加密公钥解密的实现")

公钥解密

dd,_ := tmaic.PublicDecrypt(s)

校验密码是否正确

user.Password:用户密码(已加密)

requestData.Password:要校验的密码(明文)

if !crypt.BcryptCheck(user.Password, requestData.Password) error{
    
    return "返回提示信息"
}

注意事项:如果要使用 NSQ 队列的,不用将包注释

导入包:

"github.com/pangxianfei/framework/queue"

"tmaic/app/events"

"tmaic/app/jobs"

"tmaic/app/listeners"

以下去掉注释即可:

//queue.Initialize()

//jobs.Initialize()

//events.Initialize()

//listeners.Initialize()

NSQ安装请参考:https://nsq.io/overview/quick_start.html

nsq启动

1.nsqlookupd

2.nsqd --lookupd-tcp-address=127.0.0.1:4160

3.nsqadmin --lookupd-http-address=127.0.0.1:4161

执行以上命令后:http://127.0.0.1:4171 可查看监控台

队列demo (test)

*** 详情见工程项目下

入列(我们常说的写入 topic,生产者),以下写入topic例子

	test := events.Test{}

	testparam := &pbs.Test{
		Id: uint32(userId),
	}
	test.SetParam(testparam)

	if errs := hub.Emit(&test); errs != nil {
		log.Info("user test", tmaic.Output{"event": test, "errors": errs})
	}

出列(启动一个观察者)

 
 
func init() {
	hub.Register(&Test{})
}

type Test struct {
	user models.User
	hub.Listen
}

func (user *Test) Name() hub.ListenerName {
	return "add-test" //监听器名称 后面我们会用到
}

func (user *Test) Subscribe() (eventPtrList []hub.Eventer) {
	log.Debug("Subscribe-test")
	return []hub.Eventer{
		&events.Test{},
	}

}

func (user *Test) Construct(paramPtr proto.Message) error {
	/** 第一执行这里
	  业务代码
	*/
	log.Debug("Construct-test")
	return nil
}
func (user *Test) Handle() error {
	/**第二执行这里
	 最终实现业务逻辑 :比如发邮件、消息推送、短信通知等 这些业务通常封装在 service 层,这里只是建议
	*/
	
	// 更新
	t := users.UserService.Get(cast.ToInt64(user.ID))
	t.Email = user.Email //test 其实没有这个字段 根据需要自行组织
	t.Name = user.Name   //test 其实没有这个字段 根据需要自行组织
	_ = users.UserService.Update(t)
	
	log.Debug("Handle-test")
	return nil
}

实现消费,在根目录与main.go同级,

go run artisan.go queue:listen test-add //test-add 是Name() 返回的 配合supervisor进程守护

类型转化助手

ToInt64

cast.ToInt64()

ToInt32

cast.ToInt32()

ToFloat32

cast.ToFloat32()

更多方法 查看cast包

打印

tmaic.Dump(mugs)

    mugs := map[string]interface{} {
        "password2" : map[string]string {
        "password3" : "The name cannot be empty",
        },
    }
    
    //效果
    {
        "password2": {
            "password3": "The name cannot be empty"
        }
    }
    
 

性能测试

虚拟机环境下:

avatar

压力测试

ab -c 1000 -n 5000 -k http://127.0.0.1/all

avatar

安装教程

  1. git clone git@gitee.com:pangxianfei/tmaic.git
  2. go mod init // 初始化go mod 包管理
  3. go mod tidy // 加载依赖包
  4. go mod vendor // 将依赖包拷贝到项目目录中去
  5. go run main.go
展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论

点击加入讨论🔥(2)
暂无内容
发表了博客
{{o.pubDate | formatDate}}

{{formatAllHtml(o.title)}}

{{parseInt(o.replyCount) | bigNumberTransform}}
{{parseInt(o.viewCount) | bigNumberTransform}}
没有更多内容
暂无内容
发表了问答
{{o.pubDate | formatDate}}

{{formatAllHtml(o.title)}}

{{parseInt(o.replyCount) | bigNumberTransform}}
{{parseInt(o.viewCount) | bigNumberTransform}}
没有更多内容
暂无内容
2 评论
4 收藏
分享
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部
返回顶部
顶部