gamecenter-xoa-구형 구조-stable
29232 단어 table
1、renren-wap-fuxi-service-def
모델과 서비스 인터페이스의 입도는 실제 업무를 인터페이스로 한다
userplay 관련 업무와 같은 단독dao를 인터페이스로 하지 않음
예:
/**
* $Id: IUserPlayService.java 43455 2011-07-27 12:30:44Z [email protected] $
* Copyright 2009-2010 Oak Pacific Interactive. All rights reserved.
*/
package com.xiaonei.wap.fuxi.service;
import java.util.List;
import com.xiaonei.wap.fuxi.model.AppPageResult;
import com.xiaonei.wap.fuxi.model.UserPlayFlowResult;
//--------------------- Change Logs----------------------
// <p>@author wangqiao Initial Created at 2011-7-26<p>
//
//-------------------------------------------------------
public interface IUserPlayService {
/**
* pageId list,
*
* @param userId
* @param pageNum
* @param pageSize
* @return
*/
AppPageResult getMyPlayPageList(int userId, int pageNum, int pageSize);
/**
* page ， expiredDays ， -1 ，os=-1
*
* @param userId
* @param os
* @param expiredDays
* @param pageNum
* @param pageSize
* @return
*/
AppPageResult getFriendPlayPageList(int userId, int os, int expiredDays, int pageNum,
int pageSize);
/**
* apppage
*
* @param userId
* @param pageId
* @param expiredDays
* @return
*/
List<Integer> getFriendPlayByPageId(int userId, int pageId, int expiredDays);
/**
* apppage
*
* @param userId
* @param pageIds
* @param expiredDays
* @return
*/
List<UserPlayFlowResult> getFriendPlayByPageIds(int userId, List<Integer> pageIds,
int expiredDays);
}
2、renren-wap-fuxi-service-impl
DAO 및 impl, util
OO는 in 함수를 많이 사용하여 여러 기록에 대한 조회를 실현하지만, in을 사용하면 만들어진 mysql 인덱스가 작동하지 않습니다. sql는 ==에 있을 때만 인덱스가 작동합니다
예:
/**
* $Id$
* Copyright 2009-2010 Oak Pacific Interactive. All rights reserved.
*/
package com.xiaonei.wap.fuxi.service.impl;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.collections.MapUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.Assert;
import com.xiaonei.wap.fuxi.dao.IUserPlayFlowDAO;
import com.xiaonei.wap.fuxi.model.AppPage;
import com.xiaonei.wap.fuxi.model.AppPageResult;
import com.xiaonei.wap.fuxi.model.UserPlayFlowResult;
import com.xiaonei.wap.fuxi.service.IUserPlayService;
import com.xiaonei.wap.fuxi.util.ComparatorAppPage;
//--------------------- Change Logs----------------------
//<p>@author zhanghua Initial Created at 2011-7-26<p>
// app os ，os=-1
//
//-------------------------------------------------------
public class UserPlayServiceImpl extends BaseBusinessService implements IUserPlayService,
InitializingBean {
/**
* Logger for this class
*/
private static final Log logger = LogFactory.getLog(UserPlayServiceImpl.class);
private IUserPlayFlowDAO userPlayFlowDAO;
@Override
public AppPageResult getMyPlayPageList(int userId, int pageNum, int pageSize) {
if (pageNum <= 0 || userId <= 0 || pageSize <= 0) {
return null;
}
List<AppPage> pageList = null;
// page id
List<Integer> pageIdList = getMyPlayPageIds(userId);
if (CollectionUtils.isNotEmpty(pageIdList)) {
// TODO ， getPagesWithFriendPlay
pageList = getAppPagesByPageIds(pageIdList);
}
//
AppPageResult appPageResult = new AppPageResult();
appPageResult.setCount(pageList == null ? 0 : pageList.size());
//
pageList = page(pageList, pageNum, pageSize);
appPageResult.setAppPageList(pageList);
return appPageResult;
}
@Override
public AppPageResult getFriendPlayPageList(int userId, int os, int expiredDays, int pageNum,
int pageSize) {
if (userId <= 0 || pageNum <= 0 || pageSize <= 0) {
return null;
}
//
Map<String, List<Integer>> playedMap = getFriendPlayMap(userId, expiredDays);
if (logger.isDebugEnabled()) {
logger.debug("playedMap size: " + playedMap.size());
}
if (MapUtils.isEmpty(playedMap)) {
return null;
}
//
List<AppPage> resultList = wrapAppPageList(playedMap);
if (logger.isDebugEnabled()) {
if (resultList != null) logger.debug("resultList size: " + resultList.size());
}
// os
if (os >= 0) {
filterByOs(resultList, os);
}
if (CollectionUtils.isEmpty(resultList)) {
return null;
}
if (logger.isDebugEnabled()) {
if (resultList != null) logger.debug("os filter resultList size: " + resultList.size());
}
//
sort(resultList, new ComparatorAppPage());
//
AppPageResult appPageResult = new AppPageResult();
appPageResult.setCount(resultList == null ? 0 : resultList.size());
//
resultList = page(resultList, pageNum, pageSize);
appPageResult.setAppPageList(resultList);
return appPageResult;
}
@Override
public List<Integer> getFriendPlayByPageId(int userId, int pageId, int expiredDays) {
//
Map<String, List<Integer>> playedMap = getFriendPlayMap(userId, expiredDays);
if (MapUtils.isEmpty(playedMap)) {
return null;
}
if(CollectionUtils.isNotEmpty(playedMap.get(pageId+""))){
return playedMap.get(pageId+"");
}
return null;
}
@Override
public List<UserPlayFlowResult> getFriendPlayByPageIds(int userId, List<Integer> pageIds,
int expiredDays) {
UserPlayFlowResult userPlayFlowResult;
List<UserPlayFlowResult> resultList = new ArrayList<UserPlayFlowResult>();
//
Map<String, List<Integer>> playedMap = getFriendPlayMap(userId, expiredDays);
if (MapUtils.isEmpty(playedMap)) {
return null;
}
for(int pageId : pageIds){
if(CollectionUtils.isNotEmpty(playedMap.get(pageId+""))){
userPlayFlowResult = new UserPlayFlowResult();
userPlayFlowResult.setPageId(pageId);
userPlayFlowResult.setFriends(playedMap.get(pageId+""));
resultList.add(userPlayFlowResult);
}
}
return resultList;
}
@Override
public void afterPropertiesSet() throws Exception {
Assert.notNull(userPlayFlowDAO, "appCategoryDAO is required!");
Assert.notNull(friendsFacade, "friendsFacade is required!");
Assert.notNull(userLastPlayFlowDAO, "userLastPlayFlowDAO is required!");
}
@Autowired
public void setUserPlayFlowDAO(IUserPlayFlowDAO userPlayFlowDAO) {
this.userPlayFlowDAO = userPlayFlowDAO;
}
}
3、renren-wap-fuxi-xoa-client(xoa)
Delegate 및 XoaClientFactory 등 xoa 호출 가능
예: FuxiXoaClientFactory
/**
* $Id$
* Copyright 2009-2010 Oak Pacific Interactive. All rights reserved.
*/
package com.xiaonei.wap.fuxi.xoa;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import org.apache.log4j.Logger;
import com.renren.xoa.ContentParseException;
import com.renren.xoa.Method;
import com.renren.xoa.StatusNotOkException;
import com.renren.xoa.XoaClient;
import com.renren.xoa.XoaResponse;
import com.renren.xoa.methods.XoaMethodName;
import com.renren.xoa.registry.impl.SimpleXoaRegistry;
import com.xiaonei.wap.fuxi.exception.ServiceTimeoutException;
import com.xiaonei.wap.fuxi.exception.ServiceUnableException;
/**
* Xoa Client
*
* ， 。 ，Object null
*
*/
public class FuxiXoaClientFactory {
private static final Logger logger = Logger.getLogger(FuxiXoaClientFactory.class);
public static final String pubdate = "110513";
private static final String SERVICE_ID = "fuxi.xoa.renren.com";
public static final String XOA_SERVICE_URL = "xoa://" + SERVICE_ID;
//TODO ip
private static final String SERVER_HOST = "10.3.19.200";
//TODO
private static final int SERVER_PORT = 8388;
/** 3 */
public static final int XOA_GET_TIMEOUT = 3000;
/** 5 */
public static final int XOA_POST_TIMEOUT = 5000;
private static XoaClient client = null;
/**
*
*
* @return
*/
public static XoaClient getXoaClient() {
if (client != null) {
return client;
}
synchronized (SERVICE_ID) {
// SERVICE_ID client server
SimpleXoaRegistry reg = new SimpleXoaRegistry();
reg.register(SERVICE_ID, SERVER_HOST, SERVER_PORT);
// reg.register(SERVICE_ID, "10.3.19.157", 8388);
// reg.register(SERVICE_ID, "10.3.18.204", 8188);
// reg.register(SERVICE_ID, "10.3.18.210", 8188);
// reg.register(SERVICE_ID, "10.3.19.189", 8188);
// reg.register(SERVICE_ID, "10.3.19.163", 8188);
client = new XoaClient(reg);
}
return client;
}
/**
* ，
*
* @param method
*/
public static void execute(Method method) {
long startTime = System.currentTimeMillis();
method.setParam("v", pubdate);
try {
getXoaClient().execute(method);
} catch (Exception e) {
logger.error("execute," + method.getName() + " error:", e);
} finally {
long used = (System.currentTimeMillis() - startTime);
logger.info(method.getName() + "|" + method.getPath() + "|" + used);
}
}
/**
* ，
*
* @param method
* @return
*/
public static XoaResponse getResponse(Method method) {
int timeout = XOA_GET_TIMEOUT;
if (!XoaMethodName.GET.equals(method.getName())) {
timeout = XOA_POST_TIMEOUT;
}
return getResponse(method, timeout);
}
/**
*
*
* @param method
* @return
*/
private static XoaResponse getResponse(Method method, int timeout) {
long startTime = System.currentTimeMillis();
method.setParam("v", pubdate);
Future<XoaResponse> fs = getXoaClient().submit(method);
try {
return fs.get(timeout, TimeUnit.MILLISECONDS);
} catch (ContentParseException e) {
logger.error("XOA.getResponse ContentParseException", e);
throw new ServiceUnableException();
} catch (InterruptedException e) {
logger.error("XOA.getResponse InterruptedException", e);
throw new ServiceUnableException();
} catch (ExecutionException e) {
logger.error("XOA.getResponse ExecutionException", e);
throw new ServiceUnableException();
} catch (TimeoutException e) {
logger.error("XOA.getResponse TimeoutException", e);
throw new ServiceTimeoutException();
} finally {
long used = (System.currentTimeMillis() - startTime);
logger.info(method.getName() + "|" + method.getPath() + "|" + used);
}
}
/**
*
*
* @param <T>
* @param method
* @param klass
* @return
*/
public static <T> T getContent(Method method, Class<T> klass, int timeout) {
try {
return getResponse(method, timeout).getContentAs(klass);
} catch (ContentParseException e) {
logger.error("request:" + method.getName() + "|" + method.getPath() + " error", e);
return null;
} catch (ServiceUnableException sue) {
logger.error("request:" + method.getName() + "|" + method.getPath() + " error", sue);
return null;
} catch (ServiceTimeoutException ste) {
logger.error("request:" + method.getName() + "|" + method.getPath() + " error", ste);
return null;
} catch (StatusNotOkException e) {
logger.error("request:" + method.getName() + "|" + method.getPath() + " error", e);
return null;
} catch (Exception e) {
logger.error("request:" + method.getName() + "|" + method.getPath() + " error", e);
return null;
}
}
/**
*
*
* @param <T>
* @param method
* @param klass
* @return
*
*/
public static <T> List<T> getList(Method method, Class<T[]> t, int timeout) {
T[] array = getContent(method, t, timeout);
List<T> listEntity = new ArrayList<T>();
if (array != null) {
listEntity = Arrays.asList(array);
}
return listEntity;
}
}
Delegate는 인터페이스를 실현하고 URL의 매핑을 완성하며 관련 파라미터를 가지고 다음과 같다.
/**
* $Id: UserPlayServiceDelegate.java 43518 2011-07-28 04:13:08Z [email protected] $
* Copyright 2009-2010 Oak Pacific Interactive. All rights reserved.
*/
package com.xiaonei.wap.fuxi.xoa.client;
import java.util.List;
import org.apache.commons.collections.CollectionUtils;
import com.renren.xoa.Method;
import com.xiaonei.wap.fuxi.model.AppPageResult;
import com.xiaonei.wap.fuxi.model.UserPlayFlowResult;
import com.xiaonei.wap.fuxi.service.IUserPlayService;
import com.xiaonei.wap.fuxi.xoa.FuxiXoaClientFactory;
//--------------------- Change Logs----------------------
// <p>@author anbingquan Initial Created at 2011-7-26<p>
// import
//-------------------------------------------------------
public class UserPlayServiceDelegate extends BaseDelegate implements IUserPlayService {
final static String _PREFIX_FRIENDPLAYED = FuxiXoaClientFactory.XOA_SERVICE_URL + "/friendplay";
final static String _MYPLAYLIST = _PREFIX_FRIENDPLAYED + "/myplaylist";
final static String _LIST = _PREFIX_FRIENDPLAYED + "/list";
final static String _FRIENDLIST = _PREFIX_FRIENDPLAYED + "/friendlist";
final static String _FRIENDLIST_BATCH = _PREFIX_FRIENDPLAYED + "/friendlistbatch";
@Override
public AppPageResult getMyPlayPageList(int userId, int pageNum, int pageSize) {
Method method = Method.get(_MYPLAYLIST);
method.setParam("userId", String.valueOf(userId));
method.setParam("pageNum", String.valueOf(pageNum));
method.setParam("pageSize", String.valueOf(pageSize));
return FuxiXoaClientFactory.getContent(method, AppPageResult.class, XOA_GET_TIMEOUT);
}
@Override
public AppPageResult getFriendPlayPageList(int userId, int os, int expiredDays, int pageNum,
int pageSize) {
Method method = Method.get(_LIST);
method.setParam("userId", String.valueOf(userId));
method.setParam("os", String.valueOf(os));
method.setParam("expiredDays", String.valueOf(expiredDays));
method.setParam("pageNum", String.valueOf(pageNum));
method.setParam("pageSize", String.valueOf(pageSize));
return FuxiXoaClientFactory.getContent(method, AppPageResult.class, XOA_GET_TIMEOUT);
}
@Override
public List<Integer> getFriendPlayByPageId(int userId, int pageId, int expiredDays) {
Method method = Method.get(_FRIENDLIST);
method.setParam("userId", String.valueOf(userId));
method.setParam("pageId", String.valueOf(pageId));
method.setParam("expiredDays", String.valueOf(expiredDays));
return FuxiXoaClientFactory.getList(method, Integer[].class, XOA_GET_TIMEOUT);
}
@Override
public List<UserPlayFlowResult> getFriendPlayByPageIds(int userId, List<Integer> pageIds,
int expiredDays) {
Method method = Method.get(_FRIENDLIST_BATCH);
method.setParam("userId", String.valueOf(userId));
method.setParam("expiredDays", String.valueOf(expiredDays));
if (CollectionUtils.isNotEmpty(pageIds)) {
for (Integer pageId : pageIds) {
method.setParam("pageIds", String.valueOf(pageId));
}
}
return FuxiXoaClientFactory.getList(method, UserPlayFlowResult[].class, XOA_GET_TIMEOUT);
}
}
4、renren-wap-fuxi-xoa-server
@Get 또는 @Post의 매핑 관계를 통해 서비스 층 내부 인터페이스의 방법을 호출합니다
/**
* $Id$
* Copyright 2009-2010 Oak Pacific Interactive. All rights reserved.
*/
package com.xiaonei.wap.fuxi.controllers;
import java.util.List;
import net.paoding.rose.web.annotation.Param;
import net.paoding.rose.web.annotation.Path;
import net.paoding.rose.web.annotation.rest.Get;
import org.springframework.beans.factory.annotation.Autowired;
import com.xiaonei.wap.fuxi.model.AppPageResult;
import com.xiaonei.wap.fuxi.model.UserPlayFlowResult;
import com.xiaonei.wap.fuxi.service.IUserPlayService;
//--------------------- Change Logs----------------------
// <p>@author anbingquan Initial Created at 2011-7-26<p>
//-------------------------------------------------------
@Path("/friendplay")
public class FriendPlayController {
@Autowired
private IUserPlayService userPlayService;
final static String _MYPLAYLIST = "/myplaylist";
final static String _LIST = "/list";
final static String _FRIENDLIST = "/friendlist";
final static String _FRIENDLIST_BATCH = "/friendlistbatch";
/**
* page ,
*
* @param userId
* @param pageNum
* @param pageSize
* @return
*/
@Get(_MYPLAYLIST)
public AppPageResult getMyPlayPageList(@Param("userId") int userId,
@Param("pageNum") int pageNum, @Param("pageSize") int pageSize) {
return userPlayService.getMyPlayPageList(userId, pageNum, pageSize);
}
/**
* page ， os ，
*
* @param userId
* @param os
* @param expiredDays
* @param pageNum
* @param pageSize
* @return
*/
@Get(_LIST)
public AppPageResult getFriendPlayPageList(@Param("userId") int userId, @Param("os") int os,
@Param("expiredDays") int expiredDays, @Param("pageNum") int pageNum,
@Param("pageSize") int pageSize) {
return userPlayService.getFriendPlayPageList(userId, os, expiredDays, pageNum, pageSize);
}
/**
* apppage
*
* @param userId
* @param pageId
* @param expiredDays
* @return
*/
@Get(_FRIENDLIST)
public List<Integer> getFriendPlayByPageId(@Param("userId") int userId,
@Param("pageId") int pageId, @Param("expiredDays") int expiredDays) {
return userPlayService.getFriendPlayByPageId(userId, pageId, expiredDays);
}
/**
* apppage
*
* @param userId
* @param pageIds
* @param expiredDays
* @return
*/
@Get(_FRIENDLIST_BATCH)
public List<UserPlayFlowResult> getFriendPlayByPageIds(@Param("userId") int userId,
@Param("pageIds") List<Integer> pageIds, @Param("expiredDays") int expiredDays) {
return userPlayService.getFriendPlayByPageIds(userId, pageIds, expiredDays);
}
}
5、renren-wap-fuxi(wap층)
client의delegate 인터페이스를 호출하여 분포식 호출 인터페이스의 목적을 실현하다
package com.renren.wap.fuxi.controller;
import java.util.ArrayList;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.commons.lang.math.NumberUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.util.CollectionUtils;
import org.springframework.web.servlet.ModelAndView;
import com.renren.wap.fuxi.vo.AppPageVO;
import com.xiaonei.platform.core.model.WUserCache;
import com.xiaonei.platform.core.opt.ice.WUserCacheAdapter;
import com.xiaonei.wap.fuxi.model.AppPage;
import com.xiaonei.wap.fuxi.model.AppPageResult;
/**
* @author <a href="mailto:[email protected]"> </a>
* @createTime 2011-07-15 16:00:00
*/
public class FriendPlayedingController extends BaseController {
private static final Log logger = LogFactory.getLog(FriendPlayedingController.class);
private final String ATTRIBUTE_METHOD = "method";
private final String ATTRIBUTE_PAGEVO_LIST = "voList";
private final String ATTRIBUTE_PAGE_CURPAGE = "curpage";
private final String ATTRIBUTE_PAGE_SUM = "navCount";
private final String ATTRIBUTE_PAGE_ITEMPERSIZE = "itemPerPage";
private final int SHOW_FRIEND_COUNT = 2;
public ModelAndView list(HttpServletRequest request, HttpServletResponse response)
throws Exception {
if (logger.isDebugEnabled()) {
logger.debug("FriendPlayedingController begin......");
}
ModelAndView mav = new ModelAndView("/pages/wap/friendsplay");
//int hostId = getUserId(request);
int hostId = 1;
if(hostId==0){
//
}
int os = NumberUtils.toInt(request.getParameter("os"), 0);
int curpage = NumberUtils.toInt(request.getParameter("curpage"), 0);
if (logger.isDebugEnabled()) {
logger.debug("hostId ：" + hostId);
logger.debug("os ：" + os);
logger.debug("currentPage ：" + curpage);
logger.debug("itemPerPage ：" + itemPerPage);
}
AppPageResult appPageResult = userPlayService.getFriendPlayPageList(hostId, os, EXPIRED_NO,
curpage, itemPerPage); // delegate
//AppPageResult appPageResult = tempData();
if (logger.isDebugEnabled()) {
if (appPageResult != null && appPageResult.getAppPageList() != null) {
logger.debug("appPageResult count: " + appPageResult.getCount());
}
}
List<AppPageVO> voList = buildVOList(
(appPageResult != null) ? appPageResult.getAppPageList() : new ArrayList<AppPage>(),
(appPageResult != null) ? appPageResult.getCount() : 0);
mav.addObject(ATTRIBUTE_PAGE_CURPAGE, curpage);
mav.addObject(ATTRIBUTE_PAGE_SUM, (appPageResult != null) ? appPageResult.getCount() : 0);
mav.addObject(ATTRIBUTE_PAGE_ITEMPERSIZE, itemPerPage);
mav.addObject(ATTRIBUTE_PAGEVO_LIST, voList);
mav.addObject(ATTRIBUTE_METHOD, "list");
return mav;
}
private List<AppPageVO> buildVOList(List<AppPage> pageList, int count) {
List<AppPageVO> voList = new ArrayList<AppPageVO>();// （ ， ）
AppPageVO vo;
for (AppPage page : pageList) {
vo = new AppPageVO();
vo.setId(page.getId());
vo.setPageName(page.getPageName());
vo.setCompany(page.getCompany());
vo.setIntroduction(page.getIntroduction());
vo.setWapLogoUrl(page.getWapLogoUrl());
vo.setShowText(getFriendNames(page));
vo.setPlayCount(count);
voList.add(vo);
}
return voList;
}
private String getFriendNames(AppPage page) {
String friendNames = "";
List<Integer> friendIds = String2List(page.getFriends());
List<WUserCache> users;
if (CollectionUtils.isEmpty(friendIds)) {
return null;
}
if (friendIds.size() > SHOW_FRIEND_COUNT) {
users = WUserCacheAdapter.getInstance().getUsersCacheList(
friendIds.subList(0, SHOW_FRIEND_COUNT));
} else {
users = WUserCacheAdapter.getInstance().getUsersCacheList(friendIds);
}
for (int i = 0; i < users.size(); i++) {
if (i < users.size() - 1) {
friendNames += users.get(i).getName();
} else {
friendNames += "," + users.get(i).getName();
}
}
return friendNames;
}
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Vuetify에서 행 그룹화이 기사에서는 유사한 값으로 테이블의 행을 그룹화하는 방법에 대한 경험을 공유하고자 합니다. 물론 기본 그룹화 예제를 찾을 수 있지만 제 사용 사례에는 약간의 고급 기능이 필요했습니다. 제품 데이터가 있다고 가정합니...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
