問(wèn)題描述

后臺(tái)的結(jié)構(gòu)是 SpringMVC, Spring, jpa(HibernateJpaDialect),DataSource(c3p0), Mysql(InnoBDB), transactionManager(JpaTransactionManager)。

@Transactional(value = 'transactionManager', isolation = Isolation.READ_UNCOMMITTED) public Object addScenicSpot(int tourGuideID, String jsonStr) {Djd_js entity = new Djd_js();try{ _setEntity(entity, jsonStr); entity.setDaoyouID(tourGuideID); jdjsDao.save(entity); int spotId = entity.getId(); //添加信息到消息隊(duì)列中try { Sender sender = new SenderImpl(); sender.getGPSFromBaiduAPI('jdjs', spotId, entity.getDizhi());} catch (InterruptedException e) { return false;} return spotId;}catch (Exception e){ return false;} }

以上是保存的部分，并把得到的 ID 發(fā)送到消息隊(duì)列中，下邊是消息隊(duì)列的處理部分

public boolean updateLngAndLat(MessageVo messageVo) {System.out.println('CreateTime--------'+messageVo.getCreateDate());System.out.println('Address--------'+messageVo.getContent());System.out.println('Id--------'+messageVo.getId());Djd_js entity = jdjsDao.findOne(messageVo.getId());System.out.println('entity-Address--------'+entity.getDizhi());、、運(yùn)行到這里就直接卡住了，如果注釋掉查詢，其他的調(diào)用皆正常。Map<String, Object> result = LngAndLatUtil.getLngAndLat(((MessageVo) messageVo).getContent());System.out.println('result--------'+(int)result.get('result'));if (1 == (int)result.get('result')){ entity.setJingdu(Double.valueOf(result.get('lng').toString())); entity.setWeidu(Double.valueOf(result.get('lat').toString())); System.out.println('message-------------------------------'+'lng:'+Double.valueOf(result.get('lng').toString())+', lat:'+Double.valueOf(result.get('lat').toString())); jdjsDao.updateLngAndLatBySenciSpotID(messageVo.getId(), (Double) result.get('lng'), (Double) result.get('lat'));}else { System.out.println('message-------------------------------False');}return false; }3 問(wèn)題描述

前端調(diào)用 addScenicSpot() 方法，會(huì)將信息保存到數(shù)據(jù)庫(kù)中，然后將保存之后的數(shù)據(jù)控中的ID發(fā)送到消息隊(duì)列中，然后訂閱者處理隊(duì)列中的信息，根據(jù) ID 查詢到剛保存的信息，然后調(diào)用外部接口查詢到經(jīng)緯度，并將得到的經(jīng)緯度存儲(chǔ)到數(shù)據(jù)庫(kù)中。現(xiàn)在的問(wèn)題是，保存信息正常，但是到了訂閱者處理這邊，根據(jù)得到的 ID 查找不到保存的信息。

產(chǎn)生bug的原因是spring事務(wù)提交晚于消息隊(duì)列的生產(chǎn)消息，導(dǎo)致消息隊(duì)列消費(fèi)消息時(shí)獲取到的數(shù)據(jù)不正確,靈感來(lái)自于這里:http://www.cnblogs.com/taocon...

問(wèn)題解答

同步調(diào)用，改為異步調(diào)用？

@AsyncgetGPSFromBaiduAPI

已經(jīng)解決了問(wèn)題了,應(yīng)用的這里的方法:http://www.cnblogs.com/taocon...