Golang 微服务 教程（六）
阅读次数: 2785 | 字数统计: 2,329
原文链接：ewanvalentine.io，翻译已获作者 Ewan Valentine 授权。
本文完整代码：
在上节中我们使用 go-micro 搭建了微服务的事件驱动架构。本节将揭晓从 web 客户端的角度出发如何与微服务进行调用交互。
微服务与 web 端交互
参考 go-micro 文档，可看到 go-micro 实现了为 web 客户端代理请求 RPC 方法的机制。
内部调用
微服务 A 调用微服务 B 的方法，需要先实例化再调用：bClient.CallRPC(args…)，数据作为参数传递，属于 内部调用 。
外部调用
web 端浏览器是通过 HTTP 请求去调用微服务的方法，go-micro 就做了中间层，调用方法的数据以 HTTP 请求的方式提交，属于 外部调用 。
REST vs RPC
REST 风格多年来在 web 开发领域独领风骚，常用于客户端与服务端进行资源管理，应用场景比 RPC 和 SOAP 都要广得多。更多参考：知乎：RPC 与 RESTful API 对比
REST
REST 风格对资源的管理既简单又规范，它将 HTTP 请求方法对应到资源的增删改查上，同时还可以使用 HTTP 错误码来描述响应状态，在大多数 web 开发中 REST 都是优秀的解决方案。
RPC
不过近年来 RPC 风格也乘着微服务的顺风车逐渐普及开来。REST 适合同时管理不同的资源，不过一般微服务只专注管理单一的资源，使用 RPC 风格能让 web 开发专注于各微服务的实现与交互。
Micro 工具箱
我们从第二节开始就一直在使用 go-micro 框架，现在来看看它的 API 网关。go-micro 提供 API 网关给微服务做代理。API 网关把微服务 RPC 方法代理成 web 请求，将 web 端使用到的 URL 开放出来，更多参考：go-micro toolkits，go-micro API example
使用
# 安装 go-micro 的工具箱： # $ go get -u github.com/micro/micro # 我们直接使用它的 Docker 镜像 $ docker pull microhq/micro
现在修改一下 user-service 的代码：
package main
import (
"log"
pb "shippy/user-service/proto/user"// 作者用的另一个仓库
"github.com/micro/go-micro"
)
func main() {
// 连接到数据库
db, err := CreateConnection()
defer db.Close()
if err != nil {
log.Fatalf("connect error: %v\n", err)
}
repo := &UserRepository{db}
// 自动检查 User 结构是否变化
db.AutoMigrate(&pb.User{})
// 作者使用了新仓库 shippy-user-service
// 但 auth.proto 和 user.proto 定义的内容是一致的
// 修改 shippy.auth 为 go.micro. srv .user 即可
// 注意 API 调用参数也需对应修改
srv := micro.NewService(
micro.Name("go.micro.srv.user"),
micro.Version("latest"),
)
srv.Init()
// 获取 broker 实例
// pubSub := s.Server().Options().Broker
publisher := micro.NewPublisher(topic, srv.Client())
t := TokenService{repo}
pb.RegisterUserServiceHandler(srv.Server(), &handler{repo, &t, publisher})
if err := srv.Run(); err != nil {
log.Fatalf("user service error: %v\n", err)
}
}
原代码 仓库：shippy-user-service/tree/tutorial-6
API 网关
现在把 user-service 和 emil-service 像上节一样 make run 运行起来。之后再执行：
$ docker run -p 8080:8080 \ -e MICRO_REGISTRY=mdns \ microhq/micro api \ --handler=rpc \ --address=:8080 \ --namespace=shippy
API 网关现在运行在 8080 端口，同时告诉它和其他微服务一样使用 mdns 做服务发现，最后使用的命名空间是 shippy，它会作为我们服务名的前缀，比如 shippy.auth，shippy. email ，默认值是 go.micro.api，如果不指定而使用默认值将无法生效。
web 端创建用户
现在外部可以像这样调用 user-service 创建用户的方法：
$ curl -XPOST -H 'Content-Type: application/ JSON ' \ -d '{ "service": "shippy.auth", "method": "Auth.Create", " request ": { "user": { "email": "ewan.valentine89@gmail.com", "password": "testing123", "name": "Ewan Valentine", "company": "BBC" } } }' \
效果如下：
在这个 HTTP 请求中，我们把 user-service Create 方法所需参数以 JSON 字段值的形式给出，API 网关会帮我们自动调用，并同样以 JSON 格式返回方法的处理结果。
web 端认证用户
$ curl -XPOST -H 'Content-Type: application/json' \
-d '{
"service": "shippy.auth",
"method": "Auth.Auth",
"request": {
"email": "your@email.com",
"password": "SomePass"
}
}' \
运行效果如下：
用户界面
现在将上边的 API 做成 web 端调用，我们这里使用 React 的 react-create-app 库。先安装：$ npm install -g react-create-app，最后创建项目：$ react-create-app shippy-ui
App.js
// shippy-ui/src/App.js
import React, { Component } from 'react';
import './App.css';
import CreateConsignment from './CreateConsignment';
import Authenticate from './Authenticate';
class App extends Component {
state = {
err: null,
authenticated: false,
}
onAuth = (token) => {
this.setState({
authenticated: true,
});
}
renderLogin = () => {
return (
<Authenticate onAuth={this.onAuth} />
);
}
renderAuthenticated = () => {
return (
<CreateConsignment />
);
}
getToken = () => {
return localStorage.getItem('token') || false;
}
isAuthenticated = () => {
return this.state.authenticated || this.getToken() || false;
}
render() {
const authenticated = this.isAuthenticated();
return (
<div className="App">
<div className="App-header">
<h2>Shippy</h2>
</div>
<div className='App-intro container'>
{(authenticated ? this.renderAuthenticated() : this.renderLogin())}
</div>
</div>
);
}
}
export default App;
接下来添加用户认证、货物托运的两个组件。
Authenticate 用户认证组件
// shippy-ui/src/Authenticate.js
import React from 'react';
class Authenticate extends React.Component {
constructor(props) {
super(props);
}
state = {
authenticated: false,
email: '',
password: '',
err: '',
}
login = () => {
fetch(``, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify({
request: {
email: this.state.email,
password: this.state.password,
},
// 注意
// 作者的把 Auth 认证作为了独立的项目
// Auth 其实和 go.micro.srv.user 是一样的
// 这里作者和译者的代码略有不同
service: 'shippy.auth',
method: 'Auth.Auth',
}),
})
.then(res => res.json())
.then(res => {
this.props.onAuth(res.token);
this.setState({
token: res.token,
authenticated: true,
});
})
.catch(err => this.setState({ err, authenticated: false, }));
}
signup = () => {
fetch(``, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify({
request: {
email: this.state.email,
password: this.state.password,
name: this.state.name,
},
method: 'Auth.Create',
service: 'shippy.auth',
}),
})
.then((res) => res.json())
.then((res) => {
this.props.onAuth(res.token.token);
this.setState({
token: res.token.token,
authenticated: true,
});
localStorage.setItem('token', res.token.token);
})
.catch(err => this.setState({ err, authenticated: false, }));
}
setEmail = e => {
this.setState({
email: e.target.value,
});
}
setPassword = e => {
this.setState({
password: e.target.value,
});
}
setName = e => {
this.setState({
name: e.target.value,
});
}
render() {
return (
<div className='Authenticate'>
<div className='Login'>
<div className='form-group'>
<input
type="email"
onChange={this.setEmail}
placeholder='E-Mail'
className='form-control' />
</div>
<div className='form-group'>
<input
type="password"
onChange={this.setPassword}
placeholder='Password'
className='form-control' />
</div>
<button className='btn btn-primary' onClick={this.login}>Login</button>
<br /><br />
</div>
<div className='Sign-up'>
<div className='form-group'>
<input
type='input'
onChange={this.setName}
placeholder='Name'
className='form-control' />
</div>
<div className='form-group'>
<input
type='email'
onChange={this.setEmail}
placeholder='E-Mail'
className='form-control' />
</div>
<div className='form-group'>
<input
type='password'
onChange={this.setPassword}
placeholder='Password'
className='form-control' />
</div>
<button className='btn btn-primary' onClick={this.signup}>Sign-up</button>
</div>
</div>
);
}
}
export default Authenticate;
CreateConsignment 货物托运组件
// shippy-ui/src/CreateConsignment.js
import React from 'react';
import _ from 'lodash';
class CreateConsignment extends React.Component {
constructor(props) {
super(props);
}
state = {
created: false,
description: '',
weight: 0,
containers: [],
consignments: [],
}
componentWillMount() {
fetch(``, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify({
service: 'shippy.consignment',
method: 'ConsignmentService.Get',
request: {},
})
})
.then(req => req.json())
.then((res) => {
this.setState({
consignments: res.consignments,
});
});
}
create = () => {
const consignment = this.state;
fetch(``, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify({
service: 'shippy.consignment',
method: 'ConsignmentService.Create',
request: _.omit(consignment, 'created', 'consignments'),
}),
})
.then((res) => res.json())
.then((res) => {
this.setState({
created: res.created,
consignments: [...this.state.consignments, consignment],
});
});
}
addContainer = e => {
this.setState({
containers: [...this.state.containers, e.target.value],
});
}
setDescription = e => {
this.setState({
description: e.target.value,
});
}
setWeight = e => {
this.setState({
weight: Number(e.target.value),
});
}
render() {
const { consignments, } = this.state;
return (
<div className='consignment-screen'>
<div className='consignment-form container'>
<br />
<div className='form-group'>
<textarea onChange={this.setDescription} className='form-control' placeholder='Description'></textarea>
</div>
<div className='form-group'>
<input onChange={this.setWeight} type='number' placeholder='Weight' className='form-control' />
</div>
<div className='form-control'>
Add containers...
</div>
<br />
<button onClick={this.create} className='btn btn-primary'>Create</button>
<br />
<hr />
</div>
{(consignments && consignments.length > 0
? <div className='consignment-list'>
<h2>Consignments</h2>
{consignments.map((item) => (
<div>
<p>Vessel id: {item.vessel_id}</p>
<p>Consignment id: {item.id}</p>
<p>Description: {item.description}</p>
<p>Weight: {item.weight}</p>
<hr />
</div>
))}
</div>
: false)}
</div>
);
}
}
export default CreateConsignment;
UI 的完整代码可见：shippy-ui
现在执行 npm start，效果如下：
打开 Chrome 的 Application 能看到在注册或登录时，RPC 成功调用：
总结
本节使用 go-micro 自己的 API 网关，完成了 web 端对微服务函数的调用，可看出函数参数的入参出参都是以 JSON 给出的，对应于第一节 Protobuf 部分说与浏览器交互 JSON 是只选的。此外，作者代码与译者代码有少数出入，望读者注意，感谢。
下节我们将引入 Google Cloud 云平台来托管我们的微服务项目，并使用 Terraform 进行管理。
