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

安全网络

  • Netty游戏服务器实战开发(11)：Spring+mybatis 手写分库分表策略（续）

    Netty游戏服务器实战开发(11)：Spring+mybatis 手写分库分表策略（续）

    在大型网络游戏中，传统的游戏服务器无法满足性能上的需求。所以有了分布式和微服务新起，在传统web服务器中，我们保存用户等信息基本都是利用一张单表搞定，但是在游戏服务器中，由于要求比较高，我们不能存在大表操作，即分库分表策略。在以前的文章中有关介绍分库分表的，下面我们来实战一下，首先我们做一个这样的计算。 在博主开源的游戏服务器中有这样一个场景：玩家数据保存到player表中，其中将游戏数据库分为1…
    安全网络
    • 29
    • 0
    aqztaqzt
  • Netty源码分析第6章(解码器)—->第4节: 分隔符解码器

    Netty源码分析第6章(解码器)—->第4节: 分隔符解码器

      Netty源码分析第六章: 解码器   第四节: 分隔符解码器     基于分隔符解码器DelimiterBasedFrameDecoder, 是按照指定分隔符进行解码的解码器, 通过分隔符, 可以将二进制流拆分成完整的数据包   同样继承了ByteToMessageDecoder并重写了decode方法   我们看其中的一个构造方法: 1public DelimiterBasedFrameD…
    安全网络
    • 55
    • 0
    aqztaqzt
  • Netty源码分析第3章(客户端接入流程)—->第2节: 处理接入事件之handle的创建

    Netty源码分析第3章(客户端接入流程)—->第2节: 处理接入事件之handle的创建

      Netty源码分析第三章: 客户端接入流程   第二节: 处理接入事件之handle的创建   上一小节我们剖析完成了与channel绑定的ChannelConfig初始化相关的流程, 这一小节继续剖析客户端连接事件的处理 回到上一章NioEventLoop的processSelectedKey ()方法: 1private void processSelectedKey(SelectionK…
    安全网络
    • 5
    • 0
    aqztaqzt
  • [编织消息框架][netty源码分析]7 Unsafe 实现类NioSocketChannelUnsafe职责与实现

    [编织消息框架][netty源码分析]7 Unsafe 实现类NioSocketChannelUnsafe职责与实现

    Unsafe 是channel的内部接口， 负责跟socket底层打交道。从书写跟命名上看是不公开给开发者使用的，直到最后实现NioSocketChannelUnsafe也没有公开出去 1public interface Channel extends AttributeMap, ChannelOutboundInvoker, Comparable<Channel> { 2 inter…
    安全网络
    • 7
    • 0
    aqztaqzt
  • Netty In Action中文版 – 第四章：Transports(传输)

    Netty In Action中文版 – 第四章：Transports(传输)

    Netty In Action中文版 - 第四章：Transports(传输) 本章内容 Transports(传输) NIO(non-blocking IO,New IO), OIO(Old IO,blocking IO), Local(本地), Embedded(嵌入式) Use-case(用例) APIs(接口) 网络应用程序一个很重要的工作是传输数据。传输数据的过程不一样取决是使用哪种交通…
    安全网络
    • 6
    • 0
    aqztaqzt
  • Mina、Netty、Twisted一起学（三）：TCP消息固定大小的前缀(Header)

    Mina、Netty、Twisted一起学（三）：TCP消息固定大小的前缀(Header)

    在上一篇博文中，有介绍到用换行符分割消息的方法。但是这种方法有个小问题，如果消息中本身就包含换行符，那将会将这条消息分割成两条，结果就不对了。 本文介绍另外一种消息分割方式，即上一篇博文中讲的第2条：use a fixed length header that indicates the length of the body，用一个固定字节数的Header前缀来指定Body的字节数，以此来分割消息…
    安全网络
    • 11
    • 0
    aqztaqzt
  • Java NIO框架Netty教程 (五) 字符串消息收发

    Java NIO框架Netty教程 (五) 字符串消息收发

    了解了Netty的基本概念，开发起来应该会顺手很多。  在“Hello World”代码中，我们只是在完成绑定的时候，在各自的本地打印了简单的信息，并没有客户端和服务端的消息传递。这个肯定是最基本的功能。在上代码之前，先补充一个Netty中重要的概念，ChannelBuffer.   ChannelBuffer ![](http://img.5iqiqu.com/images7/10/109542…
    安全网络
    • 7
    • 0
    aqztaqzt
  • Netty 实现 WebSocket 聊天功能

    Netty 实现 WebSocket 聊天功能

    websocket评测：http://itindex.net/detail/53887-websocket-框架-性能 不想看那么长文字的可以直接看结果： 1测试结果分析 2Netty, Node.js, Undertow, Vert.x都能正常建立百万连接。 Jetty, Grizzly 和 Spray未能完成百万连接 3Netty表现最好。内存占用非常的少， CPU使用率也不高。 尤其内存占用…
    安全网络
    • 15
    • 0
    aqztaqzt
  • Netty（ByteBuf）

    Netty（ByteBuf）

        网络数据的基本单位总是字节。Java  NIO提供了ByteBuffer作为它的字节容器，但是这个类使用起来过于复杂，而且也有些繁琐。Netty的ByteBuffer替代品是ByteBuf，一个强大的实现，既解决了JDK API的局限性，又为网络应用程序的开发者提供了更好的API。     Netty的数据处理API通过两个组件暴露——abstract class ByteBuf和inte…
    安全网络
    • 6
    • 0
    aqztaqzt
  • ASP.NET Core微服务之基于Steeltoe使用Hystrix熔断保护与监控

    ASP.NET Core微服务之基于Steeltoe使用Hystrix熔断保护与监控

    Tip: 此篇已加入.NET Core微服务基础系列文章索引 =>  Steeltoe目录快速导航： 基于Steeltoe使用Spring Cloud Eureka 基于Steeltoe使用Spring Cloud Zuul 基于Steeltoe使用Spring Cloud Hystrix 一、关于Spring Cloud Hystrix 在微服务架构中，我们将系统拆分为很多个服务，各个服务…
    安全网络
    • 0
    • 0
    aqztaqzt
  • kafka原理和实践（三）spring-kafka生产者源码

    kafka原理和实践（三）spring-kafka生产者源码

    系列目录 kafka原理和实践（一）原理：10分钟入门 kafka原理和实践（二）spring-kafka简单实践 kafka原理和实践（三）spring-kafka生产者源码 kafka原理和实践（四）spring-kafka消费者源码 kafka原理和实践（五）spring-kafka配置详解 kafka原理和实践（六）总结升华   ==============正文分割线===========…
    安全网络
    • 24
    • 0
    aqztaqzt
  • Kafka分区分配策略（2）——RoundRobinAssignor和StickyAssignor

    Kafka分区分配策略（2）——RoundRobinAssignor和StickyAssignor

    RoundRobinAssignor分配策略 RoundRobinAssignor策略的原理是将消费组内所有消费者以及消费者所订阅的所有topic的partition按照字典序排序，然后通过轮询方式逐个将分区以此分配给每个消费者。RoundRobinAssignor策略对应的partition.assignment.strategy参数值为：org.apache.kafka.clients.con…
    安全网络
    • 17
    • 0
    aqztaqzt
  • flume+kafka+storm+mysql架构设计

    flume+kafka+storm+mysql架构设计

    版本： flume-ng1.6 kafka2.10-0.8.2 storm0.9.5 大家可以看这篇文章中的架构图和数据流向图。但是安装部署请看最新版的。 另外目前主要给银行做hadoop、spark、impala、storm项目，欢迎热爱技术的朋友加好友一起探讨大数据。 序言 1前段时间学习了storm，最近刚开blog，就把这些资料放上来供大家参考。 这个框架用的组件基本都是最新稳定版本，fl…
    安全网络
    • 4
    • 0
    aqztaqzt
  • Kafka消息序列化和反序列化（上）

    Kafka消息序列化和反序列化（上）

    Kafka Producer在发送消息时必须配置的参数为：bootstrap.servers、key.serializer、value.serializer。序列化操作是在拦截器（Interceptor）执行之后并且在分配分区(partitions)之前执行的。 首先我们通过一段示例代码来看下普通情况下Kafka Producer如何编写： 1public class ProducerJavaDe…
    安全网络
    • 8
    • 0
    aqztaqzt
  • Java使用RabbitMQ（六）–订阅发布

    Java使用RabbitMQ（六）–订阅发布

    发布订阅模式 这一篇主要是java 客户端使用rabbitMQ发布和订阅消息。 前面几篇讲的是将一个消息只发给一个worker，这里讲的是将一个消息同时发给多个订阅者，也就是发布/订阅模式。 为了阐明这种模式，这里将创建一个简单的日志系统，这个系统由2部分组成：第一部分，发送日志消息；第二部分接收和打印日志消息。 在这个日志系统中，复制了一份receiver，一个接收者用来把收到的消息存储到硬盘中…
    安全网络
    • 12
    • 0
    aqztaqzt
  • Docker 之 部署RabbitMQ集群并实现Haproxy代理(一)

    Docker 之 部署RabbitMQ集群并实现Haproxy代理(一)

    前言 本小节我们学习一下使用Docker部署RabbitMQ集群。 RabbitMQ Docker Hub 目录参考 1[root@iZ2ze8sm5upgi8z1dcazqeZ rabbitmq]# pwd 2/workspace/rabbitmq 3[root@iZ2ze8sm5upgi8z1dcazqeZ rabbitmq]# tree 4. 5├── config 6│ └── docke…
    安全网络
    • 13
    • 0
    aqztaqzt
  • 使用Docker-Compose搭建Rabbitmq集群

    使用Docker-Compose搭建Rabbitmq集群

    1.使用镜像搭建集群，docker-compose.xml配置见下面的github具体配置 https://github.com/bijukunjummen/docker-rabbitmq-cluster 具体变更如下： 说完端口，下面提供一个三节点的docker-compose文件。 rabbit1（10.106.136.7） 1rabbit1: 2 image: bijukunjummen/r…
    安全网络
    • 15
    • 0
    aqztaqzt
  • RabbitMQ开机自启动脚本

    RabbitMQ开机自启动脚本

    在/etc/init.d 目录下新建一个 rabbitmq-server 文件， 复制上面的内容 添加到 rabbitmq-server 文件里。 适当修改 红色部分 DAEMON= /home/software/rabbitmq/sbin/${NAME} CONTROL= /home/software/rabbitmq/sbin/rabbitmqctl DESC=rabbitmq-server …
    安全网络
    • 12
    • 0
    aqztaqzt
  • net core 使用 rabbitmq

    net core 使用 rabbitmq

    目录(?)[+] 安装 基本用法 RabbitMQ消费失败的处理 使用RabbitMQ的Exchange Direct Exchange Fanout Exchange Topic Exchange 问题： None of the specified endpoints were reachable   windows环境安装： https://www.daimajiaoliu.com/serie…
    安全网络
    • 40
    • 0
    aqztaqzt
  • Celery 分布式任务队列快速入门

    Celery 分布式任务队列快速入门

    本节内容 Celery介绍和基本使用 在项目中如何使用celery 启用多个workers Celery 定时任务 与django结合 通过django配置celery periodic task     一、Celery介绍和基本使用  Celery 是一个 基于python开发的分布式异步消息任务队列，通过它可以轻松的实现任务的异步处理， 如果你的业务场景中需要用到异步任务，就可以考虑使用ce…
    安全网络
    • 18
    • 0
    aqztaqzt
  • SpringBoot整合RabbitMq

    SpringBoot整合RabbitMq

    SpringBoot整合RabbitMq 1.介绍 1.1 RabbitMQ MQ全称为Message Queue，即消息队列， RabbitMQ是由erlang语言开发，基于AMQP（Advanced Message Queue 高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开 发中应用非常广泛。RabbitMQ官方地址：http://www.rabb…
    安全网络
    • 14
    • 0
    aqztaqzt
  • 分布式与集群

    分布式与集群

    1、图解分布式与集群 2、集群是个物理形态，分布式是个工作方式。 分布式： 不同的业务模块部署在不同的服务器上或者同一个业务模块分拆多个子业务，部署在不同的服务器上，解决高并发的问题。 集群： 同一个业务部署在多台机器上，提高系统可用性。 **负载均衡：**将一套系统拆分成不同子系统部署在不同服务器上（这叫分布式），然后部署多个相同的子系统在不同的服务器上（这叫集群），部署在不同服务器上的同一个子…
    安全网络
    • 11
    • 0
    aqztaqzt
  • 10. Dubbo原理解析-Listener & filter

    10. Dubbo原理解析-Listener & filter

    Listener ExporterListener: dubbo在服务暴露(exporter)以及销毁暴露(unexporter)服务的过程中提供了回调窗口，供用户做业务处理。ProtocolListenerWrapper在暴露过程中构建了监听器链 public class ProtocolListenerWrapper implements Protocol {    public <T&…
    安全网络
    • 23
    • 0
    aqztaqzt
  • 26. Dubbo原理解析-监控

    26. Dubbo原理解析-监控

    Dubbo发布代码中，自带了一个简易的监控中心实现。对于一般的小业务这个监控中心应该能够满足需求，对于那些大业务量的大公司一般都会有自己的监控中心，更加丰富的功能如常用的报警短信通知等等。这章讲解分析使得读者能够了解一般的监控中心实现，也使得有自己接入监控中心需求的大概知道如何集成自己的监控中心实现。下面我们就以dubbo自带的监控中心开始讲解。   监控中心 1.  监控中心启动，我们先看下du…
    安全网络
    • 17
    • 0
    aqztaqzt
❯

解锁会员权限

开通会员

解锁海量优质VIP资源

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

  • 扫码打开当前页

返回顶部