relationmicro

社交服务

项目结构

│  handler.go - kitex对外暴露的服务接口
│  main.go    - 主方法, 资源初始化: 注册中心、数据库、线程池等资源
│
├─idl
│      relation.thrift      - idl定义文件
│
├─kitex_gen   - kitex自动生成代码
│  └─relation
│      │  k-consts.go
│      │  k-relation.go
│      │  relation.go
│      │
│      ├─combineservice     - 汇总各模块对外提供
│      │      client.go
│      │      combineservice.go
│      │      invoker.go
│      │      server.go
│      │
│      ├─messageservice     - 消息模块
│      │      client.go
│      │      invoker.go
│      │      messageservice.go
│      │      server.go
│      │
│      └─relationservice    - 关注模块
│              client.go
│              invoker.go
│              relationservice.go
│              server.go
│
├─kitex_server  - 封装其他服务
│      initmicro.go     - 从etcd获取其他服务客户端
│      user_service.go  - 封装usermicro服务接口为本地方法
│      user_service_test.go
│
├─service       - 核心业务逻辑
│      follower_service.go          - 粉丝
│      follower_service_test.go
│      follow_service.go            - 关注
│      follow_service_test.go
│      message_service.go           - 消息
│      message_service_test.go
│      userinfo_service.go
│      user_service.go              - 用户信息
│
└─util
    │  lua_util.go                  - lua脚本相关
    │  redis_constant.go            - redis键生成等固定规则
    │  redis_util.go                - redis调用
    │  redis_util_test.go
    │  str2time_util.go
    │  type_convert_util.go
    │
    └─lua
            follow
            follower

项目运行

运行环境

1. linux使用windows需配置好远程开发, 因win版的kitex自动生成有bug
2. go1.19.5
3. redis > 2.6.0 支持 EVALSHA, > 5.0 支持stream
   • 关注用到EVALSHA
   • 消息用到stream
4. 其他依赖直接拉取最新的即可 go get & go mod tidy

项目启动需要配置的资源

1. etcd
2. redis
3. usermicro 不启动user服务也能正常跑起来, 但查询列表等功能需要查询user服务，没有user服务会查询失败
   • 引用usermicro服务go get github.com/ClubWeGo/usermicro@latest 上述配置均能再main方法里找到

其他

idl 我们使用的kitex+thrift

如需要加入新的rpc接口, 需通过编写thrift文件和kitex命令自动生成相关代码

kitex官方文档

聚合message的方法到relation的生成代码中的方案 https://www.cloudwego.io/zh/docs/kitex/tutorials/code-gen/combine_service/

使用combine-service 合并多个分块的service kitex --combine-service -service github.com/ClubWeGo/relationmicro -module github.com/ClubWeGo/relationmicro ./idl/relation.thrift

go get github.com/cloudwego/kitex@latest && go mod tidy

注意生成的handler中是CombineServiceImpl