-
Java NIO框架Netty教程(五)-Netty中OIO模型(对比NIO)
一篇OIO和NIO对比的小研究。Netty中不光支持了Java中NIO模型，同时也提供了对OIO模型的支持。（New IO vs Old IO）。 首先，在Netty中，切换OIO和NIO两种模式是非常方便的，只需要初始化不同的Channel工程即可。 1ServerBootstrap bootstrap =new ServerBootstrap( 2 newOioServerSocketChan…- 8
- 0
-
Netty实现Http服务器
Netty实现Http服务器 Netty是一个异步事件驱动的网络应用程序框架用于快速开发和可维护的高性能协议服务器和客户端。Netty经过精心设计，具有丰富的协议，如FTP，SMTP，HTTP以及各种二进制和基于文本的传统协议。 Java程序员在开发web应用的时候，…- 7
- 0
-
基于Dubbo框架构建分布式服务
Dubbo是Alibaba开源的分布式服务框架，我们可以非常容易地通过Dubbo来构建分布式服务，并根据自己实际业务应用场景来选择合适的集群容错模式，这个对于很多应用都是迫切希望的，只需要通过简单的配置就能够实现分布式服务调用，也就是说服务提供方（Provider）发布的服务可以天然就是集群服务，比如，在实时性要求很高的应用场景下，可能希望来自消费方（Consumer）的调用响应时间最短，只需要选…- 7
- 0
-
kafka原理系列之（二）partition的消费策略
1、topic和partition以及consumer关系 一个topic可以认为一个一类消息，每个topic将被分成多个partition，每个partition在存储层面是append log文件。任何发布到此partition的消息都会被追加到log文件的尾部，每条消息在文件中的位置称为offset(偏移量)，offset为一个long型的数字，它唯一标记一条消息。每条消息都被append到…- 22
- 0
-
Kafka、RabbitMQ、RocketMQ等 消息中间件 介绍和对比
文章目录 1、前言 2、概念 2.1、MQ简介 2.2、MQ特点 2.2.1、先进先出 2.2.2、发布订阅 2.2.3、持久化 2.2.4、分布式 3、消息中间件性能究竟哪家强? 3.1、Kafka 3.2、RabbitMQ 3.3、RocketMQ 4、测试 4.1、测试目的 4.2、测试场景 4.2.1、Kafka 4.2.2、RocketMQ 4.2.3、RabbitMQ 4.3、测试结论…- 25
- 0
-
如何管理Spark Streaming消费Kafka的偏移量（三）
前面的文章已经介绍了在spark streaming集成kafka时，如何处理其偏移量的问题，由于spark streaming自带的checkpoint弊端非常明显，所以一些对数据一致性要求比较高的项目里面，不建议采用其自带的checkpoint来做故障恢复。 在spark streaming1.3之后的版本支持direct kafka stream，这种策略更加完善，放弃了原来使用Kafka的…- 8
- 0
-
Elasticsearch 与 Kafka 整合剖析
1.概述 目前，随着大数据的浪潮，Kafka 被越来越多的企业所认可，如今的Kafka已发展到0.10.x，其优秀的特性也带给我们解决实际业务的方案。对于数据分流来说，既可以分流到离线存储平台（HDFS），离线计算平台（Hive仓库），也可以分流实时流水计算（Storm，Spark）等，同样也可以分流到海量数据查询（HBase），或是及时查询（ElasticSearch）。而今天笔者给大家分享的就…- 4
- 0
-
虚函数与动态绑定的那点事
面向对象编程的概念 1）多态：简单理解就是多种形态，通过继承而相关联的类型，特别在运行的情况下，对象可能是基类也可能派生类类型 1）继承：能够对类型之间的关系建模，共享公共的东西，仅仅特化本质上不同的东西。 定义为virtual的函数是基类期待派生类重新定义的，基类不希望派生类继承的则定义为非虚函数，这样类就有虚函数与非虚函数之分 2）动态绑定：使程序使用继承层次中任意类型的对象，无需关心具体的类…- 7
- 0
-
Docker下RabbitMQ四部曲之四：高可用实战
本章是《Docker下RabbitMQ四部曲》系列的终篇，今天的我们一起来体验Rabbit’MQ集群的高可用能力，看看RabbitMQ集群中的部分节点宕机时，是否还能生产和消费消息； 实战概要 今天实战的步骤如下： 制作docker-compose.yml文件，为每个容器配置好参数； 启动所有容器，包括RabbitMQ集群、消息生产者的web应用、消息消费者的web应用； 逐个停止集群中的Rabb…- 12
- 0
-
.Net下RabbitMQ的使用(8) — 远程过程调用RPC
RPC是在计算中是一种常见的模式，是通常我要用消息队列来实现RPC有3个关键点： 服务的寻址 消息的接收 消息的关联 在RabbitMQ的.net客户端里，提供了2个类：SimpleRpcClient 和 SimpleRpcServer 来让我们方便的开发RPC应用。 因为RabbitMQ的RPC一定是基于队列的，所以在客户端和服务端都需要要一个各自的队列，客户端的队列用来接收服务回复的数据，…- 5
- 0
-
.Net下RabbitMQ的使用(3) — 竞争的消费者
在上一篇文章中，演示了一个发送者和一个消费者的情况。这一篇介绍一下多个消费者在同一个消息队列中获取消息的情况。 在有些应用当中，消费端接收到消息任务需要长时间的处理，如果等上一个消息处理完成以后再取下一个数据进行处理的话，势必会有一些延迟。在消息队列中的数据也会不断增多，延迟将越来越大。当然对于一个消费进程来说，在某些情况下可以起多个线程来处理，而在这里将介绍另一种处理方式，多个消费进程的情况…- 13
- 0
-
RabbitMQ消息队列（五）：Routing 消息路由
上篇文章中，我们构建了一个简单的日志系统。接下来，我们将丰富它：能够使用不同的severity来监听不同等级的log。比如我们希望只有error的log才保存到磁盘上。 1. Bindings绑定 上篇文章中我们是这么做的绑定： 1channel.queue_bind(exchange=exchange_name, 2 queue=queue_name) 3 绑定其实就是关联了exchange和q…- 8
- 0
-
nagios分布式监控配置
一、在分布式机器上安装和nagios主监控机一样配置好，在界面上呈现出相关监控信息后 二、开始安装NSCA模块 下载地址 http://nchc.dl.sourceforge.net/sourceforge/nagios/nsca-2.7.2.tar.gz 安装步骤 ./configure && make all 这样就安装完毕了，下面是客户端相关配置 cd nsca-2.7.2…- 30
- 0
-
Hadoop分布式文件系统
分布式文件系统，架构于网络之上，引入网络编程的复杂性 HDFS:Haddop Distributed Filesystem HDFS设计 超大文件、流式数据访问：HDFS的构建思路是一次写入、多次读取是最高效的访问模式。、商用硬件 低时间延迟的数据访问：HDFS是为高数据吞吐量应用优化的，可能会以提高时间延迟为代价。、大量的小文件：由于namenode将文件系统的元数据存储在内存中，因此该文件系统…- 11
- 0
-
13. Dubbo原理解析-注册中心之Zookeeper协议注册中心
下面我们来看下开源dubbo推荐的业界成熟的zookeeper做为注册中心， zookeeper是hadoop的一个子项目是分布式系统的可靠协调者，他提供了配置维护，名字服务，分布式同步等服务。对于zookeeper的原理本文档不分析，后面有时间在做专题。 zookeeper注册中心 Zookeeper对数据存储类似linux的目录结构，下面给出官方文档对dubbo注册数据的存储示例 假设读者…- 10
- 0
-
7. Dubbo原理解析-与spring融合
Spring中bean的定义可以通过编程，可以定义在properties文件，也可以定义在通过xml文件中，用的最多的是通过xml形式，由于xml格式具有很好的自说明便于编写及维护。对于xml的文档结构、数据定义及格式验证可以通过DTD和Schema， 在spring2.0之前采用的是DTD，在spring2.0之后采用Schema。使用Schema方式使得spring更加便于与第三方进行集成以及…- 6
- 0
-
JFinal 中使用 Dubbo —— 3 集群
很多人认为，既然有了JFinal，为什么还要Spring。殊不知一些基于Spring的很牛X的东东集成到JFinal中能够事半功倍。比如Dubbo这个高性能优秀的服务框架，它基于Spring，于是JFinal提供的Spring插件就能更方便地将Dubbo集成进咱们的程序中，成为高大上的程序… 1. 集群 1.1. 部署结构 下面是一个简单的Cunsumer端服务器和Provider端服务器分…- 43
- 0
-
如何在springcloud分布式系统中实现分布式锁？
一、简介 一般来说，对数据进行加锁时，程序先通过acquire获取锁来对数据进行排他访问，然后对数据进行一些列的操作，最后需要释放锁。Redis 本身用 watch命令进行了加锁，这个锁是乐观锁。使用 watch命令对于频繁访问的键会引起性能的问题。 二、redis命令介绍 SETNX命令（SET if Not eXists） 当且仅当 key 不存在，将 key 的值设为 value ，并返回1…- 5
- 0
-
SpringBoot+Redis分布式锁：模拟抢单
**本篇内容主要讲解的是redis分布式锁，这个在各大厂面试几乎都是必备的，下面结合模拟抢单的场景来使用她；本篇不涉及到的redis环境搭建，快速搭建个人测试环境，这里建议使用docker；本篇内容节点如下： ** jedis的nx生成锁 如何删除锁 模拟抢单动作(10w个人开抢) jedis的nx生成锁 对于java中想操作redis，好的方式是使用jedis，首先pom中引入依赖： 1<…- 2
- 0
-
基于redis(lua)和zookeeper分布式锁(秒杀)实现,分布式接口幂等,分布式速率限制器,分布式ID生成器.
最近的项目中遇到分布式幂等问题，在本文中，我将用一个简单demo，简单阐述下使用分布式锁解决幂等问题以及分布式环境下秒杀扣库存并发问题的解决基本思路。 推荐视频链接 Java 微服务实践视频教程 - Spring Boot Java 微服务实践 视频教程- Spring Cloud redis高可用视频 分布式电商商城视频教程 kubernets+docer jvm 秒杀项目实战 Linux sh…- 24
- 0
-
Springcloud微服务项目——人力资源管理(HRM)Day02 后台服务的搭建&Swagger接口
前言： 前面我们已经搭建了一个基础模块 今天我们就来做进一步的开发 今日任务： 文章目录 HRM的仓库搭建(码云) 系统管理需求分析 涉及模块 MybatisPlus MybatisPlus与项目的集成 后台服务的搭建 后台服务集成网关 接口文档Swagger 问题 HRM的仓库搭建(码云) 在码云上搭建一个项目的一个仓库 不知道怎么操作的请参考这篇文章 IDEA中项目同步到码云 搭建好后我们需要…- 7
- 0
-
SpringCloud微服务知识整理六：声明式服务调用 Spring Cloud Feign
什么是Spring Cloud Feign Spring Cloud Feign 是基于 Netflix Feign 实现的，整合了 Spring Cloud Ribbon 和 Spring Cloud Hystrix，除了提供这两者的强大功能之外，还提供了一种声明式的 Web 服务客户端定义方式。 一、快速入门 1、创建一个 Spring Boot 基础工程，取名为 feign-consumer…- 0
- 0
-
SpringCloud微服务知识整理一：基础知识
一.什么是微服务 将一个原本独立的单体系统拆分成多个微服务，各自独立运行，通过 HTTP的RESTful API 进行通信协作，属于架构范畴的一种设计风格。 微服务优点 1.它们往往比传统的应用程序更有效地利用计算资源。这是因为它们通过扩展组件来处理功能瓶颈问题。只需要为额外的组件部署计算资源，而不需要部署一个完整的应用程序的全新迭代。最终的结果是有更多的资源可以提供给其它任务。 2.它们更快且更…- 6
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×