-
16. Dubbo原理解析-集群&容错之router路由服务
Router服务路由， 根据路由规则从多个Invoker中选出一个子集AbstractDirectory是所有目录服务实现的上层抽象， 它在list列举出所有invokers后，会在通过Router服务进行路由过滤。 Router接口定义 public interface Router extendsComparable<Router> { URL getUrl(); <…- 16
- 0
-
Dubbo负载均衡：最少活跃数(LeastActive)的实现分析
最少活跃数的含义 官方解释：最少活跃调用数，相同活跃数的随机，活跃数指调用前后计数差，使慢的机器收到更少。 例如，每个服务维护一个活跃数计数器。当A机器开始处理请求，该计数器加1，此时A还未处理完成。若处理完毕则计数器减1。而B机器接受到请求后很快处理完毕。那么A,B的活跃数分别是1，0。当又产生了一个新的请求，则选择B机器去执行(B活跃数最小)，这样使慢的机器A收到少的请求。 最少活跃数的实现分…- 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.…- 6
- 0
-
dubbo管理控制台安装和使用
关于dubbo的配置使用已经配置好了简单的示例，下面先记录下dubbo管理控制台的安装和使用（用的zookeeper的注册中心），在网上找了些按照示例 dubbo管理控制台开源部分主要包含： 提供者 路由规则 动态配置 访问控制 权重调节 负载均衡 负责人，等管理功能。 1、下载dubbo 官方地址：http://code.alibabatech.com/mvn/relea…- 10
- 0
-
Redis分布式锁—-乐观锁的实现，以秒杀系统为例
摘要：本文使用redis来实现乐观锁，并以秒杀系统为实例来讲解整个过程。 本文源码请在这里下载：https://github.com/appleappleapple/DistributeLearning 乐观锁 大多数是基于数据版本（version）的记录机制实现的。即为数据增加一个版本标识，在基于数据库表的版本解决方案中，一般是通过为数据库表增加一个”version”字段来实现读取出数据时，…- 23
- 0
-
Springcloud微服务项目——人力资源管理(HRM)Day01 项目的搭建
声明：此项目是本人为了学习而记录下来的 并不适用于每个人 如果有不懂得地方可以私信或者留言 最后祝大家敲代码永无BUG！ 文章目录 项目背景 功能模块 项目技术架构 技术架构 技术栈 前台技术 * 后台架构 后端项目微服务原型搭建 搭建一个顶级父类 hrm_parent 搭建springcloud微服务支持模块 hrm_support_parent 搭建Eureka注册中心 hrm-eureka-…- 6
- 0
-
Spring-cloud 微服务架构搭建 04 – Hystrix 监控配合turbine的配置使用
文章目录 Hystrix仪表盘和Turbine集群监控简介 hystrix-dashboard-turbine 模块快速搭建 1. Hystrix仪表盘和Turbine集群监控简介 Hystrix仪表盘主要监控hystrix中的各项指标信息，以“桶”和“滚动时间窗的形式”，进行记录保存供外部调用。Hystrix仪表盘可以对单个服务进行监控，暴露hystrix.stream接口，Turbine整合所…- 5
- 0
-
SpringBoot微服务 +tomcat集群+Ngnix负载均衡+Mysql主从复制，读写分离（2）
PS:首先通过虚拟机模拟了两台linux服务器，版本为CentOS6.6, 二：tomcat集群 1.删除Centos6.6默认的jdk版本，然后手动安装jdk1.8版本环境。具体安装可查看http://blog.csdn.net/u011687186/article/details/52590036 首先执行 rpm-qa|grep jdk 命令（查询当前安装的jdk）然后进行卸载，如下图…- 9
- 0
-
微服务分布式事务实战（一） 项目需求描述和实现步骤
本文通过一个具体实例如何实施springCloud 分布式事务，不对分布式事务理论做探索。由于内容较多，分多个小节来说明 案例需求： 创建2个基于springCloud的微服务，分别访问不同的数据库；然后创建一个整合服务，调用微服务实现数据的保存到2个不同的数据库，要求采用分布式事务，要么都成功，要么都失败。 案例拓扑图: 实现步骤： 1 分布式事务处理器的编译和运行 1Redis 安装 2注册中…- 5
- 0
-
ASP.NET Core微服务之基于MassTransit实现数据最终一致性（1）
Tip: 此篇已加入.NET Core微服务基础系列文章索引 一、预备知识：数据一致性 关于数据一致性的文章，园子里已经有很多了，如果你还不了解，那么可以通过以下的几篇文章去快速地了解了解，有个感性认识即可。 （1）左正，《保证分布式系统数据一致性的6种方案》 （2）成金之路，《分布式系统的数据一致性解决方案》 （3）E_Star，《分布式环境下数据一致性的设计总结》 （4）Itegel，《分布式…- 11
- 0
-
Spring Cloud构建微服务架构：消息驱动的微服务（核心概念）【Dalston版】
通过《Spring Cloud构建微服务架构：消息驱动的微服务（入门）》一文，相信大家对Spring Cloud Stream的工作模式已经有了一些基础概念，比如：输入、输出通道的绑定，通道消息事件的监听等。下面在本文中，我们将详细介绍一下Spring Cloud Stream中是如何通过定义一些基础概念来对各种不同的消息中间件做抽象的。 下图是官方文档中对于Spring Cloud Stream…- 11
- 0
-
Openstack+Kubernetes+Docker微服务实践之路–RPC
重点来了，本文全面阐述一下我们的RPC是怎么实现并如何使用的，跟Kubernetes和Openstack怎么结合。 在选型一文中说到我们选定的RPC框架是Apache Thrift，它的用法是在Main方法中重启服务，在Client端连接服务去调用， 而我的想法是要跟Dubblo、HSF的用法一样，因为很多人都熟习这两个框架的用法，特别是我们好几个项目都是基于EDAS开发的，而且世面上用Dubb…- 16
- 0
-
基于.NET CORE微服务框架 -谈谈Cache中间件和缓存降级
1**、前言** surging受到不少.net同学的青睐，也提了不少问题，提的最多的是什么时候集成API 网关，在这里回答大家最近已经开始着手研发，应该在1,2个月内会有个初版API网关，其它像Token身份验证，限流降级等功能完成时间会往后推 最近也更新了surging新的版本 更新内容： Cache中间件基于Redis 所依赖的第三方库已将servicestack.redis转成stacke…- 19
- 0
-
Netty源码分析第8章(高性能工具类FastThreadLocal和Recycler)—->第7节: 获取异线程释放的对象…
Netty源码分析第8章(高性能工具类FastThreadLocal和Recycler)---->第7节: 获取异线程释放的对象 Netty源码分析第八章: 高性能工具类FastThreadLocal和Recycler 第七节: 获取异线程释放的对象 上一小节分析了异线程回收对象, 原理是通过与stack关联的WeakOrderQueue进行回收 如果对象经过异线程回收之后, 当…- 13
- 0
-
Netty源码分析第6章(解码器)—->第2节: 固定长度解码器
Netty源码分析第六章: 解码器 第二节: 固定长度解码器 上一小节我们了解到, 解码器需要继承ByteToMessageDecoder, 并重写decode方法, 将解析出来的对象放入集合中集合, ByteToMessageDecoder中可以将解析出来的对象向下进行传播, 这一小节带大家剖析一个最简单的解码器FixedLengthFrameDecoder, 从它入手了解码器的相关…- 16
- 0
-
Netty源码分析第4章(pipeline)—->第5节: 传播outbound事件
Netty源码分析第五章: pipeline 第五节: 传播outBound事件 了解了inbound事件的传播过程, 对于学习outbound事件传输的流程, 也不会太困难 在我们业务代码中, 有可能使用wirte方法往写数据: 1public void channelActive(ChannelHandlerContext ctx) throws Exception { 2 ctx.c…- 6
- 0
-
Netty源码分析第2章(NioEventLoop)—->第3节: 初始化线程选择器
Netty源码分析第二章:NioEventLoop ** ** 第三节:初始化线程选择器 回 到上一小节的MultithreadEventExecutorGroup类的构造方法: 1protected MultithreadEventExecutorGroup(int nThreads, Executor executor, 2 EventExecutorChooserFactory choo…- 6
- 0
-
《Netty in Action》中文版—第五章 ByteBuf
http://ifeve.com/netty-in-action-5/ 《Netty in Action》中文版—第五章 ByteBuf **本文翻译自《Netty in Action》第五章 ** 作者：Norman Maurer, Marvin Allen Wolfthal 译者：桃小胖 本章包含 ByteBuf—Netty的数据容器 API详情 用例 内存分配 正如我们前面提到的，网…- 7
- 0
-
Mina、Netty、Twisted一起学（五）：整合protobuf
protobuf是谷歌的Protocol Buffers的简称，用于结构化数据和字节码之间互相转换（序列化、反序列化），一般应用于网络传输，可支持多种编程语言。 protobuf如何使用这里不再介绍，本文主要介绍在MINA、Netty、Twisted中如何使用protobuf，不了解protobuf的同学可以去参考我的另一篇博文。 在前面的一篇博文中，有介绍到一种用一个固定为4字节的前缀Heade…- 11
- 0
-
Java NIO框架Netty教程（一） – Hello Netty
本站采用创作共用版权 CC BY-NC-ND/2.5/CN 许可协议， 如非特别注明，本站内容均为OneCoder原创，转载请务必注明作者和出处 本文地址：链接地址 Java程序员-1群 (已满)：225893085：Java程序员-2群：206787481： Java程序员群论坛，每天分享实用资源 OneCoder的图传已从又拍图片管家迁移到七牛云存储，由于文章过多无法一一修改，如果文中图片无…- 23
- 0
-
Spark为何使用Netty通信框架替代Akka
导读 一直以来，基于Akka实现的RPC通信框架是Spark引以为豪的主要特性，也是与Hadoop等分布式计算框架对比过程中一大亮点，但是时代和技术都在演化，从Spark1.3.1版本开始，为了解决大块数据（如Shuffle）的传输问题，Spark引入了Netty通信框架，到了1.6.0版本，Netty居然完全取代了Akka，承担Spark内部所有的RPC通信以及数据流传输。 一、网络IO扫盲 在…- 66
- 0
-
Netty系列之Netty高性能之道
1. 背景 \ 1.1. 惊人的性能数据 \ 最近一个圈内朋友通过私信告诉我，通过使用Netty4 + Thrift压缩二进制编解码技术，他们实现了10W TPS（1K的复杂POJO对象）的跨节点远程服务调用。相比于传统基于Java序列化+BIO（同步阻塞IO）的通信框架，性能提升了8倍多。 \ 事实上，我对这个数据并不感到惊讶，根据我5年多的NIO编程经验，通过选择合适的NIO框架，加上高性能的…- 25
- 0
-
Netty系列之Netty高性能之道
1. 背景 \ 1.1. 惊人的性能数据 \ 最近一个圈内朋友通过私信告诉我，通过使用Netty4 + Thrift压缩二进制编解码技术，他们实现了10W TPS（1K的复杂POJO对象）的跨节点远程服务调用。相比于传统基于Java序列化+BIO（同步阻塞IO）的通信框架，性能提升了8倍多。 \ 事实上，我对这个数据并不感到惊讶，根据我5年多的NIO编程经验，通过选择合适的NIO框架，加上高性能的…- 6
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×