并发丢失数据 - ITeye问答

0 0

并发丢失数据5

先简要说下代码的过程：并发时候的场景就相当与产生了多个a对象，同时运行a的一个服务，A a =new A(); a.execute(); 类A 里面的变量都是局部变量，作用域在方法内，execute 方法内涉及到了数据库操作，调用别的类的方法，但是调用别的类中的方法的变量也都是局部的，作用域在方法范围内，不知道为啥会产生数据丢失的现象。有碰见过的同学或有能查出这问题的思路帮忙说下。谢谢。

具体的压力测试说明如下。

：模拟复用器启动sim卡注册，查看数据库卡数据入库信息。

卡数据注册情况如下，复用器中的sim卡注册失败会重新注册，此处为并发下复用器第一次注册的情况。

1.1 1台复用器瞬间启动，需要入库1024，实际入库1024条。

2.110台复用器瞬间启动，需要入库2560条，实际入库2552条。

3.110台复用器间隔10秒启动，需要入库2560条，实际入库2560条。

4.1100台复用器间隔5秒启动，需要入库25600条，实际入库25481条。复用器启动过程就是经过另外系统处理将相关的数据写入数据库的过程，代码和上面说的原理一样。只是不明白为啥丢数据。

问题补充：这样吧，我把底层框架说下，底层是用mina2写的，通过接受客户端的协议，然后mina2从线程池拿一个线程去执行，业务，逻辑如下：根据协议号利用反射机制生成对象然后执行对象的方法，执行业务逻辑，整
参考代码如下
每次都是开启一个线程来执行
public void messageReceived(IoSession session, Object message)
throws Exception {
RbMessage tsMessage = (RbMessage) message;//通过底层传递过来的对象

commManager.messageReceived(tsSession, tsMessage);//对对象的处理

}
}catch(Exception e){
LogFactory.getLog(LogUtil.system).error(e.getMessage());
}
}
commManager 里的基本逻辑如下：
DataParser dataParser = new DataParser(message.getContent(),message.getDataLen()); //解析数据
// 实例化处理类
action = getTSAction(dataParser.getType()); //根据反射生成对象

if(action==null){

return;
}
// 赋值
action.setType(dataParser.getType());
action.setVersion(dataParser.getVersion());
action.setDocument(dataParser.getDocument());
action.setFieldListNode(dataParser.getFieldListNode());
action.setResultsNode(dataParser.getResultsNode());
action.setRbMessage(message);

// 执行处理
action.execute(context, session); //执行业务逻辑，
我的qq是316642840 有兴趣的一起探讨下，多谢光临

高并发丢失数据

2014年8月14日 23:25

a7724172
0
0 0 2

3个答案按时间排序按投票排序

0 0

有些描述，没看懂。不过，并发这种东西，如果有bug，很难处理，因为很难发现问题。只能慢慢查找定位了！

2014年8月16日 22:57

freezingsky
159
1 1 16

1条评论

0 0

并发时候的场景就相当与产生了多个a对象，同时运行a的一个服务，A a =new A(); a.execute();

-------------------
上面这句话是啥意思呢？同时运行a的服务，是指的execute方法吗？那就是同时产生多个a对象并执行a的这个方法？如果这样的话首先可以排除是多线程同步导致的问题。有可能是并发的时候丢了请求。

2014年8月15日 14:39