文章
文章用户文档快讯圈子网址导航
全部标签

安全网络

  • Netty In Action中文版 – 第十五章：选择正确的线程模型

    Netty In Action中文版 – 第十五章：选择正确的线程模型

    Netty In Action中文版 - 第十五章：选择正确的线程模型 本章介绍 线程模型(thread-model) 事件循环(EventLoop) 并发(Concurrency) 任务执行(task execution) 任务调度(task scheduling) 线程模型定义了应用程序或框架如何执行你的代码，选择应用程序/框架的正确的线程模型是很重要的。Netty提供了一个简单强大的线程模型…
    安全网络
    • 9
    • 0
    aqztaqzt
  • [编织消息框架][netty源码分析]3 EventLoop 实现类SingleThreadEventLoop职责与实现

    [编织消息框架][netty源码分析]3 EventLoop 实现类SingleThreadEventLoop职责与实现

    eventLoop是基于事件系统机制，主要技术由线程池同队列组成，是由生产/消费者模型设计，那么先搞清楚谁是生产者，消费者内容 SingleThreadEventLoop 实现 1public abstract class SingleThreadEventLoop extends SingleThreadEventExecutor implements EventLoop { 2 private…
    安全网络
    • 2
    • 0
    aqztaqzt
  • 100万并发连接服务器笔记之Java Netty处理1M连接会怎么样

    100万并发连接服务器笔记之Java Netty处理1M连接会怎么样

    五 100万并发连接服务器笔记之Java Netty处理1M连接会怎么样 2014年05月21日 14:13:56 mergerly 阅读数：20545 前言 每一种该语言在某些极限情况下的表现一般都不太一样，那么我常用的Java语言，在达到100万个并发连接情况下，会怎么样呢，有些好奇，更有些期盼。 这次使用经常使用的顺手的netty NIO框架（netty-3.6.5.Final），封装的很好…
    安全网络
    • 3
    • 0
    aqztaqzt
  • Netty心跳检测

    Netty心跳检测

    IdleStateHandler Netty中的心跳检测机制，根据这个处理器能及时的检测到读/写/读写空闲状态，根据状态进行相应的处理。 1Triggers an {@link IdleStateEvent} when a {@link Channel} has not performed 2read, write, or both operation for a while. 3 4 当没有执行…
    安全网络
    • 7
    • 0
    aqztaqzt
  • Java NIO框架Netty教程(五)-Netty中OIO模型(对比NIO)

    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…
    安全网络
    • 10
    • 0
    aqztaqzt
  • Netty实现Http服务器

    Netty实现Http服务器

                                                       Netty实现Http服务器         Netty是一个异步事件驱动的网络应用程序框架用于快速开发和可维护的高性能协议服务器和客户端。Netty经过精心设计，具有丰富的协议，如FTP，SMTP，HTTP以及各种二进制和基于文本的传统协议。        Java程序员在开发web应用的时候，…
    安全网络
    • 10
    • 0
    aqztaqzt
  • 基于Dubbo框架构建分布式服务

    基于Dubbo框架构建分布式服务

    Dubbo是Alibaba开源的分布式服务框架，我们可以非常容易地通过Dubbo来构建分布式服务，并根据自己实际业务应用场景来选择合适的集群容错模式，这个对于很多应用都是迫切希望的，只需要通过简单的配置就能够实现分布式服务调用，也就是说服务提供方（Provider）发布的服务可以天然就是集群服务，比如，在实时性要求很高的应用场景下，可能希望来自消费方（Consumer）的调用响应时间最短，只需要选…
    安全网络
    • 9
    • 0
    aqztaqzt
  • kafka原理系列之（二）partition的消费策略

    kafka原理系列之（二）partition的消费策略

    1、topic和partition以及consumer关系 一个topic可以认为一个一类消息，每个topic将被分成多个partition，每个partition在存储层面是append log文件。任何发布到此partition的消息都会被追加到log文件的尾部，每条消息在文件中的位置称为offset(偏移量)，offset为一个long型的数字，它唯一标记一条消息。每条消息都被append到…
    安全网络
    • 24
    • 0
    aqztaqzt
  • Kafka、RabbitMQ、RocketMQ等 消息中间件 介绍和对比

    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、测试结论…
    安全网络
    • 26
    • 0
    aqztaqzt
  • 如何管理Spark Streaming消费Kafka的偏移量（三）

    如何管理Spark Streaming消费Kafka的偏移量（三）

    前面的文章已经介绍了在spark streaming集成kafka时，如何处理其偏移量的问题，由于spark streaming自带的checkpoint弊端非常明显，所以一些对数据一致性要求比较高的项目里面，不建议采用其自带的checkpoint来做故障恢复。 在spark streaming1.3之后的版本支持direct kafka stream，这种策略更加完善，放弃了原来使用Kafka的…
    安全网络
    • 8
    • 0
    aqztaqzt
  • Elasticsearch 与 Kafka 整合剖析

    Elasticsearch 与 Kafka 整合剖析

    1.概述 目前，随着大数据的浪潮，Kafka 被越来越多的企业所认可，如今的Kafka已发展到0.10.x，其优秀的特性也带给我们解决实际业务的方案。对于数据分流来说，既可以分流到离线存储平台（HDFS），离线计算平台（Hive仓库），也可以分流实时流水计算（Storm，Spark）等，同样也可以分流到海量数据查询（HBase），或是及时查询（ElasticSearch）。而今天笔者给大家分享的就…
    安全网络
    • 6
    • 0
    aqztaqzt
  • 虚函数与动态绑定的那点事

    虚函数与动态绑定的那点事

    面向对象编程的概念 1）多态：简单理解就是多种形态，通过继承而相关联的类型，特别在运行的情况下，对象可能是基类也可能派生类类型 1）继承：能够对类型之间的关系建模，共享公共的东西，仅仅特化本质上不同的东西。 定义为virtual的函数是基类期待派生类重新定义的，基类不希望派生类继承的则定义为非虚函数，这样类就有虚函数与非虚函数之分 2）动态绑定：使程序使用继承层次中任意类型的对象，无需关心具体的类…
    安全网络
    • 8
    • 0
    aqztaqzt
  • Docker下RabbitMQ四部曲之四：高可用实战

    Docker下RabbitMQ四部曲之四：高可用实战

    本章是《Docker下RabbitMQ四部曲》系列的终篇，今天的我们一起来体验Rabbit’MQ集群的高可用能力，看看RabbitMQ集群中的部分节点宕机时，是否还能生产和消费消息； 实战概要 今天实战的步骤如下： 制作docker-compose.yml文件，为每个容器配置好参数； 启动所有容器，包括RabbitMQ集群、消息生产者的web应用、消息消费者的web应用； 逐个停止集群中的Rabb…
    安全网络
    • 13
    • 0
    aqztaqzt
  • .Net下RabbitMQ的使用(8) — 远程过程调用RPC

    .Net下RabbitMQ的使用(8) — 远程过程调用RPC

    RPC是在计算中是一种常见的模式，是通常我要用消息队列来实现RPC有3个关键点： 服务的寻址 消息的接收 消息的关联   在RabbitMQ的.net客户端里，提供了2个类：SimpleRpcClient 和 SimpleRpcServer 来让我们方便的开发RPC应用。 因为RabbitMQ的RPC一定是基于队列的，所以在客户端和服务端都需要要一个各自的队列，客户端的队列用来接收服务回复的数据，…
    安全网络
    • 9
    • 0
    aqztaqzt
  • .Net下RabbitMQ的使用(3) — 竞争的消费者

    .Net下RabbitMQ的使用(3) — 竞争的消费者

    在上一篇文章中，演示了一个发送者和一个消费者的情况。这一篇介绍一下多个消费者在同一个消息队列中获取消息的情况。   在有些应用当中，消费端接收到消息任务需要长时间的处理，如果等上一个消息处理完成以后再取下一个数据进行处理的话，势必会有一些延迟。在消息队列中的数据也会不断增多，延迟将越来越大。当然对于一个消费进程来说，在某些情况下可以起多个线程来处理，而在这里将介绍另一种处理方式，多个消费进程的情况…
    安全网络
    • 13
    • 0
    aqztaqzt
  • RabbitMQ消息队列（五）：Routing 消息路由

    RabbitMQ消息队列（五）：Routing 消息路由

    上篇文章中，我们构建了一个简单的日志系统。接下来，我们将丰富它：能够使用不同的severity来监听不同等级的log。比如我们希望只有error的log才保存到磁盘上。 1. Bindings绑定 上篇文章中我们是这么做的绑定： 1channel.queue_bind(exchange=exchange_name, 2 queue=queue_name) 3 绑定其实就是关联了exchange和q…
    安全网络
    • 9
    • 0
    aqztaqzt
  • 分布式ID生成方法

    分布式ID生成方法

    分布式ID生成方法     需求分析       几乎所有的业务系统，都有生成一个记录标识的需求，例如：   消息标识：message-id 订单标识：order-id 帖子标识：tiezi-id     这个记录标识往往就是数据库中的唯一主键，数据库上会建立聚集索引（cluster index）     聚集索引：物理存储上以这个字段排序。 非聚集索引：普通索引，存储的是实际记录的指针，其访问效…
    安全网络
    • 5
    • 0
    aqztaqzt
  • 分布式一致性

    分布式一致性

    简述 这里的Consistency（一致性）是指分布式系统中的数据一致性，而非数据库事务ACID特性中的Consistency。 CAP CAP（或称布鲁尔定理）指出一个分布式计算系统不可能同时满足以下三点： 一致性（Consistency）：多个数据副本是否能够保持一致； 可用性（Availability）：每次请求都能获取非错的响应，但无法保证获取的数据是否最新； 分区容忍性（Partitio…
    安全网络
    • 10
    • 0
    aqztaqzt
  • Ubuntu安装rabbitMq

    Ubuntu安装rabbitMq

      Ubuntu安装rabbitMq   笔者ubuntu版本为Ubuntu 15.10，查看ubuntu当前版本命令：cat /etc/issue。 由于rabbitMq需要erlang语言的支持，在安装rabbitMq之前需要安装erlang，执行命令： 1sudo apt-get install erlang-nox 2     安装后检查是否安装成功 1erl 2 3   安装rabbit…
    安全网络
    • 5
    • 0
    aqztaqzt
  • 22. Dubbo原理解析-编码解码之Serialization接口定义

    22. Dubbo原理解析-编码解码之Serialization接口定义

    序列化：dubbo提供了一系列的序列化反序列化对象工具。 Serialization接口定义 @SPI( "hessian2") public interface Serialization {     byte getContentTypeId();     String getContentType();     @Adaptive     ObjectOutput ser…
    安全网络
    • 37
    • 0
    aqztaqzt
  • SpringBoot+zk+dubbo架构实践（二）：SpringBoot 集成 zookeeper

    SpringBoot+zk+dubbo架构实践（二）：SpringBoot 集成 zookeeper

    上一篇：SpringBoot+zk+dubbo架构实践（一）：本地部署zookeeper 前言 1这是第二篇了，本篇我们完成两件事情。 21、搭建SpringBoot 框架； 32、基于spring boot框架访问zookeeper。 4 搭建SpringBoot框架 其实之前“IT实战联盟”已经出了该系列文章，今天我们简单搭建一下（详细的步骤可以参考架构实战篇（一）-Spring Boot+M…
    安全网络
    • 6
    • 0
    aqztaqzt
  • 初识Dubbo 系列之1-Dubbo是什么

    初识Dubbo 系列之1-Dubbo是什么

              Dubbo是阿里巴巴内部的SOA服务化治理方案的核心框架，每天为2000+ 个服务提供3,000,000,000+ 次访问量支持，并被广泛应用于阿里巴巴集团的各成员站点。Dubbo自2011年开源后，已被许多非阿里系公司使用。 Dubbo[ ]是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。 其核心部分包含: 远程通讯: 提供对多…
    安全网络
    • 59
    • 0
    aqztaqzt
  • 定时任务在集群部署的下防重复调度问题, redis 分布式锁

    定时任务在集群部署的下防重复调度问题, redis 分布式锁

    业务场景: 程序中有个一分钟执行一次的策略遍历与判断的任务,为了防止多台机器重复执行,需要设置分布式锁 查询资料,这个技术方案比较成熟 1.使用数据库 2.使用redis 3.使用zk 下面介绍下单机redis的使用分布式锁的思路,整体思路较为完善,其他资料较残缺 注意点: 1.设置随机value值 ,防止A释放锁出现释放了其他客户端B在使用的锁的问题 2.设置失效时间 ,防止死锁 3.Redis…
    安全网络
    • 19
    • 0
    aqztaqzt
  • SpringBoot基于数据库实现简单的分布式锁

    SpringBoot基于数据库实现简单的分布式锁

    本文介绍SpringBoot基于数据库实现简单的分布式锁。 1.简介 分布式锁的方式有很多种，通常方案有： 基于mysql数据库 基于redis 基于ZooKeeper 网上的实现方式有很多，本文主要介绍的是如果使用mysql实现简单的分布式锁，加锁流程如下图： 其实大致思想如下： 1.根据一个值来获取锁（也就是我这里的tag），如果当前不存在锁，那么在数据库插入一条记录，然后进行处理业务，当结束…
    安全网络
    • 28
    • 0
    aqztaqzt
❯

解锁会员权限

开通会员

解锁海量优质VIP资源

立刻开通
个人中心
购物车
优惠劵
今日签到
有新私信 私信列表
搜索

  • 扫码打开当前页

返回顶部