wie Nachricht senden, um insbesondere websocket-Verbindung mit java-server

Haben Sie die Gestaltung einer Architektur für das.

Wenn ein client stellt eine Verbindung mit dem server (öffnet die WebSocket), der server hat um die Verbindung zu halten irgendwo (wie auch immer Sie sind, identifizieren eine bestimmte Verbindung mit dem Java-backend du verwendest) in eine Datenstruktur, wird davon abhängen, was Sie zu tun versuchen. Eine gute id wäre eine ID, die der Benutzer sieht (wie einen Spitznamen, die nicht bereits abgeholt von einem anderen peer eine Verbindung zum gleichen server). Sonst, verwenden Sie einfach das socket-Objekt einen eindeutigen Bezeichner und, wenn mit anderen Benutzern über das frontend, assoziieren Sie mit Ihren eindeutigen Bezeichner, so dass ein client eine Nachricht senden kann, um einen bestimmten peer.

Einen HashMap wäre eine gute Wahl für eine Daten-Struktur, wenn ein client zum chatten mit anderen spezifischen client, wie ordnen Sie die einzigartige ID von einem client auf den socket und finden Sie einen Eintrag in O(1) in eine hash-Tabelle.

Wenn Sie wollen broadcast-Nachricht von einem client an alle anderen clients, obwohl ein HashMap funktioniert auch Recht gut (mit etwas wie HashMap.Werte()), können Sie mit einem einfachen List senden der eingehenden Nachricht an alle verbundenen clients außer den ursprünglichen Absender.

Natürlich möchten Sie auch entfernen Sie einen client aus der Daten-Struktur, wenn Sie verlieren, die Verbindung mit ihm, die ist einfach über einen WebSocket (Java-framework, die Sie verwenden sollten, rufen Sie zurück, wenn ein socket geschlossen).

Hier ist ein (fast vollständiges) Beispiel für die Verwendung einer Jetty 9 WebSocket (und das JDK 7):

package so.example;
import java.io.IOException;
import java.util.HashMap;

import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
import org.eclipse.jetty.websocket.api.annotations.WebSocket;

@WebSocket
public class MyWebSocket {
    private final static HashMap<String, MyWebSocket> sockets = new HashMap<>();
    private Session session;
    private String myUniqueId;

    private String getMyUniqueId() {
        //unique ID from this class' hash code
        return Integer.toHexString(this.hashCode());
    }

    @OnWebSocketConnect
    public void onConnect(Session session) {
        //save session so we can send
        this.session = session;

        //this unique ID
        this.myUniqueId = this.getMyUniqueId();

        //map this unique ID to this connection
        MyWebSocket.sockets.put(this.myUniqueId, this);

        //send its unique ID to the client (JSON)
        this.sendClient(String.format("{\"msg\": \"uniqueId\", \"uniqueId\": \"%s\"}",
                this.myUniqueId));

        //broadcast this new connection (with its unique ID) to all other connected clients
        for (MyWebSocket dstSocket : MyWebSocket.sockets.values()) {
            if (dstSocket == this) {
                //skip me
                continue;
            }
            dstSocket.sendClient(String.format("{\"msg\": \"newClient\", \"newClientId\": \"%s\"}",
                    this.myUniqueId));
        }
    }

    @OnWebSocketMessage
    public void onMsg(String msg) {
        /*
         * process message here with whatever JSON library or protocol you like
         * to get the destination unique ID from the client and the actual message
         * to be sent (not shown). also, make sure to escape the message string
         * for further JSON inclusion. 
         */
        String destUniqueId = ...;
        String escapedMessage = ...;

        //is the destination client connected?
        if (!MyWebSocket.sockets.containsKey(destUniqueId)) {
            this.sendError(String.format("destination client %s does not exist", destUniqueId));
            return;
        }

        //send message to destination client
        this.sendClient(String.format("{\"msg\": \"message\", \"destId\": \"%s\", \"message\": \"%s\"}",
                destUniqueId, escapedMessage));
    }

    @OnWebSocketClose
    public void onClose(Session session, int statusCode, String reason) {
        if (MyWebSocket.sockets.containsKey(this.myUniqueId)) {
            //remove connection
            MyWebSocket.sockets.remove(this.myUniqueId);

            //broadcast this lost connection to all other connected clients
            for (MyWebSocket dstSocket : MyWebSocket.sockets.values()) {
                if (dstSocket == this) {
                    //skip me
                    continue;
                }
                dstSocket.sendClient(String.format("{\"msg\": \"lostClient\", \"lostClientId\": \"%s\"}",
                        this.myUniqueId));
            }
        }
    }

    private void sendClient(String str) {
        try {
            this.session.getRemote().sendString(str);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    private void sendError(String err) {
        this.sendClient(String.format("{\"msg\": \"error\", \"error\": \"%s\"}", err));
    }
}

Der code ist selbsterklärend. Über JSON-Formatierung und Analyse, Bootsanleger, hat einige interessante utilities innerhalb Paket org.eclipse.jetty.util.ajax.

Beachten Sie auch, dass wenn Ihr WebSocket-server-framework ist nicht thread-sicher, die Sie benötigen, um die Daten zu synchronisieren Struktur, um sicherzustellen, dass keine Beschädigung von Daten (hier MyWebSocket.sockets).