本地持久化消息队列FQueue

2017-10-24 16:22:01 java框架java架构

在Java开发中,我们在处理消息推送系统时经常会遇到,数据推送方和数据接收方处理速度不一致的问题。我们一般的解决方案是声明一个blockqueue来缓存要处理的数据,解决问题。 但这样有几个缺点,一是当队列中缓存较多数据时,我们重新发布项目队列中的数据就会丢失。二是数据过多占用大量内存导致系统崩溃;  FQueue是一个高性能、基于磁盘持久存储的队列消
Java框架-Java学习-Java技术

zkClient Zookeeper java 客户端使用

2016-09-16 12:16:42 java框架java架构

一、为什么要使用zkClient?首先我们来看看ZooKeeper API的介绍。ZooKeeper实现了一个层次命名空间的数据模型,可以认为它是一个小型的、精简的文件系统。它的每个节点称为znode,znode除了本身能够包含一部分数据之外,还能够拥有子节点,当节点上的数据发生变化,或者其子节点发生变化时,基于watcher机制,会发出相应的通知给订阅其状
Java框架-Java学习-Java技术

kafka java客户端实例

2016-08-24 22:49:51 java框架

一、基本概念BrokerKafka集群中的一个服务器就称为一个brokerTopic发送到Kafka集群的消息类别(或称为消息主题),这个类别被称为Topic。(物理上不同Topic的消息分开存储,逻辑相同Topic的消息虽然保存于一个或多个broker上但用户只需指定消息的Topic即可生产或消费数据而不必关心数据存于何处)PartitionPartiti
Java框架-Java学习-Java技术

Paho eclipse mqtt java客服端

2016-08-07 22:17:00 java框架java工具

Paho Java 客服端提供了两个API:MqttAsynClient提供了一个完整的异步API,它通过注册回调函数实现工作。MqttClient封装在MqttAsynClient基础上,实现了同步的方法。Paho支持的功能有:MQTT 3.1、MQTT 3.1.1 LWT SSL / TLS Message Persistence Automatic
Java框架-Java学习-Java技术

spring session实现分布式session

2016-07-26 23:43:55 java框架java架构

spring session实现了分布式回话管理,你只需要在项目中引入相应的jar包,通过简单的配置就可以实现集群部署功能。1、在pom.xml中引入jar包<dependency> <groupId>org.springframework.session</groupId> <artifactId>spring-session-data-red
Java框架-Java学习-Java技术

mina 服务端客户端入门实例

2016-06-24 10:23:00 java框架

1. 简单的 TCPServer :(1.) 第一步 :编写IoService按照前面介绍的执行流程,我们首先需要编写 IoService,IoService 本身既是服务端,又是客户端,我们这里编写服务端,所以使用 IoAcceptor实现,由于 IoAcceptor 是与协议无关的,因为我们要编写 TCPServer,所以我们使用 IoAccepto
Java框架-Java学习-Java技术

Apache Mina Server简介

2016-06-24 08:19:05 java框架

Apache Mina Server 是什么?它一个网络通信应用框架,主要是对基于 TCP/IP、UDP/IP协议栈的通信框架,也可以提供JAVA 对象的序列化服务、虚拟机管道通信服务等,Mina 可以帮助我们快速开发高性能、高扩展性的网络通信应用,Mina 提供了事件驱动、异步(Mina 的异步 IO 默认使用的是JAVA NIO作为底层支持)操作的编程模
Java框架-Java学习-Java技术

google protobuf windows下安装及测试实例

2016-06-09 12:17:36 java框架

protobuf是google提供的一个开源序列化框架,它在google中是一个比较核心的基础库,作为分布式运算涉及到大量的不同业务消息的传递,如何高效简洁的表示、操作这些业务消息在google这样的大规模应用中是至关重要的。而protobuf这样的库正好是在效率、数据大小、易用性之间取得了很好的平衡。protobuf类似于XML,JSON这样的数据表示语言
Java框架-Java学习-Java技术

RocketMQ概况入门实例

2016-06-07 12:37:03 java框架

RocketMQ 是一款分布式、队列模型的消息中间件,具有以下特点:专业&验证1、MQ是消息领域业内专业的消息中间件,多次在国内外获奖2、经过双11阿里交易、商品、营销等核心链路真实场景验证3、阿里集团内部1000+核心应用使用,每天流转几千亿条消息,稳定可靠技术体系1、产品历史超过7年,消息保证不丢,技术体系丰富成熟2、阿里内部产品名:MetaQ...
Java框架-Java学习-Java技术

spring mvc 参数传递过程参数绑定参数封装

2016-02-02 23:43:32 java框架

spring mvc 参数传递 spring mvc基本数据类型传递 如:int指定默认等1,因为当前端没有page参数时候,int又不能为空,所有必须指定默认值,不然会报错包装类型传递 如:Integer但请求没有带page参数是,page为null,此处会报错自定义对象类型spring mvc绑定list,map对象 这两个对象都不能直接写在controller 函数的参数中,需要作为其他对象的属性使用
Java框架-Java学习-Java技术
10条数据 共1页
转到跳转