-
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，其他很多都是基于微软开发的框架做些封装而形成新的框架，大都是还没起好名就湮灭在历史长河中），而自己开发的框架…- 0
- 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…- 7
- 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 ，提高并行处理而又解决一些并行产…- 4
- 0
-
Mina、Netty、Twisted一起学（十）：线程模型
要想开发一个高性能的TCP服务器，熟悉所使用框架的线程模型非常重要。MINA、Netty、Twisted本身都是高性能的网络框架，如果再搭配上高效率的代码，才能实现一个高大上的服务器。但是如果不了解它们的线程模型，就很难写出高性能的代码。框架本身效率再高，程序写的太差，那么服务器整体的性能也不会太高。就像一个电脑，CPU再好，内存小硬盘慢散热差，整体的性能也不会太高。 玩过Android开发的同学…- 3
- 0
-
Java NIO框架Netty教程 (九)-再谈收发信息次数问题
在《Java NIO框架Netty教程（七）- 消息收发次数不匹配的问题》里我们试图分析一个消息收发次数不匹配的问题。当时笔者还是心存疑惑的。所以决定先学习一下Java NIO的Selector机制。 经过简单的了解，笔者大胆的猜测和“武断”一下该问题的原因。 首先，Selector机制让我们注册一个感兴趣的时间，然后只要有该时间发生，就会传递给接收端。我们写了三次，接收端一定会出发三次的。 然后…- 4
- 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…- 9
- 0
-
Netty websocket
Network protocols WebSocket是一种高级网络协议，旨在提高Web应用程序的性能和响应能力。 我们将通过编写示例应用程序来探索Netty对它们的支持。 在第12章中，您将学习如何使用WebSocket实现双向数据传输，方法是构建一个聊天室服务器，其中多个浏览器客户端可以实时通信。 您还将看到如何通过检测客户端是否支持它，从应用程序中的HTTP切换到WebSocket协议。 我…- 10
- 0
-
Kafka实战(二) – 摸清 Kafka 的"黑话"
Kafka属分布式消息引擎系统,提供一套完备的消息发布与订阅解决方案。 在Kafka中，发布订阅的对象是主题（Topic），可为每个业务、每个应用甚至是每类数据都创建专属的主题。 1 Producer & Consumer 向主题发布消息的客户端应用称为生产者（Producer），生产者程序通常持续不断地向一个或多个主题发送消息，而订阅这些主题消息的客户端应用程序就被称为消费者（Consu…- 6
- 0
-
微服务分布式企业框架 Springmvc+mybatis+shiro+Dubbo+ZooKeeper+Redis+KafKa
主要定位于互联网企业架构，已内置企业信息化系统的基础功能和高效的代码生成工具，包括：系统权限组件、数据权限组件、数据字典组件、核心工具 组件、视图操作组件、工作流组件组件、代码生成等。采用分层设计、双重验证、提交数据安全编码、密码加密、访问验证、数据权限验证。 平台简介 是一个分布式框架，提供项目模块化、服务化、热插拔的思想，高度封装安全性的Java EE快速开发平台。本身集成Dubbo服务管控、…- 7
- 0
-
flume-ng+Kafka+Storm+HDFS 实时系统组合
大数据我们都知道hadoop，但并不都是hadoop.我们该如何构建大数据库项目。对于离线处理，hadoop还是比较适合的，但是对于实时性比较强的，数据量比较大的，我们可以采用Storm，那么Storm和什么技术搭配，才能够做一个适合自己的项目。下面给大家可以参考。 可以带着下面问题来阅读本文章： 1.一个好的项目架构应该具备什么特点？ 2.本项目架构是如何保证数据准确性的？ 3.什么是Kafka…- 3
- 0
-
Kafka消息序列化和反序列化（下）
接上一篇：Kafka消息序列化和反序列化（上）。 有序列化就会有反序列化，反序列化的操作是在Kafka Consumer中完成的，使用起来只需要配置一下key.deserializer和value.deseriaizer。对应上面自定义的Company类型的Deserializer就需要实现org.apache.kafka.common.serialization.Deserializer接口，这…- 7
- 0
-
Java使用RabbitMQ（九）–RPC
首先声明： RPC调用会增加系统复杂度以及调试难度， 容易使代码混乱，系统缓慢。 尽量避免使用RPC，转而使用异步管道替代。 rabbitMQ实现的RPC主要流程： 客户端启动后，创建一个匿名唯一的回调队列 对于一个RPC请求，客户端发送一个消息和2个属性，一个是replyto用来设置回调队列，另一个是correlationId，每个请求的值都是唯一的 RPC worker（也是被调用的服务方）从…- 4
- 0
-
.Net下RabbitMQ的使用(6) — 消息的传输控制
前文中也多次提到消息传输的一些概念，这一篇比较全面的介绍一下，然后补充一些内容。 消息的应答 RabbitMQ有两种应答模式，自动和手动。这也是AMQP协议所推荐的。这在point-to-point和broadcast都是一样的。 自动应答-当RabbitMQ把消息发送到接收端，接收端把消息出队列的时候就自动帮你发应答消息给服务。 手动应答-需要我们开发人员手动去调用ack方法去告诉服务已经收到。…- 35
- 0
-
RabbitMQ的六种工作模式
一.基于erlang语言： 是一种支持高并发的语言 RabbitMQ的六种工作模式： 1.1 simple简单模式 消息产生着§将消息放入队列 消息的消费者(consumer) 监听(while) 消息队列,如果队列中有消息,就消费掉,消息被拿走后,自动从队列中删除(隐患 消息可能没有被消费者正确处理,已经从队列中消失了,造成消息的丢失)应用场景:聊天(中间有一个过度的服务器;p端,c端) 1.2…- 5
- 0
-
RabbitMQ消息队列（一）: Detailed Introduction 详细介绍
1. 历史 RabbitMQ是一个由erlang开发的AMQP（Advanced Message Queue ）的开源实现。AMQP 的出现其实也是应了广大人民群众的需求，虽然在同步消息通讯的世界里有很多公开标准（如 COBAR的 IIOP ，或者是 SOAP 等），但是在异步消息处理中却不是这样，只有大企业有一些商业实现（如微软的 MSMQ ，IBM 的 Websphere MQ 等），…- 9
- 0
-
python操作RabbitMQ
RabbitMQ介绍 RabbitMQ是一个由erlang开发的AMQP（Advanced Message Queue）的开源实现的产品，RabbitMQ是一个消息代理，从“生产者”接收消息并传递消息至“消费者”，期间可根据规则路由、缓存、持久化消息。“生产者”也即message发送者以下简称P，相对应的“消费者”乃message接受者以下简称C，message通过queue由P到C，queue…- 10
- 0
-
Spring分布式事务实现
分布式事务是指操作多个数据库之间的事务，spring的org.springframework.transaction.jta.JtaTransactionManager，提供了分布式事务支持。如果使用WAS的JTA支持，把它的属性改为WebSphere对应的TransactionManager。 在tomcat下，是没有分布式事务的，不…- 6
- 0
-
分布式session
一、session是什么？从哪来？ 简单来说，session就是浏览器和服务器的一系列交互动作。 为什么会出现session？这是因为HTTP协议的特点-- 无状态性--导致的。 我们通过浏览器上网时，浏览器和服务器间是通过HTTP协议交互。当我们请求页面时， 这一次请求和上一次请求没有任何关系，这就是无状态性。无状态性使得交互更加快速，但也带来一个问题，例如：当我在商品详情页面登陆后，等到了订单…- 10
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×