- 浏览: 234673 次
- 性别:
- 来自: 广州
-
最新评论
-
tonyyan:
谢谢分享!
Kafka 监控 -
dtyu100:
反手就是一个赞,这相当于是官网druid.io的中文版本,很厉 ...
Druid 大数据分析之快速应用(单机模式) -
sqy:
2018-04-12T01:30:27,527 ERROR [ ...
Druid 大数据分析之快速应用(单机模式) -
wangyudong:
学习了,不错的Spring boot实例,参考着很快写出了RE ...
Spring boot 入门实例 -
string2020:
servlet4规范出来了,求翻译
Java Servlet3.1规范
文章列表
1、为什么需要生成服务端?
很多人都用过Web Service 比较常用的是Axis,Cxf,平时开发服务器端都是从Java-->服务端;经常与其它应用做接口对接,根据业务接口文档及Wsdl开发相应客户端,从Wsdl生成相应客户端代码方式很多, ...
Redis on Windows
This is a port for Windows based on Redis.
We officially support the 64-bit version only. Although you can build the 32-bit version from source if desired.
You can download the latest unsigned binaries and the unsigned MSI installer from the release page.
For releases prior t ...
GreenPlum存储模式
写道
GreenPlum 数据库创建表时提供了一组关于存储的参数,这一点非常重要。什么时候使用堆(Heap)存储与AO(Append-optimized)存储,什么时候使用基于行式存储与列式存储。正确选择堆与AO和行与列对于大表来说非常重要。
CREATE TABLE
写道
Defines a new table. Note: Referential integrity syntax (foreign key constraints) is accepted but not enforced. Synopsis
...
Storm 能够保证每一个由 Spout 发送的消息都能够得到完整地处理。本文详细解释了 Storm 如何实现这种
保障机制,以及作为用户如何使用好 Storm 的可靠性机制。
消息的“完整性处理”是什么意思
一个从 spout 中发送出的 tuple 会产生上千个基于它创建的 tuples。例如,有这样一个 word-count 拓扑:
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("sentences", new KestrelSpout("kes ...
一、Storm大数据位置
解决方案
开发商
类型
描述
Greenplum数据库基本由PostgreSQL核心增强数据库实例组合并衔接成的数据库管理系统,即Greenplum
数据在PostgreSQL基础上扩展开发出来的。
每个Greenplum数据库由1个master实例和2个或2个以上segment实例组成,客户端使用PostgreSQL规范
与Master交互。接下来的插图,展示Greenplum数据库实例由1个master和6 segement实例组成:
上述插图中Master Host部署在专用服务器上,1台Host就是1台计算机(物理机或虚拟机)-包括操作系统、
...
一、sql_trace(SQL跟踪)
查看文件位置:show parameter user_dump_dest
设置:alter session set sql_trace=true;
查询结果:tkprof E:\ORACLE\PRODUCT\10.2.0\ADMIN\JJONE\UDUMP\jjone_ora_3600.trc sql1.txt
二、SQL Explain(SQL执行计划)
1)@?\rdbms\admin\utlxplan
2)set autotrace on/ set timing on/ set auto ...
引用
提供不同数据源和方言实现智能分页,因Spring单例模式,可以利用Cglib实现动态数据源切换方案,基础东西不讲了,直接看代码。
引用
持久超接口,获取操作模板,可以是JdbcTemplate、SqlSessionTemplate等
package com.sunshine.basic.dao;
public interface SuperDao<T> {
/**
* 获取操作模板
* @return
*/
T getTemplate();
}
引用
查询+分页操作接口
package com.suns ...
STORM喷头数据读取方式
- 博客分类:
- STORM
STORM数据喷头常用读取数据方式:
1) 自定义对队,其它应用程序将数据写入队列,则STORM读取队列进行实时处理
2) 引用KAFKA,STORM喷头从KAFKA读取数据
1.引言
1.1 名词解释
Zookeeper:解决分布式应用中经常遇到的一些数据管理问题,如:统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等。
ZeroMQ:Storm0.9.0之前的版本中需要安装ZeroMQ,实现Strom Worker之间的通信;Storm0.9.0版本之后采用Netty替代ZeroMQ使Strom部署分布式环境更方便。
Netty
引用
本节采用JDK1.5之后java.util.concurrent包的API服务端实现线程池读取信息,可以接采用Executors工具快速创建线程池,也可以ExecutorService子类自定义创建。
客端连接服务端发送信息后关闭连接SOCKET短连接(HTTP为短连接),若采用SOCKET长连接,需要增加"心跳检测",本节暂未实现长连接。
因Selector轮询可读事件时,存在重读问题,解决办法是在读的代码块中加下述代码selectKey.cancel()或selectKey.interestOps(selectKey.interestOps() &a ...
引用
继上节利用JAVA NIO实现简单数据传,本节实现自定义对象传输,为了实现接收方构建完整对象,自定义对象实现Serializable接口,以便完成对象序列化与反序化。
下一节我们将采用线程池来管理读写,期待...
import java.io.Serializable;
/**
* 传输对象,利用ObjectOutputStream、ObjectInputStream
* 传输,所以对象需要可序列化
* @author oy
*
*/
public class User implements Serializable{
private sta ...
传统IO 写道
网络传输方式问题:传统的RPC框架或者基于RMI等方式的远程服务(过程)调用采用了同步阻塞IO,当客户端的并发压力或者网络时延增大之后,同步阻塞IO会由于频繁的wait导致IO线程经常性的阻塞,由于线程无法高 ...
引用
JAVA 获取网络图片或本地图片压缩后打成ZIP,但是获取网络流存在问题:每次获取图片流的大小不一样(图片不完整),以致无法构建图片进行压缩?
/*
注释以下代码:即可获取完整图片流网络不稳定情况且网络流是顺序读取,所以获得前部份流,不需要关闭连接,只需要将用完的流关闭即可
*/
finally{
if(httpCon != null)
httpCon.disconnect();
}
package com.sunshine.monitor.comm.util.http;
import java.io.File;
imp ...
引用
JAXB 2.0 API is being loaded from the bootstrap classloader解决方法:
http://docs.oracle.com/javase/1.5.0/docs/guide/standards/