-
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…- 20
- 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的图传已从又拍图片管家迁移到七牛云存储，由于文章过多无法一一修改，如果文中图片无…- 28
- 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框架，加上高性能的…- 37
- 0
-
Netty系列之Netty高性能之道
1. 背景 \ 1.1. 惊人的性能数据 \ 最近一个圈内朋友通过私信告诉我，通过使用Netty4 + Thrift压缩二进制编解码技术，他们实现了10W TPS（1K的复杂POJO对象）的跨节点远程服务调用。相比于传统基于Java序列化+BIO（同步阻塞IO）的通信框架，性能提升了8倍多。 \ 事实上，我对这个数据并不感到惊讶，根据我5年多的NIO编程经验，通过选择合适的NIO框架，加上高性能的…- 6
- 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…- 17
- 0
-
kafka管理监控插件
kafka 监控插件 1.KafkaOffsetMonitor 项目地址： https://github.com/quantifind/KafkaOffsetMonitor KafkaOffsetMonitor是用来实时监控Kafka集群的consumers以及它们在partition中的offset(偏移量)。 You can see the current consumer groups, f…- 14
- 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…- 16
- 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 …- 4
- 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进行…- 10
- 0
-
-
RabbitMQ消息队列（二）：”Hello, World“
本文将使用Python（pika 0.9.8）实现从Producer到Consumer传递数据”Hello, World“。 首先复习一下上篇所学：RabbitMQ实现了AMQP定义的消息队列。它实现的功能”非常简单“：从Producer接收数据然后传递到Consumer。它能保证多并发，数据安全传递，可扩展。 和任何的Hello world一样，它们都不复杂。我们将会设…- 8
- 0
-
GlusterFS分布式存储系统
1. 分布式文件系统理论基础 1.1 分布式文件系统出现 计算机通过文件系统管理，存储数据，而现在数据信息爆炸的时代中人们可以获取的数据成指数倍的增长，单纯通过增加硬盘个数来扩展计算机文件系统的存储容量的方式，已经不能满足目前的需求。 分布式文件系统可以有效解决数据的存储和管理难题，将固定于某个地点的某个文件系统，扩展到任意多个地点/多个文件系统，众多的节点组成一个文件系统网络。每个节点可以分布在…- 30
- 0
-
Jmeter分布式压测
一、原因 1、当你想并发很大的时候（比如3000）那么一台jmeter可能就不能胜任了，这时候就需要多台jmeter同时加压 2、当jmeter压力机安装在没有gui的linux上，又不想通过非gui的方式完成性能测试 二、原理 原理很简单就是找一台装有jmeter的机器当控制端，由这个控制端统一控制其它装有jmeter的机器作为代理，产生压力。如下图 三、安装jdk和jmeter 1、分别下载…- 13
- 0
-
Zookeeper实现分布式锁
文章目录 什么是Zookeeper Zookeeper集群机制 Zookeeper特性 Zookeeper数据结构 Zookeeper应用场景 Zookeeper的环境搭建（linux） Zookeeper客户端 Zookeeper配置文件介绍 Java操作Zookeeper Zookeeper的事件通知 使用Zookeeper实现分布式锁的思路 Redis实现分布式锁代码实现 什么是Zookee…- 15
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×