秒杀Servlce接口设计

1、创建service包，创建SecKillServlce业务接口

SecKillServlce.Java

package org.secKill.service;
/*_* 业务接口：站在“开发者”的角度设计接口_* 三个方面：方法定义粒度，参数，返回类型（return 类型/异常）*/import org.secKill.dto.Exposer;
import org.secKill.dto.SecKillExecution;
import org.secKill.entity.SecKill;
import org.secKill.exception.RepeatKillException;
import org.secKill.exception.SecKillCloseException;
import org.secKill.exception.SecKillException;

import java.util.List;

/** * Created by 谭雪娇 on 2017/5/5. */public interface SecKillService {
    /* * 查询所有秒杀记录 * @return * */ List getSecKillList();
    /* * c查询单个秒杀记录 * @Param SecKillId * @return * */ SecKill getById(long secKillId);
    /* * 秒杀开启时输出秒杀接口地址， * 否则输出系统时间 * @param secKillId * */ Exposer exportSecKillUrl(long secKillId);
    /* * 执行秒杀操作 * @param secKillId * @param userPhone * @param md5*/ SecKillExecution executeZSecKill(long secKillId, long userPhone, String md5) throws SecKillException,RepeatKillException,SecKillCloseException;
}

建立dto包，创建暴露秒杀接口dto（数据传输层）

Exposer.java

package org.secKill.dto;

/** * Created by 谭雪娇 on 2017/5/5. * 暴露秒杀接口DTO */public class Exposer {
    //是否开启秒杀 private boolean exposed;
    //一种加密措施 private String md5;
    //id private long secKillId;
    //开始时间 private long start;
    //结束时间 private long end;

public Exposer(boolean exposed, String md5, long secKillId) {
        this.exposed = exposed;
        this.md5 = md5;
        this.secKillId = secKillId;
    }

public Exposer(boolean exposed, String md5, long start, long secKillId, long end) {
        this.exposed = exposed;
        this.md5 = md5;
        this.start = start;
        this.secKillId = secKillId;
        this.end = end;
    }

public Exposer(boolean exposed, long secKillId) {
        this.exposed = exposed;
        this.secKillId = secKillId;
    }

public boolean isExposed() {
        return exposed;
    }

public void setExposed(boolean exposed) {
        this.exposed = exposed;
    }

public String getMd5() {
        return md5;
    }

public void setMd5(String md5) {
        this.md5 = md5;
    }

public long getSecKillId() {
        return secKillId;
    }

public void setSecKillId(long secKillId) {
        this.secKillId = secKillId;
    }

public long getStart() {
        return start;
    }

public void setStart(long start) {
        this.start = start;
    }

public long getEnd() {
        return end;
    }

public void setEnd(long end) {
        this.end = end;
    }

@Override
    public String toString() {
        return "Exposer{" +
                "exposed=" + exposed +
                ", md5='" + md5 + '\'' +
                ", secKillId=" + secKillId +
                ", start=" + start +
                ", end=" + end +
                '}';
    }
}

创建包enums，创建枚举类型SecKillStateEnum.java使用枚举表述数据常量字典

SecKillStateEnum.java

package org.secKill.enums;

/** * 使用枚举表述常量数据字典 * * @author yan */public enum SecKillStateEnum {

SUCCESS(1, "秒杀成功"), END(0, "秒杀结束"),

REPEAT_KILL(-1, "重复秒杀"),

INNER_ERROR(-2, "系统异常"),

DATA_REWRITE(-3, "数据篡改");

private int state;

private String stateInfo;

private SecKillStateEnum(int state, String stateInfo) {
        this.state = state;
        this.stateInfo = stateInfo;
    }

public int getState() {
        return state;
    }

public String getStateInfo() {
        return stateInfo;
    }

public static SecKillStateEnum stateOf(int index) {
        for (SecKillStateEnum state : values()) {
            if (state.getState() == index) {
                return state;
            }
        }
        return null;
    }

}

在dto包内创建封装秒杀执行后结果类SecKillExecution.java

package org.secKill.dto;

import org.secKill.entity.SuccessKilled;
import org.secKill.enums.SecKillStateEnum;

/** * Created by 谭雪娇 on 2017/5/5. * 封装秒杀执行后结果 */public class SecKillExecution {
    private long secKillId;
    //秒杀执行结果状态 private int state;
    //状态标识 private String stateInfo;
    //秒杀成功对象 private SuccessKilled successKilled;

public SecKillExecution(long secKillId, SecKillStateEnum stateEnum , SuccessKilled successKilled) {
        this.secKillId = secKillId;
        this.state = stateEnum.getState();
        this.stateInfo=stateEnum.getStateInfo();
        this.successKilled=successKilled;

}

public SecKillExecution(long secKillId,SecKillStateEnum stateEnum) {
        this.secKillId = secKillId;
        this.state =stateEnum.getState();
        this.stateInfo = stateEnum.getStateInfo();
    }

public long getSecKillId() {
        return secKillId;
    }

public void setSecKillId(long secKillId) {
        this.secKillId = secKillId;
    }

public int getState() {
        return state;
    }

public void setState(int state) {
        this.state = state;
    }

public String getStateInfo() {
        return stateInfo;
    }

public void setStateInfo(String stateInfo) {
        this.stateInfo = stateInfo;
    }

public SuccessKilled getSuccessKilled() {
        return successKilled;
    }

public void setSuccessKilled(SuccessKilled successKilled) {
        this.successKilled = successKilled;
    }
}

创建包exception创建三个异常

创建SecKillException.java 秒杀执行异常

package org.secKill.exception;

/** * Created by 谭雪娇 on 2017/5/5. */public class SecKillException extends RuntimeException{
    public SecKillException(String message){super(message);}
    public SecKillException(String message,Throwable cause){super(message,cause);}
}

重复秒杀异常RepeatKillException.继承SecKillException.java

package org.secKill.exception;

import org.secKill.dto.SecKillExecution;
import org.secKill.entity.SuccessKilled;
import org.secKill.enums.SecKillStateEnum;

/** * Created by 谭雪娇 on 2017/5/5. */public class RepeatKillException extends SecKillException{
    public RepeatKillException(String message) {
        super(message);
    }

public RepeatKillException(String message, Throwable cause) {
        super(message, cause);
    }
}

创建SecKillException.java,表示秒杀关闭异常

package org.secKill.exception;

/** * Created by 谭雪娇 on 2017/5/5. * 秒杀关闭异常 */public class SecKillCloseException extends SecKillException {
    public SecKillCloseException(String message) {
        super(message);
    }

public SecKillCloseException(String message, Throwable cause) {
        super(message, cause);
    }
}