Atmosphäre: Server erhält seine Nachricht

Question

Ich habe eine ManagedService mit onMessage Funktion

@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); 
    } 

} 

Und ich habe Client-Server-Kommunikation. Mehrere Clients können diesen Kanal mit ihren IDs abonnieren. Dann kann der Client einen Status senden, wie

message = { ident: "uniqid", Status: "statusMessageValue" });

Die Klasse FormUserPresenceUpdate speichert alle empfangenen Status aller Clients und sendet sie per Broadcast-Funktion als Array als Nachrichten zurück (returnArrayString).

Das Problem ist, dass, ob die Clients die richtigen Werte (das Array von Nachrichten) erhalten, der Server dieses Array auch von sich selbst erhält und fehlgeschlagen, es zu analysieren. Die Frage ist also: Was ist die Lösung für diese Situation? Kann ich es irgendwie so machen, dieses Nachrichtenfeld nicht vom Server selbst zu versenden? Oder sollte ich einen zweiten Kanal erstellen (das möchte ich wirklich nicht)?

Answer 1

Sie sollten Ihre Nachricht als eine Klasse definieren und einen Decoder für diese Klasse definieren;)

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

    getter and setter method. 

    ... 
} 

Decoder (dies wird auf com.fasterxml.jackson.databind.ObjectMapper abhängen):

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); 
     } 
    } 
} 

Und füge decoders = {MessageDecoder.class} zu @Message:

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

Und es gibt eine andere Verwenden Sie JSONParser, um zu bestimmen, ob die Nachricht in die Nachrichtenklasse geparst werden kann oder nicht, falls nicht, lassen Sie die Methode @Messsage zurückgeben.