universal-chain

public class BizService implements Invoker {
	private IIdempotentDao idempotentDao;
	public String doBiz(String param) {
		InvokerContext context = InvokerContext.create().apendArg(param);
		context.putExtendContext(LockContext.create().appendLock(LockHolder.create("wzy", null)));
		String rlt = (String) InvokerBuilder
				.buildInvoker(this, context, FilterFactory.createLockFilter())
				.delegateInvokeInvoker();
		System.out.println("==>执行结果：" + rlt);
		return rlt;
	}
	@Override
	public Object invoke(InvokerContext lockContext) {
		String param = (String) lockContext.getArgs().get(0);
		System.out.println("---> 执行业务:param=" + param);
		return "OK";
	}
}

public void doBizNew2(final String param) {
	IdempotentStep step1 = new IdempotentStep(IdempotentHolder.create("幂等key-new", "业务1", "step1")) {
		@Override
		public Object invoke(InvokerContext invokerContext) {
			String step1rlt = step1(param);
			return step1rlt;
		}
	};
	IdempotentStep step2 = new IdempotentStep(IdempotentHolder.create("幂等key-new", "业务1", "step2")) {
		@Override
		public Object invoke(InvokerContext invokerContext) {
			return step2(param, invokerContext);
		}
	};
	IdempotentStep step3 = new IdempotentStep(IdempotentHolder.create("幂等key-new", "业务1", "step3")) {
		@Override
		public Object invoke(InvokerContext invokerContext) {
			return step3(param);
		}
	};
	// 1. 不用锁的写法
	StepsContainer.create(idempotentDao).addStep(step1).addStep(step2).addStep(step3).executeAll(InvokerContext.create());
	// 2. 用锁的写法
	// InvokerContext context = InvokerContext.create();
	// context.putExtendContext(LockContext.create().appendLock(LockHolder.create("wzy")));
	// StepsWithinLockContainer.create(idempotentDao).addStep(step1).addStep(step2).addStep(step3).executeAll(context);
}