wuyuhou
- 浏览: 13906 次
- 性别:
- 来自: 上海
-
最新评论
-
wuyuhou：
yuanyu5237 写道楼主您好，请教一下，代码中的IQue ...
简单的SEDA框架实现 -
yuanyu5237：
isStarted这个方法真没有了
持久化Queue -
yuanyu5237：
找到了，呵呵，多谢楼主，这恐怕是我在网上找到的唯一一个比较简单 ...
简单的SEDA框架实现 -
yuanyu5237：
楼主您好，请教一下，代码中的IQueue在哪儿？
简单的SEDA框架实现
文章列表
这个空间，开了很久了，一直没使用，最近突然想到了它的定位，以后就是代码空间吧。自己毕竟是一个程序员，而且还想把这个事长久做下去，因为能得到快感。。。。。除了本篇外，其余所有博客都由代码组成。
编程序是一种境界，是一种乐趣。。。。。
子非鱼焉知鱼之乐。。。。
乐在其中就行了。。。。
JDK6中的源代码编译功能，网上给的示例一般都无法运行，会抛出ClassNotFoundException。
经过改良，主要原因是字节码输出的文件不对。现修改为输出到内存中。
/**
* 字符串变为Class
*
* @author wuyuhou
*
*/
public class StringToClass {
public static void main(String[] args) throws Exception {
Class clazz = loadClass("com.test.CalculatorTest", ...
/**
* 固定长度格式化器
*
* @author wuyuhou
*
*/
public class FixedLengthFormatter {
//对齐方式
public static enum Alignment {
LEFT,//左对齐
MIDDLE,//居中
RIGHT//右对齐
}
//对齐方式，默认左对齐
private Alignment alignment = Alignment.LEFT;
//长度
private int fixedLength = 0;
//填充符号 ...
/**
* 段容器接口定义
*
* @author wuyuhou
*
*/
public interface IStagedContainer {
//取得标识
String getId();
//发送事件
void sendEvent(IEvent e);
// 启动
void start();
// 停止
void stop();
}
/**
* 事件接口
*
* @author yourname (mailto:yourname@primeton.com)
*/
public in ...
/**
* 日志记录器接口
*
* @author yourname (mailto:yourname@primeton.com)
*/
public interface ILogger {
boolean isDebugEnabled();
boolean isInfoEnabled();
boolean isWarnEnabled();
boolean isErrorEnabled();
void debug(Object message);
void debug(Object message, Object[] pa ...
/**
* 队列接口
*
* @author yourname (mailto:yourname@primeton.com)
*/
public interface IQueue<E> {
//入队
void offer(E o);
//出队
E poll();
// 启动
void start();
// 停止
void stop();
}
/**
* 持久化队列
*
* @author yourname (mailto:yourname@primeton.com)
*/
p ...
/**
* 数据序列化接口
*
* @author Administrator
*
*/
public interface IDataMarshaller {
/**
* 序列化
*
* @param data 数据对象，不可以为空
* @param out 序列化目标，不可以为空
* @param additional 额外附属信息，如果没有用，可以为空
*/
void marshal(Object data, OutputStream out, Object additional) throws Exception ...
public class JsonTool {
/**
* json字符串的格式化，友好格式
*
* @param json json串
* @param fillStringUnit 填充字符，比如四个空格
* @return
*/
public static String formatJson(String json, String fillStringUnit) {
if (json == null || json.trim().length() == 0) {
return null;
}
int ...