Ambiance: serveur reçoit son message

Question

j'ai un ManagedService avec fonction onMessage

@ManagedService(path = "/atmosphere/formuserpresence/{id}") 
public class FormUserPresenceUpdate extends AtmosphereHelper 
{ 

    @Message 
    public final void onMessage(final String message) throws IOException 
    { 
     ... 
     ... 
     ... 
     ... 
     broadcast(FormUserPresenceUpdate.class, "/atmosphere/formuserpresence/" + statusMessage.getId(), returnArrayString); 
    } 

} 

Et je la communication client-serveur. Plusieurs clients peuvent s'abonner à cette chaîne en utilisant leurs identifiants. Ensuite, le client peut envoyer un statut, comme

message = { ident: "UNIQID", statut: "statusMessageValue" });

Classe FormUserPresenceUpdate stocke tous les statuts reçus de tous les clients et les renvoie en tant que tableau sous la forme d'une fonction de diffusion en tant que messages (returnArrayString). Le problème est que, si les clients reçoivent les valeurs correctes (le tableau de messages), le serveur reçoit également ce tableau de lui-même et n'a pas réussi à l'analyser. Donc, la question est: quelle est la solution à cette situation? Puis-je en quelque sorte le faire, de ne pas envoyer ce tableau de messages par le serveur lui-même? Ou devrais-je créer une deuxième chaîne (je ne voudrais vraiment pas faire ça)?

Answer 1

Vous devez définir votre message en tant que classe et définir un décodeur pour cette classe;)

public class Message { 
    private String ident; 
    private String status; 
    ... 

    getter and setter method. 

    ... 
} 

décodeur (cela dépendra com.fasterxml.jackson.databind.ObjectMapper):

public class MessageDecoder implements Decoder<String, Message> { 

    private ObjectMapper mapper = new ObjectMapper(); 

    @Override 
    public Message decode(String s) { 
     try { 
      return mapper.readValue(s, Message.class); 
     } catch (IOException e) { 
      throw new RuntimeException(e); 
     } 
    } 
} 

Et ajouter decoders = {MessageDecoder.class} à @Message:

@Message(decoders = {MessageDecoder.class}) 
public final void onMessage(final String message) throws IOException 
{ 
    ... 
    ... 
    ... 
    ... 
    broadcast(FormUserPresenceUpdate.class, "/atmosphere/formuserpresence/" + statusMessage.getId(), returnArrayString); 
} 

Et il y a un autre r solution, utilisez JSONParser pour déterminer si le message peut être analysé dans la classe Message ou non, laissez @Messsage retourner la méthode.