gameapi

GAME API

Core Concept

Webocket with Actor

@MessageMapping("/game.req")
@SendTo("/topic/public")
public GameMessage gameReq(@Payload GameMessage gameMessage,
                           SimpMessageHeaderAccessor headerAccessor) {

//ACTOR
// Received Socket Message -> SomeActor
if(gameMessage.getType()== GameMessage.MessageType.GAME){
    switch (gameMessage.getContent()){
        case "join":{
            int ftableNo = gameMessage.getNum1();
            headerAccessor.getSessionAttributes().put("tableNo",ftableNo);
            ActorSelection lobbyActor = system.actorSelection("user/lobby");
            lobbyActor.tell(new JoinGame(ftableNo,userName,userSession),ActorRef.noSender() );
        }

}

RestAPI with ActorMessage

// Simple ASK
@RequestMapping("/gameinfo/dealer/{gameId}")
int getDealer(@PathVariable String gameId) {
    try{
        String actorPath = "user/lobby/table-" + gameId;
        ActorSelection tableActor = system.actorSelection(actorPath);
        return (int)AkkaUtil.AskToActorSelect(tableActor,new TableInfo(TableInfo.Cmd.DealerPos),1);
    }catch (Exception e){
        logger.error(e.toString());
        return -100;
    }
}

// Forward ASK
// In Controller : ASK -> TABLE -> GAME -> RESPONSE
// Finally, the controller does not need to know who is responding.
return (String)AkkaUtil.AskToActorSelect(tableActor,new GameTick(GameTick.Cmd.TESTPING),1);

// In TableActor
.match(GameTick.class,t->{
    if(t.getCmd() == GameTick.Cmd.TESTPING){
        //You can pass the sender and delegate the last response to another actor.
        gameActor.tell(t,getSender());
    }
})

// In GameActor
.match(GameTick.class, c -> {
    if(c.getCmd() == GameTick.Cmd.TESTPING){
        // Just Alive Check
        getSender().tell("ok",ActorRef.noSender());
    }    

MiniProjects

• WebGame Kit for Multiplayer