-
微服务架构核心技术八
微服务技术架构体系层次结构 最上面一层为接入层，主要为负载均衡器，负责把外部流量接入到内部平台上 最下面一层为基础设施层，运维团队来维护. 网关层负责反向路由、限流熔断、安全等跨横切面内容 业务服务层上个博客分为聚合层和基础层 支撑服务——系统微服务化后，系统变得更加碎片化，系统的部署、运维、监控等都比单体架构更加复杂，那么，就需要将大部分的工作自动化 平台服务 k8s等容器部署，权限管控(JWT…- 14
- 0
-
微服务架构核心技术十四
微服务通讯方式RPC vs REST 图例 从九个方面分析两种通讯方式的差别: RPC采用一些定制的消息格式，服务端和客户端需要以一定的消息格式通讯.REST无强消息耦合性. RPC一般采用二进制消息格式紧凑，性能高.REST采用文本类型的消息协议 RPC一般用TCP协议通讯，grpc也支持http2协议通讯 payload size 大小可能影响到性能 接口契约IDL语言类似一个协议，来规定接入…- 18
- 0
-
ASP.NET Core微服务之基于Ocelot+IdentityServer实现统一验证与授权
Tip: 此篇已加入.NET Core微服务基础系列文章索引 一、案例结构总览 这里，假设我们有两个客户端（一个Web网站，一个移动App），他们要使用系统，需要通过API网关（这里API网关始终作为客户端的统一入口）先向IdentityService进行Login以进行验证并获取Token，在IdentityService的验证过程中会访问数据库以验证。然后再带上Token通过API网关去访问具…- 59
- 0
-
Spring Cloud构建微服务架构：分布式服务跟踪（跟踪原理）【Dalston版】
通过上一篇 《分布式服务跟踪（入门）》的例子，我们已经通过Spring Cloud Sleuth往微服务应用中添加了实现分布式跟踪具备的基本要素。下面通过本文来详细说说实现分布式服务跟踪的一些要点。 分布式系统中的服务跟踪在理论上并不复杂，它主要包括下面两个关键点： 为了实现请求跟踪，当请求发送到分布式系统的入口端点时，只需要服务跟踪框架为该请求创建一个唯一的跟踪标识，同时在分布式系统内部流转的时…- 16
- 0
-
Spring Cloud构建微服务架构：服务网关（基础）【Dalston版】
通过之前几篇Spring Cloud中几个核心组件的介绍，我们已经可以构建一个简略的（不够完善）微服务架构了。比如下图所示： 我们使用Spring Cloud Netflix中的Eureka实现了服务注册中心以及服务注册与发现；而服务间通过Ribbon或Feign实现服务的消费以及均衡负载；通过Spring Cloud Config实现了应用多环境的外部化配置以及版本管理。为了使得服务集群更为健壮…- 9
- 0
-
Springboot+Dubbo+Nacos 注解方式实现微服务调用
一.项目结构 1|-- spring-boot-dubbo-demo (父级工程) 2 |-- spring-boot-dubbo-base (基础工程) 3 |-- spring-boot-dubbo-consumer (消费者) 4 |-- spring-boot-dubbo-provider (生产者) 5 6 SpringBoot版本:2.2.0 Dubbo版本:2.7.…- 5
- 0
-
Netty游戏服务器实战开发(10):Netty结合kafka实现分布式消息队列
在分布式游戏服务器系统中，消息处理队列主要解决问题就是解耦系统中的业务，使得每个系统看起来功能比较单一，而且解决一些全服数据共享等问题。 通常我们知道kafka是作为消息队列比较火的一种方式，其实还有（Active MQ，Rabbit MQ，Zero MQ）个人觉得kafka比较好用点，哈哈，习惯吧。 同样我们来复习kafka基础。 kafka基础。 的内容来介绍kafka的基本安装。 首先我们要…- 57
- 0
-
Netty源码分析第3章(客户端接入流程)—->第1节: 初始化NioSockectChannelConfig
Netty源码分析第三章: 客户端接入流程 概述: 之前的章节学习了server启动以及eventLoop相关的逻辑, eventLoop轮询到客户端接入事件之后是如何处理的?这一章我们循序渐进, 带大家继续剖析客户端接入之后的相关逻辑 第一节:初始化NioSockectChannelConfig 在剖析接入流程之前我们首先补充下第一章有关创建channel的知…- 8
- 0
-
[编织消息框架][netty源码分析]5 EventLoopGroup 实现类NioEventLoopGroup职责与实现
分析NioEventLoopGroup最主有两个疑问 1.next work如何分配NioEventLoop 2.boss group 与child group 是如何协作运行的 从EventLoopGroup接口约定通过register方法从channel或promise转换成ChannelFuture对象 next方法就是用来分配NioEventLoop 1public interface…- 12
- 0
-
Netty In Action中文版 – 第十六章：从EventLoop取消注册和重新注册
Netty In Action中文版 - 第十六章：从EventLoop取消注册和重新注册 本章介绍 EventLoop 从EventLoop注册和取消注册 在Netty中使用旧的Socket和Channel Netty提供了一个简单的方法来连接Socket/Channel，这是在Netty之外创建并转移他们的责任到Netty。这允许你将遗留的集成框架以无缝方式一步一步迁移到Netty；Netty…- 68
- 0
-
Mina、Netty、Twisted一起学（二）：TCP消息边界问题及按行分割消息
在TCP连接开始到结束连接，之间可能会多次传输数据，也就是服务器和客户端之间可能会在连接过程中互相传输多条消息。理想状况是一方每发送一条消息，另一方就立即接收到一条，也就是一次write对应一次read。但是，现实不总是按照剧本来走。 MINA官方文档节选： TCP guarantess delivery of all packets in the correct order. But there…- 24
- 0
-
Java NIO框架Netty教程 (六) ChannelBuffer
在学字符串消息收发的时候，已经提到过。ChannelBuffer是Netty中非常重要的概念。所有消息的收发都依赖于这个Buffer。我们通过Netty的官方的文档来了解一下，基于流的消息传递机制。 In a stream-based transport such as TCP/IP, received data is stored into a socket receive buffer. …- 12
- 0
-
Netty 快速入门
Netty 快速入门 下面枚举所有的 Netty 应用程序的基本构建模块，包括客户端和服务器。 BOOTSTRAP Netty 应用程序通过设置 bootstrap（引导）类的开始，该类提供了一个 用于应用程序网络层配置的容器。 CHANNEL 底层网络传输 API 必须提供给应用 I/O操作的接口，如读，写，连接，绑定等等。对于我们来说，这是结构几乎总是会成为一个“socket”。 Netty …- 19
- 0
-
Netty–Reactor模型
上一篇博客讲了Netty创建事件循环组对象。本篇博客对Netty的Reactor模型中事件循环组对象所起的具体作用做一个介绍。 Reactor模型 Reactor模型分类 根据Reactor 的数量和处理资源线程池的数量不同，有三种典型的实现。 单Reactor 单线程 单Reactor 多线程 多Reactor 多线程 单Reactor 单线程 上图就是单Reactor 单线程模型图 selec…- 48
- 0
-
Netty websocket
Network protocols WebSocket是一种高级网络协议，旨在提高Web应用程序的性能和响应能力。 我们将通过编写示例应用程序来探索Netty对它们的支持。 在第12章中，您将学习如何使用WebSocket实现双向数据传输，方法是构建一个聊天室服务器，其中多个浏览器客户端可以实时通信。 您还将看到如何通过检测客户端是否支持它，从应用程序中的HTTP切换到WebSocket协议。 我…- 20
- 0
-
Kafka、RabbitMQ、RocketMQ消息中间件的对比
引言 分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。现在开源的消息中间件有很多,目前对Kafka、RabbitMQ、RocketMQ这三个消息中间件做下对比分析。 --kafkaRocketMQRabbitMQ数据来源相关文章定位设计定位系统间的数据流管道，实时数据处理。 例如：常规的消息系统、网站活性跟踪，监控数据，日志收集、处理等非日志的可靠消息传输。 例如：订单…- 45
- 0
-
基于Kafka+Flink+Redis的电商大屏实时计算案例
前言 一年一度的双11又要到了，阿里的双11销量大屏可以说是一道特殊的风景线。 实时大屏（real-time dashboard）正在被越来越多的企业采用，用来及时呈现关键的数据指标。 并且在实际操作中，肯定也不会仅仅计算一两个维度。 由于Flink的“真·流式计算”这一特点，它比Spark Streaming要更适合大屏应用。 本文从笔者的实际工作经验抽象出简单的模型，并简要叙述计算流程（当然大…- 17
- 0
-
Strom+Kafka + redis实时计算单词出现频率的案例
案例要实现的目标 在Kafka的shell 客户端中输入内容，通过Storm实时去kafka中取数据并进行计算单词出现的次数，并且实时把这些数据信息存储到redis中。 代码编写 编写Pom文件，代码如下： 1<?xml version="1.0" encoding="UTF-8"?> 2<project xmlns="http:…- 17
- 0
-
Spark Streaming使用Kafka保证数据零丢失
spark streaming从1.2开始提供了数据的零丢失，想享受这个特性，需要满足如下条件： 1.数据输入需要可靠的sources和可靠的receivers 2.应用metadata必须通过应用driver checkpoint 3.WAL(write ahead log) 可靠的sources和receivers spark streaming可以通过多种方式作为数据sources(包括ka…- 19
- 0
-
Java使用RabbitMQ（五）–消息分发策略
消息分发策略 RabbitMQ默认的消息分发策略是公平分发（Fair dispatch），把消息轮流发给每个worker者。 这样有个问题：某个worker很忙的 时候，会累积大量的消息，导致异常、内存溢出等问题。 一个解决方案是：设置某一时间只给一个worker者发送一条消息，在没有收到ack消息回应时，不给发第二个。 1int prefetchCount = 1; 2channel.basic…- 31
- 0
-
DocKer中下部署rabbitmq性能集群
rabbitmq集群中，各个rabbitmq为对等节点，即每个节点均提供给客户端连接，进行消息的接收和发送。节点分为内存节点和磁盘节点，一般的，均应建立为磁盘节点，为了防止机器重启后的消息消失；这几个节点需要在同一个局域网内；这几个节点需要有相同的erlang cookie，否则不能正常通信。 环境版本 linux发行版本：centos linux 7 linux内核：Linux localhos…- 22
- 0
-
AMQP-RabbitMQ/4/路由模式
4. 路由模式 Routing 图示 个人理解 生产者定义Exchange，设置类型为direct。将消息发送给Exchange之前，为每条消息指定路由键 消费者定义队列Queue，并将队列与Exchange进行绑定，在绑定的时候需要告诉Exchange，当前这个Queue接受的路由键。 消息由Exchange发送给Queue时，消息的routingKey必须与该队列订阅的routingKey完全…- 75
- 0
-
基于Python语言使用RabbitMQ消息队列（六）
远程过程调用（RPC） 在第二节里我们学会了如何使用工作队列在多个工人中分布时间消耗性任务。 但如果我们想要运行存在于远程计算机上的方法并等待返回结果该如何去做呢？这就不太一样了，这种模式就是常说的远程过程调用（RPC）。 在本节我们会 在本节我们会使用RabbitMQ创建一个RPC系统：一个客户端和一个可扩展（scalable）的RPC服务。由于我们没什么真正的时间消耗型任务去分配，我们就创建一…- 23
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×