日韩在线三级,久久婷婷丁香,久久国产高清

手游服務端框架之跨服匹配服，手游服務器租用

2018年08月29日

如今的手游世界，如果沒搞個跨服賽事，都不好意思說它是一個手游了。

說到跨服，就不得不說下匹配服了。比如一個跨服天梯賽事，需要滿足不同服的玩家能夠同屏ＰＫ。為了能夠把實力接近的玩家作為對手，我們需要一個獨立的匹配服來收集數據，然后進行房間分配。匹配服，也是跨服賽設計的基礎。

典型的匹配服通信層我們可以采用http,也可以采用socket。本文將采用http作為游戲服與匹配服的通信層。選擇http方式，我們可以搭個tomcat服務，非常方便。當然，如果不使用tomcat的話，我們也可以使用mina或者netty本身的http服務。

設計思路也非常簡單，有點像游戲服的業務處理器。我們需要做到，對于不同的請求，我們都綁定一個方法與之對應。而對于數據的編解碼，由于匹配服的通信數據一般都比較短，我們直接用json進行序列化即可。

下面，開始我們的編碼。

★如有手游服務器租用可咨詢宇眾臨風，QQ：2850293179 Tel：15999932452 訂購網址：www.jindaxi.cn

搭建mina的http服務

在前面游戲后臺設計中，我們已經看到如何使用mina搭建http服務了。

/**
* 匹配服http服務
* @author kingston
*/
public class MatchServer {
private Logger logger = LoggerFactory.getLogger(MatchServer.class);
private IoAcceptor acceptor;
//http端口
int port = 8899;
public void start() throws Exception {
acceptor = new NioSocketAcceptor();
acceptor.getFilterChain().addLast("codec", new HttpServerCodec());
acceptor.setHandler(new HttpServerHandle());
acceptor.bind(new InetSocketAddress(port));
logger.error("---------> http server start at port:{}", port);
}
public void shutdown() {
if (acceptor != null) {
acceptor.unbind();
acceptor.dispose();
}
logger.error("---------> http server stop at port:{}", port);
}
}
class HttpServerHandle extends IoHandlerAdapter {
private static Logger logger = LoggerFactory.getLogger(MatchServer.class);
@Override
public void exceptionCaught(IoSession session, Throwable cause)
throws Exception {
}
@Override
public void messageReceived(IoSession session, Object urlParams)
throws Exception {
if (urlParams instanceof HttpRequest) {
// 請求，解碼器將請求轉換成HttpRequest對象
HttpRequest request = (HttpRequest) urlParams;
Message msg = parseHttpRequest(request);
UrlDispatcher.getInstance().dispatch(session, msg);
}
}
@SuppressWarnings("unchecked")
private Message parseHttpRequest(HttpRequest httpReq) {
String service = httpReq.getParameter("service");
if (StringUtils.isEmpty(service)) {
return null;
}
Class<?> clazz = UrlDispatcher.getInstance().getMessageClazzBy(service);
String paramJson = httpReq.getParameter("param");
if (StringUtils.isNotEmpty(paramJson)) {
try{
return (Message)new Gson().fromJson(URLDecoder.decode(paramJson), clazz);
}catch(Exception e) {
e.printStackTrace();
}
}
return null;
}
}

消息通信

在游戲服，我們發出一條http請求。匹配服為了將請求分發到對應的處理器，我們需要為每一條消息作一個標記。最簡單的，可以使用請求消息的類名。所以，我們必須把業務簽名和參數都融合到url里面去。也就是說，一個有效的url可能是這樣：

http://localhost:8899?service=MReqLadderApplyMessage&param={"playerId":0,"score":0,"power":0}

為了能區別游戲服和匹配服的消息類型，我們匹配服的消息，都加一個M(Match)前綴，那么請求協議就MReq，響應協議就是MRes了。

對于游戲服來說，發出的請求屬于Message的子類，返回的消息也是Message的子類。底層幫我們實現了消息的編解碼。我們可以看下代碼實現。

public class MatchHttpUtil {
public static Message submit(Message request) throws IOException {
String signature = request.getClass().getSimpleName();
String data = new Gson().toJson(request);
String param = HttpUtil.buildUrlParam("service", signature,
"param", data);
String url = "http://localhost:8899" + "?" + param;
System.err.println("發送url:" + url);
String resultJson = HttpUtil.get(url);
UrlResponse urlResponse = new Gson().fromJson(resultJson, UrlResponse.class);
String respClazz = urlResponse.getAttachemt();
Class<?> msgClazz = MatchMessageFactory.getInstance().getMessageBy(respClazz);
Message msgResponse = (Message)new Gson().fromJson(urlResponse.getMessage(), msgClazz);
return msgResponse;
}
}

業務處理器

我們依然使用 @Controller注解來標識一個模塊處理器，使用@RequestMapper注解來標記業務處理方法。不同的是，在游戲服我們每個消息的元信息都帶有一個模塊號和子類型號。在匹配服，我們就不這里處理了。因為匹配服的業務比較少。我們直接用消息類的名稱作為業務簽名即可。

在業務分發器，我們保存每一個方法簽名，與對應的方法處理器。

public class UrlDispatcher {
private Logger logger = LoggerFactory.getLogger(getClass());
private volatile static UrlDispatcher instance;
/** [message signature, CmdExecutor] */
private static final Map<String, CmdExecutor> service2Handler = new HashMap<>();
private static final Map<String, Class<?>> signature2Message = new HashMap<>();
}

匹配服在收到一個http請求，通過參數解析得到對應的業務簽名，同時通過json反序列化得到請求消息的參數。將消息分發到對應的業務處理器。代碼如下：

public void dispatch(IoSession session, Message message) {
String signature = buildSignature(message.getClass());
CmdExecutor cmdExecutor = service2Handler.get(signature);
if (cmdExecutor == null) {
logger.error("message executor missed, signature={}", signature);
return;
}
Object[] params = convertToMethodParams(session, cmdExecutor.getParams(), message);
Object controller = cmdExecutor.getHandler();
try {
//通過反射
cmdExecutor.getMethod().invoke(controller, params);
}catch(Exception e) {
logger.error("", e);
}
}