-
ASP.NET Core微服务之基于Steeltoe使用Spring Cloud Config统一管理配置
Tip: 此篇已加入.NET Core微服务基础系列文章 一、关于Spring Cloud Config 在分布式系统中，每一个功能模块都能拆分成一个独立的服务，一次请求的完成，可能会调用很多个服务协调来完成，为了方便服务配置文件统一管理，更易于部署、维护，所以就需要分布式配置中心组件了，在Spring Cloud中，就有这么一个分布式配置中心组件 — Spring Cloud Config。 S…- 9
- 0
-
Spring Cloud构建微服务架构：服务消费（Ribbon）【Dalston版】(转载+自己实现)
通过上一篇《Spring Cloud构建微服务架构：服务消费（基础）》，我们已经学会如何通过LoadBalancerClient接口来获取某个服务的具体实例，并根据实例信息来发起服务接口消费请求。但是这样的做法需要我们手工的去编写服务选取、链接拼接等繁琐的工作，对于开发人员来说非常的不友好。所以，下来我们看看Spring Cloud中针对客户端负载均衡的工具包：Spring Cloud Ribbo…- 1
- 0
-
Spring Cloud构建微服务架构：Hystrix监控数据聚合【Dalston版】
上一篇我们介绍了使用Hystrix Dashboard来展示Hystrix用于熔断的各项度量指标。通过Hystrix Dashboard，我们可以方便的查看服务实例的综合情况，比如：服务调用次数、服务调用延迟等。但是仅通过Hystrix Dashboard我们只能实现对服务单个实例的数据展现，在生产环境我们的服务是肯定需要做高可用的，那么对于多实例的情况，我们就需要将这些度量指标数据进行聚合。下面…- 6
- 0
-
.Net Core 分布式微服务框架介绍 – Jimu
系列文章 .Net Core 分布式微服务框架介绍 - Jimu .Net Core 分布式微服务框架 - Jimu 添加 Swagger 支持 一、前言 近些年一直浸淫在 .Net 平台做企业应用开发，用过的 .Net 框架不多（具体数量不清，印象深刻的有 Asp.Net MVC，WPF，其他很多都是基于微软开发的框架做些封装而形成新的框架，大都是还没起好名就湮灭在历史长河中），而自己开发的框架…- 2
- 0
-
6种微服务RPC框架，你知道几个？
开源 RPC 框架有哪些呢？ 一类是跟某种特定语言平台绑定的，另一类是与语言无关即跨语言平台的。 跟语言平台绑定的开源 RPC 框架主要有下面几种。 Dubbo：国内最早开源的 RPC 框架，由阿里巴巴公司开发并于 2011 年末对外开源，仅支持 Java 语言。 Motan：微博内部使用的 RPC 框架，于 2016 年对外开源，仅支持 Java 语言。 Tars：腾讯内部使用的 RPC 框架，…- 7
- 0
-
Netty源码分析第5章(ByteBuf)—->第5节: directArena分配缓冲区概述
Netty源码分析第五章: ByteBuf 第五节: directArena分配缓冲区概述 上一小节简单分析了PooledByteBufAllocator中, 线程局部缓存和arean的相关逻辑, 这一小节简单分析下directArena分配缓冲区的相关过程 回到newDirectBuffer中: 1protected ByteBuf newDirectBuffer(int initi…- 8
- 0
-
Netty源码分析第3章(客户端接入流程)—->第4节: NioSocketChannel注册到selector
Netty源码分析第三章: 客户端接入流程 第四节: NioSocketChannel注册到selector 我们回到最初的NioMessageUnsafe的read()方法: 1public void read() { 2 //必须是NioEventLoop方法调用的, 不能通过外部线程调用 3 assert eventLoop().inEventLoop(); 4 //服务端cha…- 3
- 0
-
[编织消息框架][netty源码分析]8 Channel 实现类NioSocketChannel职责与实现
Unsafe是托委访问socket，那么Channel是直接提供给开发者使用的 Channel 主要有两个实现 NioServerSocketChannel同NioSocketChannel 致于其它不常用不在研究范围内 NioServerSocketChannel 是给server用的，程序由始至终只有一个NioServerSocketChannel NioSocketChannel 是给客户端…- 4
- 0
-
[编织消息框架][netty源码分析]2 EventLoop
eventLoop从命名上看是专门处理事件 事件系统主要由线程池同队列技术组成，有以下几个优点 1.任务出队有序执行，不会出现错乱，当然前提执行线程池只有一个 2.解偶系统复杂度，这是个经典的生产者/消费者模型，生产者只需要生成执行上下文需要的数据，消费者集中实现处理逻辑，无需要关注太多关系层次问题 3.可根据业务按单一类型事件独立分配一套event system ，提高并行处理而又解决一些并行产…- 6
- 0
-
Mina、Netty、Twisted一起学（十）：线程模型
要想开发一个高性能的TCP服务器，熟悉所使用框架的线程模型非常重要。MINA、Netty、Twisted本身都是高性能的网络框架，如果再搭配上高效率的代码，才能实现一个高大上的服务器。但是如果不了解它们的线程模型，就很难写出高性能的代码。框架本身效率再高，程序写的太差，那么服务器整体的性能也不会太高。就像一个电脑，CPU再好，内存小硬盘慢散热差，整体的性能也不会太高。 玩过Android开发的同学…- 4
- 0
-
Java NIO框架Netty教程 (九)-再谈收发信息次数问题
在《Java NIO框架Netty教程（七）- 消息收发次数不匹配的问题》里我们试图分析一个消息收发次数不匹配的问题。当时笔者还是心存疑惑的。所以决定先学习一下Java NIO的Selector机制。 经过简单的了解，笔者大胆的猜测和“武断”一下该问题的原因。 首先，Selector机制让我们注册一个感兴趣的时间，然后只要有该时间发生，就会传递给接收端。我们写了三次，接收端一定会出发三次的。 然后…- 6
- 0
-
Java NIO框架Netty教程(十二)-并发访问测试(中)
写在前面：对Netty并发问题的测试和解决完全超出了我的预期，想说的东西越来越多。所以才出现这个中篇，也就是说，一定会有下篇。至于问题点的发现，OneCoder也在努力验证中。 继续并发的问题。在《Java NIO框架Netty教程(十一)-并发访问测试(上)》中，我们测试的其实是一种伪并发的情景。底层实际只有一个Channel在运作，不会出现什么无响应的问题。而实际的并发不是这个意思的，独立的客…- 8
- 0
-
Netty服务端启动
源码 1public final class Server { 2 3 public static void main(String[] args) throws Exception { 4 EventLoopGroup bossGroup = new NioEventLoopGroup(1); 5 EventLoopGroup workerGroup = new NioEventLoopGrou…- 12
- 0
-
Netty websocket
Network protocols WebSocket是一种高级网络协议，旨在提高Web应用程序的性能和响应能力。 我们将通过编写示例应用程序来探索Netty对它们的支持。 在第12章中，您将学习如何使用WebSocket实现双向数据传输，方法是构建一个聊天室服务器，其中多个浏览器客户端可以实时通信。 您还将看到如何通过检测客户端是否支持它，从应用程序中的HTTP切换到WebSocket协议。 我…- 12
- 0
-
kafka原理和实践（四）spring-kafka消费者源码
系列目录 kafka原理和实践（一）原理：10分钟入门 kafka原理和实践（二）spring-kafka简单实践 kafka原理和实践（三）spring-kafka生产者源码 kafka原理和实践（四）spring-kafka消费者源码 kafka原理和实践（五）spring-kafka配置详解 kafka原理和实践（六）总结升华 ==============正文分割线=========…- 37
- 0
-
Kafka分区分配策略（3）——自定义分区分配策略
自定义分区分配策略 读者不仅可以任意选用Kafka所提供的3种分配策略，还可以自定义分配策略来实现更多可选的功能。自定义的分配策略必须要实现org.apache.kafka.clients.consumer.internals.PartitionAssignor接口。PartitionAssignor接口的定义如下： 1Subscription subscription(Set<String…- 20
- 0
-
kafka管理监控插件
kafka 监控插件 1.KafkaOffsetMonitor 项目地址： https://github.com/quantifind/KafkaOffsetMonitor KafkaOffsetMonitor是用来实时监控Kafka集群的consumers以及它们在partition中的offset(偏移量)。 You can see the current consumer groups, f…- 15
- 0
-
docker安装kafka,超级简单的
简介 kafka是一个分布式消息队列。具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息，消费者从队列里取消息进行业务逻辑。一般在架构设计中起到解耦、削峰、异步处理的作用。 kafka对外使用topic的概念，生产者往topic里写消息，消费者从读消息。为了做到水平扩展，一个topic实际是由多个partition组成的，遇到瓶颈时，可以通过增加partition的数量来进行横向扩…- 16
- 0
-
flume+kafka+storm
1. 需求 将mysql增量变化的数据，实时的插入到postgresql数据库中，方法有多种实现，这里采用通过flume配置mysql的数据库源，然后flume采集到mysql的增量数据，作为kafka的生产者，然后进入kafka短暂存储，storm作为kafka的消费者，消费到kafka中的增量mysql数据，进行处理，插入到postgresql中。 整个实验环境在HDP环境中，也可以自行搭建A…- 17
- 0
-
Docker 之 部署RabbitMQ集群并实现Haproxy代理(二)
前言 本小节学习一下使用Docker-compose部署Rabbitmq集群。 目录参考 1[root@iZ2ze8sm5upgi8z1dcazqeZ rabbitmq]# pwd 2/workspace/rabbitmq 3[root@iZ2ze8sm5upgi8z1dcazqeZ rabbitmq]# tree 4. 5├── config 6│ └── docker-compose.yml …- 6
- 0
-
使用Rabbitmq/spring进行RPC
使用RabbitMQ进行RPC的必要 常见的RPC方法/协议包括CORBA，Java RMI，Web Service，Hessian，Thrift及Rest API，相对于前面提到的RPC方式，使用RabbbitMQ（JMS也是一样）方式需要在client-service provider中间增加MQ组件，这样做增加了部署的复杂性，但同时带来额外的好处。 可以对service provider进行…- 11
- 0
-
-
RabbitMQ消息队列（二）：”Hello, World“
本文将使用Python（pika 0.9.8）实现从Producer到Consumer传递数据”Hello, World“。 首先复习一下上篇所学：RabbitMQ实现了AMQP定义的消息队列。它实现的功能”非常简单“：从Producer接收数据然后传递到Consumer。它能保证多并发，数据安全传递，可扩展。 和任何的Hello world一样，它们都不复杂。我们将会设…- 11
- 0
-
GlusterFS分布式存储系统
1. 分布式文件系统理论基础 1.1 分布式文件系统出现 计算机通过文件系统管理，存储数据，而现在数据信息爆炸的时代中人们可以获取的数据成指数倍的增长，单纯通过增加硬盘个数来扩展计算机文件系统的存储容量的方式，已经不能满足目前的需求。 分布式文件系统可以有效解决数据的存储和管理难题，将固定于某个地点的某个文件系统，扩展到任意多个地点/多个文件系统，众多的节点组成一个文件系统网络。每个节点可以分布在…- 32
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×