• service
  • 定义需要调用的rpc接口
• message
  • 定义所有rpc接口中输入和输出用到的结构，以及实现它们过程中的结构

• 定义服务端口
• 定义仓库接口并实现
• 定义微服务service，所有sevice的第一个参数为 ctx context.Context，用于保存上下文信息
• main：启动网络监听，启动微服务
  • 启动网络监听：listener, err := net.Listen("tcp", PORT)
  • 启动grpc服务端：server := grpc.NewServer()
  • 为微服务注册数据体：pb.RegisterShippingServiceServer(server, &service的interface的struct)
  • 开启监听：server.Serve(listener)

• 连接到服务端口：conn, err := grpc.Dial(ADDRESS, grpc.WithInsecure)
• 初始化grpc客户端：client := pb.NewShippingServiceClient(conn)
• 远程调用服务：client.service_func(xxxx)

使用.proto定义service 和 message

• service
  • 定义需要调用的rpc接口
• message
  • 定义所有rpc接口中输入和输出用到的结构，以及实现它们过程中的结构

rpc服务：使用go-micro【需要修改go.mod---->https://www.icode9.com/content-4-729280.html，否则直接按照教程会出错】

• 不用定义服务端口
• 仓库接口实现相同
• 定义微服务的service中把pb.Response返回值放到了函数的入参里
• main：启动网络监听，启动微服务

  • 微服务注册流程并初始化

    server := micro.NewService(…Option)
    server.Init()

  • 为微服务注册数据体

    pb.RegisterShippingServiceHandler(server.Server(), &service的interface的struct)

  • 启动

    server.run()

在client的代码中远程调用server内定义的服务

• 先定义客户端对应的服务并初始化

  service := micro.NewService(micro.Name("go.micro.srv.consignment"))
  service.Init()

• 注册为service的客户端

  client := pb.NewShippingServiceClient("go.micro.srv.consignment", service.Client())

• 接下去就可以调用相关服务端函数

consignment-service | consignment-cli | vessel-service

• 功能描述
  • 这三个是一起的，两个服务端一个客户端
  • consignment客户端向consignment服务端请求托运服务，consignment服务端向vessel服务端请求货轮服务
• 注意点
  • 依赖的数据库是mongoDB，mongoDB是用database/collection来存储数据的，在docker-compose.yaml中定义了上面的服务以其为依赖，因此会先启动它。打开mongoDB的会话在repository.go中的collection()接口上，直接定位到collection进行增查

user-service | user-cli

• 功能描述

  • 这两个是一起的，一个服务端一个客户端
  • user-cli向user-service提供个人信息，user-service负责记录信息到postgres数据库中

• 注意点

  • 依赖的数据库是postgres，默认的用户名/数据库名/密码都是postgres，但是在docker-compose.yaml中自定义了相关的信息

  • 启动postgres特别要注意：目前不知道原因在哪，需要启动两次postgres，即第一次运行user-service会报错如下，需要再次运行一次【此时postgres已经在运行了】才能正常连接上数据库

    meloneater@meloneater-ubuntu:~/gopath/src/shippy$ docker-compose run user-service
    Creating postgres ... done
    Creating shippy_user-service_run ... done
    Host:database	port:5432	User:userService	Password:12345DbName:userServiceDB
    &{RWMutex:{w:{state:0 sema:0} writerSem:0 readerSem:0 readerCount:0 readerWait:0} Value:<nil> Error:<nil> RowsAffected:0 db:0xc0005ca000 blockGlobalUpdate:false logMode:0 logger:{LogWriter:0xc000189db0} search:<nil> values:{mu:{state:0 sema:0} read:{v:<nil>} dirty:map[] misses:0} parent:0xc0005c00d0 callbacks:0x1e648e0 dialect:0xc0005ac060 singularTable:false nowFuncOverride:<nil>}
    err: dial tcp 172.18.0.5:5432: connect: connection refused
    2021-06-02 12:13:22.045343 I | connect error: dial tcp 172.18.0.5:5432: connect: connection refused
    ERROR: 1
    
    meloneater@meloneater-ubuntu:~/gopath/src/shippy$ docker-compose run user-service
    Creating shippy_user-service_run ... done
    Host:database	port:5432	User:userService	Password:12345DbName:userServiceDB
    &{RWMutex:{w:{state:0 sema:0} writerSem:0 readerSem:0 readerCount:0 readerWait:0} Value:<nil> Error:<nil> RowsAffected:0 db:0xc000600000 blockGlobalUpdate:false logMode:0 logger:{LogWriter:0xc000189db0} search:<nil> values:{mu:{state:0 sema:0} read:{v:<nil>} dirty:map[] misses:0} parent:0xc000606000 callbacks:0x1e648e0 dialect:0xc000604000 singularTable:false nowFuncOverride:<nil>}
    err: <nil>
    2021-06-02 12:13:26.046013 I | Transport [http] Listening on [::]:41921
    2021-06-02 12:13:26.046124 I | Broker [http] Connected to [::]:38709
    2021-06-02 12:13:26.046527 I | Registry [mdns] Registering node: go.micro.srv.user-c0f4d48d-7e77-4438-a42e-1fba51024ca1

  • 还有一个没解决的问题：就是micro.Flags的解析，从命令行解析出的数据都是空的，不知道为什么，所以先写死了value

总体注意点

• 修改完代码后要make build生成新的二进制文件，再用docker-compose build去利用Dockerfile生成images
• 在最外层文件夹写了个Makefile是为了方便一些重构和运行操作

在user-service中，使用哈希加密用户密码再存储，加密结果如下一堆字符串

userServiceDB=# select * from users
userServiceDB-# where email = '[email protected]';
                  id                  |  ... |                           password     
--------------------------------------+  ... +----------------------------------------
 32c67401-2688-4e2d-b05a-f4e8506974cd |  ... | $2a$10$tKWwVgHMa9UQbp0ble/5juraBYrrIYpOy/zHOiX0jpGoogugJuP.u
 bea161a2-5ab0-405a-a7f3-5c90c01f6a6b |  ... | $2a$10$0QTpmhNx4U215/XZEzznnuFi75snT0TXrW9kjI78XlB6/MiylrCmy 
 8f689475-5204-452a-a066-2450f286a695 |  ... | $2a$10$niGsFowPHLgRBrp5TKzEsOrQd/8D/AU0HPnMgDB5rDGTNYtqigs2q
 353cb13d-27a8-4a7a-8e3e-d369a60bd572 |  ... | $2a$10$fwMsVMi.8MZBXKsxDPSppeeMadY7wwZ1M25Bbk.q5wHiUeSbUPOP. 
 d8d8c146-0557-43a6-89a4-74350faa5445 |  ... | $2a$10$n3n8ACX7oJPyHhOr4L624eLAfq1/ItFEPvUmdRu8mmNAe0B4j5ZMq 
(5 rows)

JWT加密整个用户信息，对应tocken_service.go里面的Encode函数

调用流程

• 打开vessel-service, consignment-service, user-service

• 打开user-cli，存储用户信息，并且获取到JWT加密信息

• 打开consignment-cli，调用.json文件的货物信息，使用JWT加密用户【会调用tocken_service.go里面Decode函数】。这步目前只需要验证加密用户是否存在于数据库中，而不用管用户和.json内的用户信息匹配。

  # 这部分是错误密钥111
  meloneater@meloneater-ubuntu:~/gopath/src/shippy$ docker-compose run consignment-cli consignment.json 111
  Creating shippy_consignment-cli_run ... done
  2021-06-04 04:01:44.413765 I | infoFile: 
  consignment.json
  2021-06-04 04:01:44.413788 I | token: 
  111
  
  2021-06-04 04:01:49.514734 I | create consignment error: {"id":"go.micro.client","code":408,"detail":"call timeout: context deadline exceeded","status":"Request Timeout"}
  ERROR: 1
  
  # 这部分是正确JWT密钥
  meloneater@meloneater-ubuntu:~/gopath/src/shippy$ docker-compose run consignment-cli consignment.json eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJVc2VyIjp7ImlkIjoiN2ZmYzliMjEtNjZjZi00MmEwLWE2OTItOTU4NmNjMzU3NTM5IiwibmFtZSI6Im1lbG9uZWF0ZXIiLCJjb21wYW55Ijoiemp1IiwiZW1haWwiOiJtZWxvbmVhdGVyQGdtYWlsLmNvbSIsInBhc3N3b3JkIjoiJDJhJDEwJHEuYmR5WFduNFdMNEMydmY3UVl3Q3UvYXVHL25mVDZreWlZSzhQaHdxTllTOTh0NW8zUnNTIn0sImV4cCI6MTYyMzAzODQ2MiwiaXNzIjoiZ28ubWljcm8uc3J2LnVzZXIifQ.TDc6ErRg9Qyh_M6j9nP4NpIyGm2OJqt7-eeTn-ZGtok
  Creating shippy_consignment-cli_run ... done
  2021-06-04 04:02:13.990956 I | infoFile: 
  consignment.json
  2021-06-04 04:02:13.990986 I | token: 
  eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJVc2VyIjp7ImlkIjoiN2ZmYzliMjEtNjZjZi00MmEwLWE2OTItOTU4NmNjMzU3NTM5IiwibmFtZSI6Im1lbG9uZWF0ZXIiLCJjb21wYW55Ijoiemp1IiwiZW1haWwiOiJtZWxvbmVhdGVyQGdtYWlsLmNvbSIsInBhc3N3b3JkIjoiJDJhJDEwJHEuYmR5WFduNFdMNEMydmY3UVl3Q3UvYXVHL25mVDZreWlZSzhQaHdxTllTOTh0NW8zUnNTIn0sImV4cCI6MTYyMzAzODQ2MiwiaXNzIjoiZ28ubWljcm8uc3J2LnVzZXIifQ.TDc6ErRg9Qyh_M6j9nP4NpIyGm2OJqt7-eeTn-ZGtok
  
  2021-06-04 04:02:14.268047 I | created: true
  2021-06-04 04:02:14.285920 I | description:"This is a test consignment" weight:55000 containers:<customer_id:"cust001" origin:"Manchester, United Kingdom" user_id:"user001" > containers:<customer_id:"cust002" origin:"Derby, United Kingdom" user_id:"user001" > containers:<customer_id:"cust005" origin:"Sheffield, United Kingdom" user_id:"user001" > vessel_id:"vessel001" 

目前有个BUG：错误的密钥会让user-service停止服务。

原因是在token_service.go的Decode()的ParseWithClaims()函数解析JWT密钥的时候，当输入的密钥不符合JWT格式的XXX.XXX.XXX, 那么函数在取第二部分claims的时候就会访问不对的空间

meloneater@meloneater-ubuntu:~/gopath/src/shippy/user-service$ docker-compose run user-service
Creating shippy_user-service_run ... done
Host:database	port:5432	User:userService	Password:12345	DbName:userServiceDB
&{RWMutex:{w:{state:0 sema:0} writerSem:0 readerSem:0 readerCount:0 readerWait:0} Value:<nil> Error:<nil> RowsAffected:0 db:0xc0005280c0 blockGlobalUpdate:false logMode:0 logger:{LogWriter:0xc0001a1d60} search:<nil> values:{mu:{state:0 sema:0} read:{v:<nil>} dirty:map[] misses:0} parent:0xc00011c1a0 callbacks:0x1e80920 dialect:0xc0001a4220 singularTable:false nowFuncOverride:<nil>}
err: <nil>
2021-06-04 04:10:14.858426 I | Transport [http] Listening on [::]:36955
2021-06-04 04:10:14.858557 I | Broker [http] Connected to [::]:44995
2021-06-04 04:10:14.858950 I | Registry [mdns] Registering node: go.micro.srv.user-ddba6942-84f0-441f-858e-452c13d8296a
panic: runtime error: invalid memory address or nil pointer dereference   # 错误显示在这
[signal SIGSEGV: segmentation violation code=0x1 addr=0x30 pc=0x12ea1b8]

# 错误的JWT token输入格式
meloneater@meloneater-ubuntu:~/gopath/src/shippy$ docker-compose run consignment-cli consignment.json 111

# 正确的JWT token输入格式
meloneater@meloneater-ubuntu:~/gopath/src/shippy$ docker-compose run consignment-cli consignment.json 111.111.111

需要理解的问题：go-micro的上下文到底是什么？

主要对email-service/user-service/user-cli进行解耦，使用micro自带的pubsub

• cli要根据topic进行publish
• server要根据topic进行subscriber
• 因为用了pubsub所以不需要再使用NATS，主要就是要掌握下pubsub的写法，具体参考https://github.com/asim/go-micro/tree/master/examples/pubsub

使用MySQL

• 还是需要连接两次，但是出现一个现象：快速连接情况下可能来两次连接都不够，但是如果第二次运行隔久一点时间，就一定能两次成功
  • 猜测原因：MySQL完整建立服务需要一段时间

最终结果