使用gRPC go实现 基于Topic的高效消息订阅发布模型 姓名 张凯 中国电子云 目 录 gRPC go 介绍 01 gRPC四种通信模式及落地场景 02 根据proto生成go桩代码 03 订阅者动态注册 04 发布者消息推送 05 现场案例演示 06 gRPC go介绍 gRPC是什么？ 01. 副标题 开篇思考几个问题 01. 副标题 gRPC介绍 Web开发 基于通信模式如何落地？ 01. 副标题 流式传输 基于通信模式如何落地？ 01. 副标题 以及，本次分享的 “ ” 基于Topic消息发布订阅 基于Topic的消息发布模型简介 01. 副标题 基于Topic的消息发布模型简介 01. 副标题 BRIAN KERNGHAN service PubSubService { rpc Publish(PublishRequest) 服务器和客户端的接口代码。  --go_out=.: 类似地，这个选项指定了非 gRPC 相关的 Protocol Buffers 消息结构体等 Go 语言代码的输出目录， 同样为当前目录。protoc-gen-go 插件会处理 .proto 文 件中的消息定义并生成对应的 Go 结构体。 订阅者动态注册 01. 副标题 type subscriber chan interface{}

Go在数据库中间件的应用 基础架构组/刘延允 liuyun827@foxmail.com 2017年9月 1 关于我 • 刘延允——酷狗音乐，基础架构组 • 数据库变更通知服务 • 酷狗消息队列 • 酷狗数据库中间件 • 主要工作：分布式存储、高可用、数据库 • 两年通信设备开发经验，四年互联网 • 五年C/C++使用经验，一年Golang 2 CONTENTS • 程序开发的需求 程序开发的需求 • Golang特性 • Go开发mysql中间件 • 整体方案 • 分表路由 • 故障切换 • 平滑扩容 • 系统运维 3 程序开发的需求 • 语言特性精炼，容易入门 • 开发效率高，代码逻辑清晰 • 运行性能强，节省机器资源 • 部署维护方便 • 生态圈完善 4 Golang特性 • Go语法简练；没有学习压力 • 开发效率高；语言描述能力接近于脚本语言

7/1/2017 基于amqp实现的golang消息队列MaxQ http://192.168.10.11:3999/maxq.slide#1 1/22 基于amqp实现的golang消息队列 MaxQ 2017-07-01 张培培 饿了么－基础框架组 7/1/2017 基于amqp实现的golang消息队列MaxQ http://192.168.10.11:3999/maxq.slide#1 2. IPC消息队列 3. AMQP协议 4. MaxQ架构模型 5. MaxQ相关特性 6. 使用场景和案例 7/1/2017 基于amqp实现的golang消息队列MaxQ http://192.168.10.11:3999/maxq.slide#1 3/22 1. 队列 跟消息队列相比，有哪些共性？ 7/1/2017 基于amqp实现的golang消息队列MaxQ 生产者消费者 通信方式 存储方式 堆积能力 消息可靠性 生产消费关系 Pull/Push 7/1/2017 基于amqp实现的golang消息队列MaxQ http://192.168.10.11:3999/maxq.slide#1 5/22 2. IPC消息队列 跟消息队列相比，有哪些共性？ 7/1/2017 基于amqp实现的golang消息队列MaxQ http://192.168

Laravel 5.6 带来了日志系统的重大升级，所有日志配置都存放在新的 config/logging.php 配置文件，你现在可以轻松构建发送日志消息到多个处 理器的日志”堆栈”。例如，你可以发送所有 debug 级别消息到系统日志同时发送 error 级别消息到 Slack 以便团队成员可以快速响应： 'channels' => [ 'stack' => [ 'driver' }); }); 在 Laravel 5.6 中，你可以基于认证用户模型属性指定一个动态的最大请求次数，如果 User 模型包含 rate_limit 属性，可以将属性名传递 给 throttle 中间件，以便用于计算最大请求次数计数： Route::middleware('auth:api', 'throttle:rate_limit,1')->group(function () { withSwiftMessage 回调 在之前版本的 Laravel 中，使用 withSwiftMessage 注册的 Swift 消息自定义回调函数在内容已经被编码并添加到消息后被调用。这些回调现在在 内容被添加前调用，从而允许你自定义编码以及其他消息选项。 分页 Bootstrap 4 分页器生成的分页链接现在默认使用 Bootstrap 4，要让分页器生成 Bootstrap

第一部分：序言 新版特性 Laravel 6.0（LTS 版本） 在 Laravel 5.8 的基础上继续进行优化， 包括引入语义化版本、兼容 Laravel Vapor、优化授权响应、支持任 务中间件、新增懒集合、优化数据库子查询、将前端脚手架提取到独 立的 Composer 包 laravel/ui、以及多个 bug 修复和可用性的提 升。 语义化版本 Laravel 框架包 laravel/framework 编辑、异常分享、以及经过优化的用户体验。 优化授权响应 在之前版本的 Laravel 中，获取并提供自定义授权消息给终端用户 很困难，主要难点在于如何向终端用户解释清楚为什么特定的请求被 拒绝了。在 Laravel 6.0 中，我们可以使用 Gate::inspect 方法和 授权响应消息来轻松实现。例如，给定如下策略方法： /** * 判断用户是否可以查看指定的航班. * * @param Laravel 中文学习资源：https://xueyuanjun.com 4 接下来我们可以通过 Gate::inspect 方法获取授权策略的响应，然 后再通过响应示例的 message() 方法获取授权消息： $response = Gate::inspect('view', $flight); if ($response->allowed()) { // 用户被授权可以访问航班... } if

将登录次数限制引入框架，更多详情请参考认证限制一节。 Laravel 5.1 Laravel 5.1 在 5.0 的基础上继续进行优化和提升，接受 PSR-2 代码风格，新增事件广播 机制，中间件参数，Artisan 优化，等等。 PHP 5.5.9+ 由于 PHP 5.4 将会在今年 9 月份“寿终正寝”，并且 PHP 开发组不会再提供安全更新，Laravel 5.1 要求 PHP5 器上的某些数据更新后，通常一条消息将会通过 websocket 连接发送到客户端并进行处理。 为了帮助你构建这样类型的应用，Laravel 使得通过 websocket 连接广播事件变得简单可行。 广播 Laravel 事件允许你在服务端代码和客户端 JavaScript 框架之间共享相同的事件名称。 更多关于事件广播的内容请查看事件一节。 中间件参数 Laravel 5.1 里，中间件可以接受额外 le)) { // 跳转... } return $next($request); } } 中间件参数可以再定义路由时通过：分隔中间件名称和参数名称来指定，多个参数可以通过 逗号进行分隔： 本文档由 Laravel 学院（LaravelAcademy.org）提供 3 Route::put('post/{id}'

........................................................................................ 100 5.2 中间件 .................................................................................................. orders', 'check-status' => 'Check order status', ]); 此外，Passport 还包含了用于验证访问令牌认证请求包含必要令牌域的中间件： Route::get('/orders/{order}/status', function (Order $order) { // Access token has "check-status" 和 api 路由文件在如何分割 Web 界面和 API 路由方面提供了指导。api 路由文件中的路由会通 过 RouteServiceProvider 自动添加 api 前缀和 auth:api 中间件。 闭包控制台命令 除 了 通 过 命 令 类 定 义 之 外 ， 现 在 Artisan 命 令 还 可 以 在 app/Console/Kernel.php 文 件 的 commands

2、Laravel 5.2 Laravel 5.2 在 5.1 基础上继续改进和优化，添加了许多新的功能特性：多认证驱动支 持、隐式模型绑定、简化 Eloquent 全局作用域、可选择的认证脚手架、中间件组、访问频 率限制、数组输入验证优化等等。 多认证驱动 在之前的 Laravel 版本中，框架只支持默认的、基于 session 的认证驱动，且在单个应 用中只能拥有一个认证模型类（对应单张 Eloquent 模型类的话，Laravel 将会自动注入该模型。 更多隐式模型绑定详情请查看 Laravel 5.2 文档 HTTP 路由模型绑定部分。 中间件组 中间件组允许你通过单个方便的键来对相关路由中间件进行分组，从而为某个路由一次指 定多个中间件。例如，在同一个应用中构建 Web UI 或 API 时这一特性很有用，你可以 将 session 和 csrf 路由分组到一个 web 组，或者将访问频率限制分组到 组像这样分配给路由： Route::group(['middleware' => ['web']], function () { // }); 访问频率限制 一个新的访问频率限制中间件已经被内置到框架中，从而允许你轻松限制给定 IP 地址在 指定时间内对某个路由发起请求的数目。例如，要限制某个 IP 地址每分钟只能访问某个 路由 60 次，你可以这么做： Route::get('/api/users'

154 ...................................................................... 美团服务体验平台对接业务数据的最佳实践-海盗中间件 167 ...................................................................... 美团点评智能支付核心交易系统的可用性实践 176 美团点评基础架构部希望在基础存储、高性能通信、大规模在线访问、服务治理、实时监控、容器化及集 群智能调度等领域提供业界领先的、统一的解决方案，CAT 目前在美团点评的产品定位是应用层的统一 监控组件，在中间件（RPC、数据库、缓存、MQ 等）框架中得到广泛应用，为各业务线提供系统的性能 指标、健康状况、实时告警等服务。 本文会对 CAT 的客户端、性能等做详细深入的介绍，前不久我们也发过一篇 CAT 2016 年初至今，CAT 接入的应用增加了400%，机器数增加了 900%，每天处理的消息总量高达 3200 亿，存储消息量近 400TB，高峰期集群 QPS 达 650万/秒。 面对流量的成倍增长，CAT 在通信、计算、存储方面都遇到了前所未有的挑战。整个系统架构也经历了 一系列的升级和改造，包括消息采样聚合、消息存储、业务多维度指标监控、统一告警等等，项目最终稳 定落地。为公司未来几年内业务流量的稳定增长，打下了坚定的基石。