在有的情况下,我们需要得到固定格式的序列号,而不是数据库默认的自增序列号,
例如我们要求此序列号必须有固定前缀,长度必须固定为12为,必须自增,要怎么实现呢。
通常情况下,可以在Oracle中定义一个序列,
CREATE SEQUENCE seqTest
INCREMENT BY 1 -- 每次加几个
START WITH 1 -- 从1开始计数
NOMAXvalue -- 不设置最大值
NOCYCLE -- 一直累加,不循环
CACHE 10; --设置缓存cache个序列,如果系统down掉了或者其它情况将会导致序列不连续,也可以设置为---------NOCACHE
定义好sequence后,你就可以用currVal,nextVal取得值。
SELECT Sequence名称.CurrVal FROM DUAL;
select seqtest.currval from dual
我们可以将这个序列通过触发器绑定到某个表上,例如下面,
create sequence SEQ_ID
minvalue 1
maxvalue 99999999
start with 1
increment by 1
nocache
order;
建解发器代码为:
create or replace trigger tri_test_id
before insert on S_Depart --S_Depart 是表名
for each row
declare
nextid number;
begin
IF :new.DepartId IS NULLor :new.DepartId=0 THEN --DepartId是列名
select SEQ_ID.nextval --SEQ_ID正是刚才创建的
into nextid
from sys.dual;
:new.DepartId:=nextid;
end if;
end tri_test_id;
这样就实现了在表中插入数据时候自定义的序列可以自增了。
————————————————————
在IBE在PRE_PAYMENT的ACTION中,将会生成一个唯一的transaction ID, 这个ID会根据不同的业务类型分配不同的前缀,例如RR,RB,RH等。
可以看到,在数据库中创建了如下序列,
CREATE SEQUENCE TXCTLADMIN.SQ_TXCTL_ONLINE_REVENUE_BKG INCREMENT BY 1 MAXVALUE 99999999 MINVALUE 1 CYCLE NOCACHE ORDER
其实这个步骤也可以在Hibernate中进行配置,像下面这样,
接着在java代码OnlineTransactionDataProviderImpl中,通过以下方式获取下一个序列号,
@Override
public Long getSequenceNum(final String sequenceName) {
return (Long) this.getSessionFactory().getCurrentSession()
.createSQLQuery("select " + sequenceName + ".NEXTVAL as id from dual").addScalar("id", Hibernate.LONG)
.uniqueResult();
}
关键代码为select " + sequenceName + ".NEXTVAL as id from dual 这一句,结合上面java代码的上下文,这里的sequenceName为SQ_TXCTL_ONLINE_REVENUE_BKG,
即,如果已经在数据库中创建了一个序列,则获取下一个序列是借助虚拟表DUAL获取的,像下面这样,
SELECT TXCTLADMIN.SQ_TXCTL_ONLINE_REVENUE_BKG.NEXTVAL FROM DUAL;
通过上面的方式可以生成一个transaction ID, 我们可以验证当前生成的ID值,
SELECT TXCTLADMIN.SQ_TXCTL_ONLINE_REVENUE_BKG.CURRVAL FROM DUAL;
在简单的插入数据的业务中,完全可以配置一个触发器,每当插入数据到指定表的时候,就获取上面的序列并随之插入新行中,
但是IBE在这里获取了序列号之后,新行并不是需要马上插入数据库,因为后面还有大量业务需要处理,所以这里只是先显式生成序列号。
传统的Java多线程经常使用synchronized来同步线程,它依靠JVM的锁机制来实现临界区的函数或者变量在访问中的原子性。
在Web容器默认采用单实例(单Servlet实例)多线程的方式来处理Http请求,但是,这样的处理方式会导致变量访问的线程安全问题。也就是说,Servlet对象并不是一个线程安全的对象。
为了解决web容器多线程的线程安全问题,可以使用ThreadLocal机制来解决这个问题。
在IBE中,各个service bean都是无状态的,用户的状态都保存在session中,但是多个用户的所有操作日志都将打印在同一个日志文件中,如果没有一个标识符号,根本无法区分哪条日志是谁的。
因此在IBE中,就是先定义了一个ThreadLocal类型的关联ID:correlationInfo,当用户的第一个请求到达服务器时,先生成一个correlationInfo变量,每次写日志时用这个变量作为唯一标识符,
多个线程之间的correlationInfo则能起到唯一标识作用,在日志上就能区分每个用户的内容了。当用户操作发生跳转,有新的请求的时候,可以将correlationInfo放在session或者放在URL中,当同
一个用户的请求到达时候,再读出这个corrleationInfo,继续写日志。
private static ThreadLocal
获取corrInfo的方法,可以看到用的是JDK自带的UUID算法,可以保证唯一性。
public static CorrelationInfo getCorrelationInfo() {
CorrelationInfo correlationInfo = ThreadLocalUtil.corrInfo.get();
if (correlationInfo == null || correlationInfo.isBlankCorrelationInfo()) {
correlationInfo = new CorrelationInfo("null", UUID.randomUUID().toString(), "WEB");
}
return correlationInfo;
}
接着,在做payment之前,因为此payment请求是从第三方跳转到IBE的,甚至是在内部和外部系统进行多次来回跳转,此时需要先获取这个correlationId,写日志的时候就不会混乱。
bookingDetail.setCorrelationInfo(ThreadLocalUtil.getCorrelationInfo());
IBE由SpringMVC实现业务层,单例sevelet将每个http请求分配到独立线程,通过FacadeController找到具体的service进行执行,这个过程中,IBE与内外系统有来回交互,在Service层中的bean几乎是无状态的(除了一些需要注入的handler),所有用户状态都保存在session中,另外通过correctlation ID可以将请求与线程绑定,即每次都能保证在内外系统通过http交互时,同一个人的请求总是由同一个线程继续处理。http请求默认是重写URL实现,每一个http请求中,都附带有JSESSION ID,默认的session ID是IBE自己生成并用来保存用户状态,但此JSESSION ID则是由外部系统1A生成,用来与具体事务关联的(例如锁定票务事务,票务是由第三方提供的)。
Web容器默认采用单实例(单Servlet实例)多线程的方式来处理Http请求
手机扫一扫
移动阅读更方便
你可能感兴趣的文章