-
分布式消息队列Kafka
文章目录 分布式消息队列Kafka 架构 组成架构 * 好处 * Api 命令行操作 * Java Api * 1.producer 1 * 1）异步提交 2 * 2）同步提交 3 4 * 2.Consumer 5 6 * 1）自动提交 7 * 2）手动提交 8 * 3）自定义存储offset 9 10 * 3.自定义Interceptor 11 12 * 运行机制 13 生产者 1 * 1.分区…- 21
- 0
-
基于Dubbo框架构建分布式服务
Dubbo是Alibaba开源的分布式服务框架，我们可以非常容易地通过Dubbo来构建分布式服务，并根据自己实际业务应用场景来选择合适的集群容错模式，这个对于很多应用都是迫切希望的，只需要通过简单的配置就能够实现分布式服务调用，也就是说服务提供方（Provider）发布的服务可以天然就是集群服务，比如，在实时性要求很高的应用场景下，可能希望来自消费方（Consumer）的调用响应时间最短，只需要选…- 3
- 0
-
SpringBoot+zk+dubbo架构实践（五）：搭建微服务电商架构（内附GitHub地址）
往期回顾 SpringBoot+zk+dubbo架构实践（一）：本地部署zookeeper SpringBoot+zk+dubbo架构实践（二）：SpringBoot 集成 zookeeper SpringBoot+zk+dubbo架构实践（三）：部署Dubbo-admin管理平台 SpringBoot+zk+dubbo架构实践（四）：sb+zk+dubbo框架搭建（内附源码Git地址） 前言 1…- 7
- 0
-
25. Dubbo原理解析-telnet
Dubbo提供了telnet命令去查看服务功能 **这里主要介绍一下dubbo实现telnet命令的整体实现 ** 当服务器端接收到的消息类型是string的时候回调用到TelnetHandler的telent方法中 TelnetHanlderAdpter类会从接收的字符串解析出命令，根据dubbo的spi扩展机制获取对应的TelnetHandler实现 在com.alibaba.…- 1
- 0
-
初识Dubbo 系列之前传1-Dubbo产生的背景
背景 (#) 随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，亟需一个治理系统确保架构有条不紊的演进。 单一应用架构 当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署节点和成本。 此时，用于简化增删改查工作量的 数据访问框架(ORM) 是关键。 垂直应用架构 当访问量逐渐增大，单一应用增加机器…- 5
- 0
-
Dubbo 同步、异步调用的几种方式
我们知道，Dubbo 缺省协议采用单一长连接，底层实现是 Netty 的 NIO 异步通讯机制；基于这种机制，Dubbo 实现了以下几种调用方式： 同步调用 异步调用 参数回调 事件通知 同步调用 同步调用是一种阻塞式的调用方式，即 Consumer 端代码一直阻塞等待，直到 Provider 端返回为止； 通常，一个典型的同步调用过程如下： Consumer 业务线程调用远程接口，向 Provi…- 28
- 0
-
用Redis实现分布式锁 与 实现任务队列
这一次总结和分享用Redis实现分布式锁 与 实现任务队列 这两大强大的功能。先扯点个人观点，之前我看了一篇博文说博客园的文章大部分都是分享代码，博文里强调说分享思路比分享代码更重要（貌似大概是这个意思，若有误请谅解），但我觉得，分享思路固然重要，但有了思路，却没有实现的代码，那会让人觉得很浮夸的，在工作中的程序猿都知道，你去实现一个功能模块，一段代码，虽然你有了思路，但是实现的过程也是很耗时的，…- 3
- 0
-
SpringCloud微服务知识整理十一：分布式服务跟踪：Spring Cloud Sleuth
什么是Spring Cloud Sleuth 随着业务的发展，我们的系统规模也会变得越来越大，各微服务间的调用关系也变得越来越错综复杂。这时候对于每个请求全链路调用的跟踪就变得越来越重要，通过实现对请求调用的跟踪可以帮助我们快速的发现错误根源以及监控分析每条请求链路上的性能瓶颈等好处。 针对上面所述的分布式服务跟踪问题，Spring Cloud Sleuth提供了一套完整的解决方案。 快速入门 准…- 32
- 0
-
SpringCloud微服务知识整理五：服务容错保护 Spring Cloud Hystrix
什么是Spring Cloud Hystrix 在微服务架构中，我们将系统拆分为很多个服务，各个服务之间通过注册与订阅的方式相互依赖，由于各个服务都是在各自的进程中运行，就有可能由于网络原因或者服务自身的问题导致调用故障或延迟，随着服务的积压，可能会导致服务崩溃。为了解决这一系列的问题，断路器等一系列服务保护机制出现了。 Spring Cloud Hystrix 实现了断路器、线路隔离等一系列服务…- 19
- 0
-
微服务架构核心技术八
微服务技术架构体系层次结构 最上面一层为接入层，主要为负载均衡器，负责把外部流量接入到内部平台上 最下面一层为基础设施层，运维团队来维护. 网关层负责反向路由、限流熔断、安全等跨横切面内容 业务服务层上个博客分为聚合层和基础层 支撑服务——系统微服务化后，系统变得更加碎片化，系统的部署、运维、监控等都比单体架构更加复杂，那么，就需要将大部分的工作自动化 平台服务 k8s等容器部署，权限管控(JWT…- 10
- 0
-
微服务架构核心技术十四
微服务通讯方式RPC vs REST 图例 从九个方面分析两种通讯方式的差别: RPC采用一些定制的消息格式，服务端和客户端需要以一定的消息格式通讯.REST无强消息耦合性. RPC一般采用二进制消息格式紧凑，性能高.REST采用文本类型的消息协议 RPC一般用TCP协议通讯，grpc也支持http2协议通讯 payload size 大小可能影响到性能 接口契约IDL语言类似一个协议，来规定接入…- 11
- 0
-
ASP.NET Core微服务之基于Exceptionless实现分布式日志记录
Tip: 此篇已加入.NET Core微服务基础系列文章索引 一、Exceptionless极简介绍 Exceptionless 是一个开源的实时的日志收集框架，它可以应用在基于 ASP.NET，ASP.NET Core，Web API，Web Forms，WPF，Console，ASP.NET MVC 等技术开发的应用程序中，并且提供了REST接口可以应用在 Javascript，Node.js…- 8
- 0
-
Spring Cloud构建微服务架构：服务容错保护（Hystrix依赖隔离）【Dalston版】
前言 在上一篇《Spring Cloud构建微服务架构：服务容错保护（Hystrix服务降级）》中，我们已经体验了如何使用@HystrixCommand来为一个依赖资源定义服务降级逻辑。实现方式非常简单，同时对于降级逻辑还能实现一些更加复杂的级联降级等策略。之前对于使用Hystrix来实现服务容错保护时，除了服务降级之外，我们还提到过线程隔离、断路器等功能。那么在本篇中我们就来具体说说线程隔离。 …- 10
- 0
-
Spring Cloud构建微服务架构：服务消费（基础）【Dalston版】
通过上一篇《Spring Cloud构建微服务架构：服务注册与发现》，我们已经成功地将服务提供者：eureka-client或consul-client注册到了Eureka服务注册中心或Consul服务端上了，同时我们也通过DiscoveryClient接口的getServices获取了当前客户端缓存的所有服务清单，那么接下来我们要学习的就是：如何去消费服务提供者的接口？ 使用LoadBalanc…- 12
- 0
-
SpringCloud微服务搭建详解
主要讲解SpringCloud搭建微服务的步骤，其中用到了Eurake、Ribbon、Feign、Hystrix、Zuul、Config技术。 项目地址：https://github.com/17665387407?tab=repositories 一、建立一个总工程 首先建立一个microservice-parent总工程，总工程中并不做什么业务逻辑，总工程主要定义一个POM文件，将后续各个…- 7
- 0
-
Netty游戏服务器实战开发(9):利用redis或者zookeeper实现3pc分布式事务锁（三）。支撑腾讯系列某手游百万级流量公测
导读：在编写前面两篇文章的时候，博主其实已经把这个项目做完了，因为不可能一边写文章，一遍写项目。所以我都是把项目做完之后然后通过自己测试之后确保没有问题就来编写文章。 最近估计大家都听说了“华夏银行技术处长编写病毒植入系统，盗窃 700 余万受审”按键沸沸扬扬。很多人就想知道，如此可爱的程序员宝宝如何走向犯罪的道路，所以不管出于人性和社会道德，技术人员还是不要轻易的在系统中留下后门程序。否者被查出…- 18
- 0
-
Netty源码分析第5章(ByteBuf)—->第3节: 缓冲区分配器
Netty源码分析第五章: ByteBuf 第三节: 缓冲区分配器 缓冲区分配器 , 顾明思议就是分配缓冲区的工具 , 在 netty中 , 缓冲区分配器的顶级抽象是接口 ByteBufAllocator, 里面定义了有关缓冲区分配的相关 api 抽象类 AbstractByteBufAllocator实现了 ByteBufAllocator接口 , 并且实现了其大部分功能 和 Abs…- 0
- 0
-
Netty源码分析第2章(NioEventLoop)—->第8节: 执行任务队列
** ** Netty源码分析第二章: NioEventLoop ** ** 第八节: 执行任务队列 继续回到NioEventLoop的run()方法: 1protected void run() { 2 for (;;) { 3 try { 4 switch (selectStrategy.calculateStrategy(selectNowSupplier, hasTasks())) { 5…- 4
- 0
-
Netty In Action中文版 – 第十二章：SPDY
Netty In Action中文版 - 第十二章：SPDY 本章我将不会直接翻译Netty In Action书中的原文，感觉原书中本章讲的很多废话，我翻译起来也吃力。所以，本章内容我会根据其他资料和个人理解来讲述。 12.1 SPDY概念及背景 SPDY是Google开发的基于传输控制协议（TCP）的应用层协议，开发组正在推动SPDY成为正式标准（现为互联网草案）.SPDY协议…- 5
- 0
-
Netty In Action中文版 – 第三章：Netty核心概念
Netty In Action中文版 - 第三章：Netty核心概念 在这一章我们将讨论Netty的10个核心类，清楚了解他们的结构对使用Netty很有用。可能有一些不会再工作中用到，但是也有一些很常用也很核心，你会遇到。 Bootstrap or ServerBootstrap EventLoop EventLoopGroup ChannelPipeline Channel Future or …- 0
- 0
-
Mina、Netty、Twisted一起学（一）：实现简单的TCP服务器
MINA、Netty、Twisted为什么放在一起学习？首先，不妨先分别看一下它们官方网站对其的介绍： MINA： Apache MINA is a network application framework which helps users develop high performance and high scalability network applications easily. It…- 4
- 0
-
Java NIO框架Netty教程(七)-再谈收发信息次数问题
在《Java NIO框架Netty教程（五）- 消息收发次数不匹配的问题》里我们试图分析一个消息收发次数不匹配的问题。当时笔者还是心存疑惑的。所以决定先学习一下Java NIO的Selector机制。 经过简单的了解，笔者大胆的猜测和“武断”一下该问题的原因。 首先，Selector机制让我们注册一个感兴趣的时间，然后只要有该时间发生，就会传递给接收端。我们写了三次，接收端一定会出发三次的。 然后…- 16
- 0
-
netty实现websocket
1.搭建springboot web 项目，参考 https://blog.csdn.net/u013184307/article/details/98057621 2.导入包 1<dependency> 2 <groupId>io.netty</groupId> 3 <artifactId>netty-all</artifactId> …- 9
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×