Technoboy
- 浏览: 153757 次
- 性别:
- 来自: 大连
-
最新评论
-
eclipseakwolf：
很棒的文章
Shiro User Manual-Authentication -
xugangqiang：
very good
Java Concurrent Programming (1) -
jlcon：
是不是AbstractShiroTest还需要继承EasyMo ...
Shiro User Manual-Testing -
jlcon：
createNiceMock这个EasyMockSupport ...
Shiro User Manual-Testing -
Technoboy：
53873039oycg 写道楼主：问下，你的那个dao接口的 ...
Shiro Example
文章列表
1. 介绍
Disconf是一套完整的基于zookeeper的分布式配置统一解决方案。它支持配置（配置项+配置文件）的分布式化管理。
2. 安装
依赖Mysql， Tomcat， Nginx， Zookeeeper， Redis。
路径配置：
将你的配置文件放到此地址目录下（以下地址可自行设定）：
/home/work/dsp/disconf-rd/online-resources
如果不确定如何配置，可以拷贝/disconf-web/profile/rd/目录下的文件，拷贝过去后，依次修改配置文件内容即可。配置文件包括：
jdbc-mysql.propert ...
1. 简介
Producer发送一条消息到broker后，如何存储到commitlog文件，又是如何构建的consumequeue，index文件，将从源码的角度剖析。
2. SendMessageProcessor
该类是负责响应Producer发消息到broker的入口处理逻辑类。其processRequest响应两种请求：
CONSUMER_SEND_MSG_BACK： consumer消费失败的消息发回broker。
default： producer发消息到broker。
由default，进入sendMessage方法，首先，我们看到对opaque的操作，表示透传 ...
1. 介绍
Consumer默认使用DefaultMQPushConsumerImpl长轮询拉消息的方式来消费，可以保证实时性同Push一样。还可以参考example项目，使用DefaultMQPullConsumerImpl，由业务控制如果拉消息，更新消费进度等方式。
2. 集群模式VS广播模式
集群模式：
消息的消费进度，即consumerOffset.json保存在broker上。
所有consumer平均消费topic的消息。
消息消费失败后，consumer会发回broker，broker根据消费失败次数设置不同的delayLevel进行重发。
相同topic不同的con ...
1.启动
producer通过配置的namesrv列表，启动时随机选择一个进行相连。首先引出，设置namesrv的几种方式，优先级依次由高到低：
第一种：代码中指定namesrv地址
producer.setNamesrvAddr(namesrvAddr);
consumer.setNamesrvAddr(namesrvAddr);
第二种：Java启动参数中指定：
-Drocketmq.namesrv.addr=192.168.0.1:9876
第三种：环境变量
NAMESRV_ADDR
第四种为http方式获取。
如果启动 ...
1. 介绍
当broker为slave且有master的情况下，通过HAService，slave从master同步commitlog数据，并通过ReputMessageService异步构建consumequeue。通过SlaveSynchronize定时每分钟从master同步config目录下的四个文件。默认，master监听broker端口+1。
2. 启动
slave可以通过配置指定master地址，也可以从namesrv获取master地址。broker启动，在BrokerController#initialize方法：
if (BrokerRole.SLAVE == ...
1. 部署方式
Broker可部署为2m-2s-async, 2m-2s-sync, 2m-noslave。推荐的部署方式为1.
2. 文件结构
abort：broker启动后会创建此空文件，当正常关闭broker后，将其删除。该文件的作用是，当broker启动后检测到该文件存在，说明上次 ...
1. 介绍
Namesrv的功能，就相当于RPC中的注册中心。对于MQ而言，broker启动，将自身创建的topic等信息注册到Namesrv上。consumer和producer需要配置namesrv的地址，启动后，首先和namesrv建立长连接，并获取相应的topic信息(比如，哪些broker有topic路由信息)，然后再和broker建立长连接。Namesrv本身无状态，可集群部署。所有的注册信息，都保存在namesrv的类似map内存数据结构中。
2. 启动
Namesrv启动后，首先会加载KVConfig服务，然后监听本地端口(默认9876),等待客户端连接，并定时 ...
1. 下载
https://github.com/alibaba/RocketMQ.git
下载后，运行install.sh或install.bat会在target目录下产生alibaba-rocketmq-broker.tar.gz（如果编译过程出现checkstyle不通过，注释掉pom文件的checkstyle plugin），然后解压复制到相应目录。
2. 启动
到MQ的bin/目录：
namesrv：nohup sh mqnamesrv >> /opt/ns.log &
broker：nohup sh mqbroker -c ../con ...
1. 介绍
索引文件指，发送一条消息后，MQ通过（topic和uniqKey）或（topic和keys）构建的索引，然后通过queryMsgByKey可以查询到结果。注意，通过queryMsgById的查询，不是索引查询。索引文件存在于/store/index/文件夹下，以时间戳命名，如20151209213520685。每个索引文件，默认存储2000w条数据，文件大小默认为420000040字节。索引文件由头信息，槽位，内容组成。
2. 组成
头信息包含6个字段，分别为：
beginTimestamp：long型，第一条消息的存储时间。
endTimestamp：long型， 最 ...
1. Overview
对于web应用，Shiro提供了认证和授权的过滤器实现。
2. Architecture
a. ServletContextSupport
提供了对ServletContext访问的支持。
b. AbstractFilter
提供了对过滤器初始化的配置。如果想在过滤器初始化时添加逻辑，可通过覆 ...
1. Overview
为了降低使用Quartz的难度，并能以Spring风格的方式使用Quartz，Spring为Quartz提供了Scheduler, Trigger, JobDetail的FactoryBean类，以及一些工具类，使Quartz能很好的注入容器，并可以结合Spring容器的生命周期，启动和关闭job。
2. JobDetailBean
使用JobDetailBean，需要设置其JobClass属性，指定实现了Job接口的实现类。JobDetailBean默认使用bean名作为job名，DEFAULT作为组名，并可以通过applicationContextJobDa ...
7 JobStore
Quartz 为所有类型的 Job 存储提供了一个接口。这个接口位于 org.quartz.spi 包中，叫做 JobStore。JobStore 用于对 Job、Trigger、Calendar、Listener和 Scheduler 状态进行存储。Quartz使用者通常不用直接访问JobStore接口的方法，它们在运 ...
1 Overview
Quartz是一个开源的作业调度框架，可被集成到任何的Java EE 或者Java SE程序中。
2 Scheduler
通过SchedulerFactory接口创建Scheduler对象。当 Scheduler 实例被创建之后，就会被保存到一个仓库中(org.quartz.impl.SchedulerRepository)。Scheduler对象可以被start、standby和shutdown。一旦Scheduler被shutdown，那么不应该重新启动它。Scheduler对象被启动后，Triggers才会被触发。在Trigger被触发时，Schedule ...
1. 说明：
maven项目，基于Spring3.1，MyBatis3.1，Shiro1.1，EHCache2.2。
项目的sql目录下的init_schema.sql文件为数据库脚本，例子中使用SQLServer。如果使用MySQL，只需将pom.xml中的MySQL依赖打开，然后修改db.properties文件，将配置改为MySQL即可。如果你不想使用数据库，将main_config.properties中的mockUserServiceFlag设置为true，应用就会使用MockUserServiceImpl类作为授权和验证的实现。对于第二个例子，添加了过滤器链，并使用EHCac ...
Apache Shiro用户手册中文版。