service-support

complex service support

模块说明

名称	描述
service-support-code	业务支持
service-support-example	业务支持示例

复杂业务支持

使用

  //implements Handler
 @Service
 public class TokenCheckHandler implements IHandler {
 
 
     private final static Logger LOGGER = LoggerFactory.getLogger(TokenCheckHandler.class);
 
     @Override
     public void execute() {
         LOGGER.info("TokenCheckHandler-execute");
     }
 }

  //implements Handler
 @Service
 public class RequestCheckHandler implements IHandler {
 
     private final static Logger LOGGER = LoggerFactory.getLogger(RequestCheckHandler.class);
 
     @Override
     public void execute() {
         LOGGER.info("RequestCheckHandler-execute");
 
     }
 }

  //implements Handler
 @Service
 public class OrderQueryHandler implements IHandler {
 
 
     private final static Logger LOGGER = LoggerFactory.getLogger(OrderQueryHandler.class);
 
     @Override
     public void execute() {
         LOGGER.info("OrderQueryHandler-execute");
     }
 }

 //register Processor extends BaseProcessor
 
@Service
public class RequestCheckProcessor extends BaseProcessor {

    //register handler chain
    public RequestCheckProcessor(OrderQueryProcessor orderQueryProcessor,
    TokenCheckHandler tokenCheckHandler, RequestCheckHandler requestCheckHandler) {
        this.setProcessor(this);
        //set next processor （successor processor）
        this.setSuccessor(orderQueryProcessor);
        this.append(tokenCheckHandler);
        this.append(requestCheckHandler);
    }

    @Override
    public void configurate() {

    }

    //Override process method parallel or serial execute
    @Override
    public void process() {
        Iterator iterator = this.iterator();
        while (iterator.hasNext()) {
            IHandler handler = (IHandler) iterator.next();
            if (handler.executeFlag()) {
                handler.execute();
            }
        }
        this.processSuccessor();
    }
}

 //register Processor extends BaseProcessor
 
@Service
public class OrderQueryProcessor extends BaseProcessor {

    //register handler chain
    public OrderQueryProcessor(OrderQueryHandler orderQueryHandler) {
            this.setProcessor(this);
            //set next processor （successor processor）
            this.setSuccessor(null);
            this.append(orderQueryHandler);
    }

    @Override
    public void configurate() {

    }

    //Override process method parallel or serial execute
    @Override
    public void process() {
        Iterator iterator = this.iterator();
        while (iterator.hasNext()) {
            IHandler handler = (IHandler) iterator.next();
            if (handler.executeFlag()) {
                handler.execute();
            }
        }
        this.processSuccessor();
    }
}

public class SupportApplicationTest {

    private final static Logger LOGGER = LoggerFactory.getLogger(SupportApplicationTest.class);


    @Autowired
    private RequestCheckProcessor requestCheckProcessor;

    //entry point
    @Test
    public void method() {
        Assert.assertNotNull("RequestCheckProcessor is null", requestCheckProcessor);

        try {
            //step 1 bind request
            contextHolder.bindRequest("request");

            //step 2 set contextHolder.bindResponse sucess before the end 
            requestCheckProcessor.getProcessor().process();
            contextHolder.bindResponse("response");

            //step 3 return response
            LOGGER.info("response : {}", contextHolder.getResponse());
            
        } catch (Exception e) {
            Result result = new Result(e, ErrorCode.FAIL);
            LOGGER.info("response : {}", result);
        } finally {
            //step 4 ThreadLocal contextHolder clear
            contextHolder.clear();
        }
    }


}

日志

2020-09-05 10:01:13.868  INFO 14724 --- [main] c.c.s.support.holder.ContextHolder       : [ContextHolder] key=request_param,value="request" binded.
2020-09-05 10:01:13.870 DEBUG 14724 --- [main] c.cy.service.support.core.BaseProcessor  : [BaseProcessor] processor is com.cy.service.support.processor.RequestCheckProcessor.
2020-09-05 10:01:13.870 DEBUG 14724 --- [main] c.cy.service.support.core.BaseProcessor  : [BaseProcessor] handler is com.cy.service.support.handler.TokenCheckHandler.
2020-09-05 10:01:13.870  INFO 14724 --- [main] c.c.s.support.handler.TokenCheckHandler  : TokenCheckHandler-execute
2020-09-05 10:01:13.871 DEBUG 14724 --- [main] c.cy.service.support.core.BaseProcessor  : [BaseProcessor] handler is com.cy.service.support.handler.RequestCheckHandler.
2020-09-05 10:01:13.871  INFO 14724 --- [main] c.c.s.s.handler.RequestCheckHandler      : RequestCheckHandler-execute
2020-09-05 10:01:13.871  INFO 14724 --- [main] c.c.s.support.holder.ContextHolder       : [ContextHolder] key=terminate,value=null getted.
2020-09-05 10:01:13.871 DEBUG 14724 --- [main] c.cy.service.support.core.BaseProcessor  : [BaseProcessor] successor is com.cy.service.support.processor.OrderQueryProcessor.
2020-09-05 10:01:13.871 DEBUG 14724 --- [main] c.cy.service.support.core.BaseProcessor  : [BaseProcessor] handler is com.cy.service.support.handler.OrderQueryHandler.
2020-09-05 10:01:13.871  INFO 14724 --- [main] c.c.s.support.handler.OrderQueryHandler  : OrderQueryHandler-execute
2020-09-05 10:01:13.874  INFO 14724 --- [main] c.c.s.support.holder.ContextHolder       : [ContextHolder] key=terminate,value=null getted.
2020-09-05 10:01:13.875  INFO 14724 --- [main] c.c.s.support.holder.ContextHolder       : [ContextHolder] key=response_param,value="response" binded.
2020-09-05 10:01:13.875  INFO 14724 --- [main] c.c.s.support.SupportApplicationTest     : response : response