消费者云CSE微服务实践## 消费者云CSE微服务实践 李林锋 ## 关于我 9年电信软件平台中间件开发、设计、架构经验 精通Netty、Mina等网络通信框架 华为软件 短信/彩信/WAP网关平台SGP、API开放集成网关API Fabric首席设计师 华为软件分布式服务框架DSF首席设计师 《Netty权威指南》、《分布式服务框架原理与实践》作者 微博、微信：Nettying 公众号：Netty之家 816e8fd9c1e245b4d9cafff6180bc3c/p2_3.jpg) ## ServiceComb ## 议题 • 华为消费者云业务简介 • 微服务框架技术选型 • CSE在消费者云业务的实践 ## 华为消费者云业务简介 华为消费者云业务包括 华为应用市场、华为视频、华为钱包、华为运动健康等服务，为华为和荣耀手机提供精品云服务，提升用户体验 ## ← 应用详情  微服务化收益  联系方式： ## 关于我 ● 经历：2008年加入华为，从事多年平台中间件、云计算和PaaS平台设计和开发 ● 目前在华为终端消费者云业务从事华为手机应用市场的云化、微服务化架构设计 《Netty权威指南》、《分布式服务框架原理与实践》作者 热爱技术写作和分享 微信号：右侧扫码 Email: li_linfeng@huawei li_linfeng@huawei.com  ## 华为消费者云服务简介  云空间  ## 六 ：pull 消息消费 消费者主动拉取消息消费，客户端通过类 DefaultMQPullConsumer 客户端可以指定特定 MessageQueue 也可以通过 DefaultMQPullConsumer.fetchMes group_name 消费 topic 为 TopicTest 的进度为: // 队列 queue=0 消费进度 23 // 队列 queue=2 消费进度为 22 等等... } } } 3. 加载消费者订阅关系 ${user.home}/store/config/subscriptionGroup.json { "dataVersion": { "counter":10 码力 | 57 页 | 2.39 MB | 2 年前3
- Multi Producer, Multi Consumer, Lock Free, Atomic Queue0 码力 | 54 页 | 886.12 KB | 1 年前3
- NTTDATA 汽车行业数字营销平台微服务化实践业对外形象及标准化化运营 ## 大数据分析及应用 活动数据，消费者数据，媒体数据，车联网数据等，全渠道数据收集追踪，建立数据分析模型，辅助业务的决策优化  ## 消费者权益及服务数字化布局 建设“一个会员、分众运营、复合模式”的会员体 车联网及线下店端消费者旅程与线上消费者旅程相结合，设计多种跨渠道跨屏互动，引导进店消费者通过扫码，配车，留资等行为整合线上数据 利用人脸识别等多种技术及平台，通过可配置用户聚类评级模型和数据处理算法，实现消费者深度洞察，提高销售线索质量及转化率，助力经销商销售 ## 新媒体营销数字化布局 从微信营销及小程序开始布局其他新兴媒体渠道，如抖音，汽车之家等，基于360°消费者画像的精准营销触达。营销触达数据实时跟踪分析，形成数据闭环 活动工具管理  个性化推荐引擎 消费者互动数据 消费者交易数据活动管理 短信 营销中台 人 和 Consumer(消费消费者). 客户端在同一时间只会连接一台 nameserver，只有在连接出现异常时才会向尝试连接另外一台。客户端每隔 30s 向 Nameserver 发起 topic 的路由信息查询。 温馨提示: Nameserver consumegroup：消息消费组，一个消费单位的“群体”，消费组首先在启动时需要订阅需要消费的 topic。一个 topic 可以被多个消费组订阅，同样一个消费组也可以订阅多个主题。一个消费组拥有多个消费者。 术语解释起来有点枯燥晦涩，接下来我举例来阐述。 例如我们在开发一个订单系统，其中有一个子系统：order-service-app，在该项目中会创建一个消费组 order_consumer 来订阅 order_consumer 消费组的其中一个消费者。 ### 1. 消费模式 那这三个消费者如何来分工来共同消费 order topic 中的消息呢？ 在 RocketMQ 中支持广播模式与集群模式。 广播模式：一个消费组内的所有消费者每一个都会处理 topic 中的每一条消息，通常用于刷新内存缓存。 集群模式：一个消费组内的所有消费者共同消费一个 topic 中的消息，即分工协作，一个消费者消费一部分数据，启动负载均衡，0 码力 | 165 页 | 12.53 MB | 2 年前3
- 分布式NewSQL数据库TiDB删除非root用户 59 Binlog 同步 60 进入管理页面 60 开启 Binlog 61 全量数据迁移，记录CommitTS数据 65 添加消费者 67 查看消费者 70 删除消费者 72 修改 Binlog GC 73 关闭 Binlog 74 如何使用TiFlash 76 简介 76 步骤一 开启TiFlash 76 步骤二 38d53bcf09/p62_1.jpg) 迁移类型 增量迁移 全量+增量迁移 CommitTS 获取CommitTS ## 第三步：Binlog消费者 使用步骤二中的CommitTS数据，添加消费者 添加消费者 目标数据类型 MySQL协议 Kafka IP 端口 用户名 状态 操作 Binlog 同步服务默认不开启，点击图示开关打开开启窗口  ## 本节习题 ## 简答题 1. 简述线程的基本概念。程序、进程、线程的关系是什么？ 2. 线程的生命周期包括哪些基本状态？这些状态的关系如何？状态间的切换控制如何进行？（可以通0 码力 | 82 页 | 1010.73 KB | 2 年前3
- 微服务架构实践-唯品会订阅/变更通知 注册/心跳 调用 Client Service ## 服务路由 • 灰度发布 • A/B测试 • 流量控制 • 机房选择 # app1的消费者只能访问所有端口为20880的服务实例 # app2的消费者只能访问所有端口为20881的服务实例 scope: application force: true runtime: true enabled: true 自营 海淘 直发 直发 WMS 直发 HTS ## 下一代微服务架构Service Mesh ## 微服务架构痛点—开源微服务框架演进困难 消费者服务 消费者服务1 1.0版本 SDK 消费者服务2 2.0版本 SDK 消费者服务3 2.5版本 SDK 提供者服务A 1.0版本 SDK 提供者服务B 2.0版本 SDK 提供者服务C 2.5版本 SDK 提供者服务 微服务架构痛点—自研微服务框架演进困难 ## 业务研发部门A 业务研发部门B 消费者服务A1 1.0版本 SDK 消费者服务A2 提供者服务B3 提供者服务B2 2.0版本 SDK 消费者服务B1 提供者服务A3 3.0版本 SDK 1.0版本 SDK 2.0版本 SDK 1.0版本 SDK 业务研发部门C 2.0版本 SDK 消费者服务C1 2.0版本 SDK 3.0版本0 码力 | 120 页 | 82.16 MB | 2 年前3
共 226 条
- 1
- 2
- 3
- 4
- 5
- 6
- 23