方法1,
首先,确保“queue”表是用InnoDB形式存储的,以支持事务
然后,在“queue”表增加一个标志位,读取的时候设定位一个中间状态
然后,等待短消息发送完毕后,在把这条记录删除掉
最后,一条数据处理完毕后提交事务
首先,确保“queue”表是用InnoDB形式存储的,以支持事务
然后,在“queue”表增加一个标志位,读取的时候设定位一个中间状态
然后,等待短消息发送完毕后,在把这条记录删除掉
最后,一条数据处理完毕后提交事务
解决方案 »
- 请问大家对spring的aop和控制反转是怎么理解的?
- 请问哪位高手对Liferay Portal 的源码有研究?或者对在Liferay Portal 上进行Portlet开发有研究的,请指点一下学习路线。谢谢
- java 数据类型转化,可能你没注意哦
- JAVA有点基础,要怎么才能短时间突破呢?
- websphere 5.1 支持 el表达式语言吗?
- IBM的solidDB,还有这个东西吗?
- jb9+weblogic开发ejb的一个异常~ 不明~
- 请问为什么在做Entity时会有数据库得导入会不是自己设定的数据库呢?
- 急!Hibernate4.3+Spring4.1+Struts2.3整合框架问题
- option中value值的传递问题
- 求正则表达式
- 讨论XML在Java非Web项目中的应用
等待分配给其他线程
每个线程一个临时发送表,每个线程分别读取和删除自己临时子表中的数据
tmp_queue_0001...tmp_queue_0010设计一个单线程,循环检测每个线程的临时表,检测到数据记录数为0时,
从queue表中取得100条记录,插入到子表,并同时从queue中删除记录
(这个过程中使用事务操作)这个方式应该完全满足你的应用