-
Spring Cloud构建微服务架构：服务消费（Ribbon）【Dalston版】
通过上一篇《Spring Cloud构建微服务架构：服务消费（基础）》，我们已经学会如何通过LoadBalancerClient接口来获取某个服务的具体实例，并根据实例信息来发起服务接口消费请求。但是这样的做法需要我们手工的去编写服务选取、链接拼接等繁琐的工作，对于开发人员来说非常的不友好。所以，下来我们看看Spring Cloud中针对客户端负载均衡的工具包：Spring Cloud Ribbo…- 0
- 0
-
ASP.NET Core微服务之基于Consul实现服务治理（3）
一、示例整体架构 此示例会由一个API Gateway, 一个Consul Client以及三个Consul Server组成，有关Consul的Client和Server这两种模式的Agent的背景知识，请移步我之前的文章加以了解：《.NET Core微服务之基于Consul实现服务治理》。其中，Consul的Client和Server节点共同构成一个Data Center，而API Gatew…- 6
- 0
-
Netty源码分析第8章(高性能工具类FastThreadLocal和Recycler)—->第6节: 异线程回收对象…
Netty源码分析第8章(高性能工具类FastThreadLocal和Recycler)---->第6节: 异线程回收对象 Netty源码分析第八章: 高性能工具类FastThreadLocal和Recycler 第六节: 异线程回收对象 异线程回收对象, 就是创建对象和回收对象不在同一条线程的情况下, 对象回收的逻辑 我们之前小节简单介绍过, 异线程回收对象, 是不会放在当前线…- 1
- 0
-
Netty源码分析第4章(pipeline)—->第3节: handler的删除
Netty源码分析第四章: pipeline 第三节: handler的删除 上一小节我们学习了添加handler的逻辑操作, 这一小节我们学习删除handler的相关逻辑 如果用户在业务逻辑中进行ctx.pipeline().remove(this)这样的写法, 或者ch.pipeline().remove(new SimpleHandler())这样的写法, 则就是对han…- 4
- 0
-
Netty源码分析第2章(NioEventLoop)—->第7节: 处理IO事件
Netty源码分析第二章: NioEventLoop ** ** 第七节:处理IO事件 上一小节我们了解了执行select()操作的相关逻辑, 这一小节我们继续学习select()之后, 轮询到io事件的相关逻辑: 回到NioEventLoop的run()方法: 1protected void run() { 2 for (;;) { 3 try { 4 switch (selectS…- 9
- 0
-
Netty源码分析第2章(NioEventLoop)—->第1节: NioEventLoopGroup之创建线程执行器
Netty源码分析第二章: NioEventLoop 概述: 通过上一章的学习, 我们了解了Server启动的大致流程, 有很多组件与模块并没有细讲, 从这个章开始, 我们开始详细剖析netty的各个组件, 并结合启动流程, 将这些组件的使用场景及流程进行一个详细的说明 这一章主要学习NioEventLoop相关的知识, 何为NioEventLoop? Ni…- 6
- 0
-
Netty In Action中文版 – 第七章：编解码器Codec
Netty In Action中文版 - 第七章：编解码器Codec 本章介绍 Codec，编解码器 Decoder，解码器 Encoder，编码器 Netty提供了编解码器框架，使得编写自定义的编解码器很容易，并且也很容易重用和封装。本章讨论Netty的编解码器框架以及使用。 7.1 编解码器Codec 编写一个网络应用程序需要实现某种编解码器，编解码器的作用就是讲原始字节数据与…- 3
- 0
-
使用Netty进行文件传输
一、简介 使用Netty进行文件传输主要涉及到FileChannel文件通道，它用来连接文件，可以通过这个通道读写文件。在使用FileChannel之前必须先打开它，FileChannel无法直接打开，可以通过InputStream、OutputStream或RandomAccessFile来获取FileChannel实例，比如： 1RandomAccessFile file=new Random…- 306
- 0
-
通俗地讲，Netty 能做什么？
https://www.zhihu.com/question/24322387/answer/78947405 作者：郭无心 链接：https://www.zhihu.com/question/24322387/answer/78947405 来源：知乎 著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。 Netty是什么？ 1）本质：JBoss做的一个Jar包 2）目的…- 7
- 0
-
Netty零拷贝机制
Netty零拷贝机制 Netty自己的ByteBuf JDK ByteBuffer的缺点： ByteBuf做了那些增强 ByteBuf操作 ByteBuf动态扩容原理 选择合适的ByteBuf实现 Unsafe的实现 PooledByteBuf对象、内存复用 零拷贝机制 Netty自己的ByteBuf ByteBuf是为解决ByteBuffer的问题和满足网络应用程序开发人员的日常需求儿设计的。 …- 11
- 0
-
基于Dubbo框架构建分布式服务
Dubbo是Alibaba开源的分布式服务框架，我们可以非常容易地通过Dubbo来构建分布式服务，并根据自己实际业务应用场景来选择合适的集群容错模式，这个对于很多应用都是迫切希望的，只需要通过简单的配置就能够实现分布式服务调用，也就是说服务提供方（Provider）发布的服务可以天然就是集群服务，比如，在实时性要求很高的应用场景下，可能希望来自消费方（Consumer）的调用响应时间最短，只需要选…- 0
- 0
-
Kafka实战(七) – 优雅地部署 Kafka 集群
既然是集群，必然有多个Kafka节点，只有单节点构成的Kafka伪集群只能用于日常测试，不可能满足线上生产需求。 真正的线上环境需要考量各种因素，结合自身的业务需求而制定。看一些考虑因素（以下顺序，可是分了顺序的哦） 1 操作系统 - OS 可能你会问Kafka不是JVM上的大数据框架吗？Java又是跨平台的语言，把Kafka安装到不同的操作系统上会有什么区别吗？ 区别相当大！ 确实，Kafka由…- 10
- 0
-
RabbitMQ VS Apache Kafka （八）—— Kafka消息路由原语与路由保证
Kafka的路由保证主要基于以下实现： 消息持久化：一旦消息存储到主题中，则确认不会出现丢失消息的问题 消息确认：Kafka（或者是Zookeeper）与发布者、订阅者之间的消息通信 消息批量 Kafka与RabbitMQ一个最大的不同之处在于Kafka支持在消息发送和处理时批量操作。当然，RabbitMQ也可以实现类似批量的操作： 每多少条消息暂停一次直至收到所有的消息确认。 消费者设置预取阈值…- 21
- 0
-
Kafka分区分配策略（1）——RangeAssignor
引言 按照Kafka默认的消费逻辑设定，一个分区只能被同一个消费组（ConsumerGroup）内的一个消费者消费。假设目前某消费组内只有一个消费者C0，订阅了一个topic，这个topic包含7个分区，也就是说这个消费者C0订阅了7个分区，参考下图（1）。 此时消费组内又加入了一个新的消费者C1，按照既定的逻辑需要将原来消费者C0的部分分区分配给消费者C1消费，情形上图（2），消费者C0和C1各…- 10
- 0
-
Kafka和消息队列之间的超快速比较
原文：A super quick comparison between Kafka and Message Queues 作者：Hendrik Swanepoel 翻译：Vincent 译者注：本文的目的是让读者快速了解Kafka与消息队列之间的关系，告诉读者为什么会考虑使用它的原因。以下为译文。 Kafka最初是由Linkedin社区开发的一项技术。简而言之，它有点像消息队列系统，但它与消息队列…- 3
- 0
-
Kafka实战－Storm Cluster
1.概述 在《Kafka实战－实时日志统计流程》一文中，谈到了Storm的相关问题，在完成实时日志统计时，我们需要用到Storm去消费Kafka Cluster中的数据，所以，这里我单独给大家分享一篇Storm Cluster的搭建部署。以下是今天的分享目录： Storm简述 基础软件 安装部署 效果预览 下面开始今天的内容分享。 2.Storm简述 Twitter将Storm开源了，这是一个分布…- 5
- 0
-
Java使用RabbitMQ（三）–消息确认
消息确认 RabbitMQ 每将一个消息交付给一个消费者时，会立刻把这个消息标记为被删除，如果消费者在处理消息时怠机了，那么这个消息就彻底消失了，这很明显不符合我们的期望，我们希望在一个消费者怠机时，把这个消息交付给其他消费者处理。 所以 RabbitMQ 让消费者在处理完消息后，返回确认消息，告知RabbitMQ 你确实可以删除这条消息了。 也就是 channel.basicConsume(TA…- 8
- 0
-
C# 操作rabbitmq（三）
此篇介绍rabbitmq的Routing 一、 使用exchange时，会广播给所有连接的consumer，而有时候我们需要订阅消息的子集就好，例如只需要其中的一些错误信息写入到日志当中 二、 Bindings 在上一篇中我们创建了exchange和queue的绑定，其中有一个属性routingKey，该属性依赖于exchange的类型，fanout会忽略改属性。 direct类型的exchang…- 12
- 0
-
Spring Boot 配置多源的 RabbitMQ
简介 MQ 是开发中很平常的中间件，本文讲述的是怎么在一个Spring Boot项目中配置多源的RabbitMQ，这里不过多的讲解RabbitMQ的相关知识点。如果你也有遇到需要往多个RabbitMQ中发送消息的需求，希望本文可以帮助到你。 环境 rabbitmq 3.7.12 spring boot 2.1.6.RELEASE 当然软件的版本不是硬性要求，只是我使用的环境而已，唯一的要求是需要启…- 18
- 0
-
RabbitMQ消息队列（六）：使用主题进行消息分发
在上篇文章 RabbitMQ消息队列（五）：Routing 消息路由 中，我们实现了一个简单的日志系统。Consumer可以监听不同severity的log。但是，这也是它之所以叫做简单日志系统的原因，因为是仅仅能够通过severity设定。不支持更多的标准。 比如syslog unix的日志工具，它可以通过severity (info/warn/crit...)…- 6
- 0
-
RabbitMQ消息持久化
在某些特定场景中,队列中的数据十分重要,比如当客户需要确认支付时的验证码,这时候如果服务器突然出现了故障,那么队列中的消息必须存在,不能丢失.这种消息需要进行持久化处理.这也是RabbitMQ的一大特色,消息可靠性 消息持久化:在服务器出现故障后,消息依旧存在于队列之中. 一.queue的持久化 queue的持久化通过durable=true来实现,信道的第二个参数即durable 1channe…- 8
- 0
-
分布式中 CAP BASE ACID 理解
概念理解（CAP,BASE, ACID) CAP CAP: Consistency, Availability, Partition-tolerance **强一致性(Consistency)。**系统在执行过某项操作后仍然处于一致的状态。在分布式系统中，更新操作执行成功后所有的用户都应该读取到最新的值，这样的系统被认为具有强一致性。 **可用性(Availability)。**每一个操作总是能…- 8
- 0
-
MyCat,Cobar,分布式数据库分片（MySQL高可用中间件）
**大纲 ** 第一 MYCAT 背景 第二 MYCAT 发展 第三 MYCAT 简介 第四 MYCAT特性 第五 MYCAT安装使用 第六 MYCAT和COBAR 比较 第七 参考 **一，**背景 随着传统的数据库技术日趋成熟、计算机网络技术的飞速发展和应用范围的扩充，数据库应用已经普遍建立于计算机网络之上。这时集中式数据库系统表现出它的不足： （1）集中式处理，势必造成性能瓶颈； （2）…- 20
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×