Socket-Kommunikation mit einem Webbrowser über Java und JavaScript ②

Hintergrund

Frühere Artikel: https://qiita.com/take4eng/items/d0b009c48ee8c3fe420a

Erstellen Sie wie im vorherigen Artikel oben beschrieben ein Serverprogramm in Java und führen Sie die Socket-Kommunikation durch. ⇒ Da die HTTP-Kommunikation durch Drücken analysiert wird, ist der Code nutzlos kompliziert.

Java EE verfügt über viele APIs für die Socket-Kommunikation und kann sehr einfach implementiert werden. Viele Leute haben es bereits zusammengefasst, aber ich werde die implementierten Inhalte zusammenfassen.

Obwohl eine bequeme API vorbereitet ist, führt niemand eine Analyse durch Drücken durch. Selbst wenn ich es google, kommt es nicht leicht heraus ...

Praktischer Inhalt

1. Verwendung der WebSocket-API
2. Erstellen Sie ein Serverprogramm mit der API
3. Bearbeiten Sie den Client-Programmcode im vorherigen Artikel, um eine Chat-Anwendung zu erstellen

Verwendung der WebSocket-API

Beschreibt die grundlegende WebSocket-API. Es gibt viele andere APIs als die hier vorgestellten, aber Sie können bei Bedarf googeln.

Erstellen einer Endpunktklasse

import javax.websocket.server.ServerEndpoint;
 
@ServerEndpoint("/Kontextpfad")
public class SanpleEndpoint {
}

1. Importieren Sie die ServerEndpoint-Klasse
2. Fügen Sie der Klasse die Annotation @ServerEndpoint hinzu
3. Beschreiben Sie den Kontextpfad, der den Speicherort der Datei angibt

Verarbeitungsmethode erstellen

/*
Importieren Sie jede Klasse
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
*/

//Verarbeitung beim Herstellen einer Verbindung zu einem Client
@OnOpen
public void onOpen(Session session) {
}
 
//Was tun, wenn eine Nachricht vom Client empfangen wird?
@OnMessage
public void onMessage(String message) {
}

//Was tun, wenn ein Fehler auftritt?
@OnError
public void onError(Throwable error) {
}

//Was tun, wenn die Verbindung zum Client unterbrochen wird?
@OnClose
public void onClose(Session session) {
}

1. Importieren Sie die erforderlichen Klassen
2. Fügen Sie jede der Methode entsprechende Anmerkung hinzu
3. Argumente können nach Bedarf geändert oder hinzugefügt werden

Erstellen Sie ein Serverprogramm mithilfe der API

Serverprogramm

import java.io.IOException;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;

import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

//Eine Anmerkung, die angibt, dass es sich um eine serverseitige Klasse eines Web-Sockets handelt.
//Streit(wSck)Stellt den URI dar, der beim Herstellen einer Verbindung vom Client verwendet wird.
@ServerEndpoint(value = "/wSck")
public class SocketFree2 {

	//Erstellen Sie einen Client-Sitzungsthread(Speichern Sie jede Sitzung für jeden Client)
	//Set: Sammlung ohne doppelte Elemente
	//CopyOnWriteArrayList：java.util.Eine thread-sichere Version von Set
	private static Set<Session> user = new CopyOnWriteArraySet<>();

	@OnOpen//Bei der Verbindung mit einem Client
    public void onOpen(Session mySession) {
        System.out.println("connect ID:"+mySession.getId());//session.getId():Sitzungs-ID abrufen
        user.add(mySession);//Hinzufügen einer Sitzung pro Client zur Liste
    }

    @OnMessage//Wenn Daten vom Client gesendet werden
    public void onMessage(String text , Session mySession) {//Argumente sind der gesendete Text und die Sitzung der Quelle
    	System.out.println(text);
    	//getAsyncRemote(): Holen Sie sich eine Instanz von RemoteEndpoint
    	//sendText(String): Text an Client senden
    	for (Session user : user) {
    		user.getAsyncRemote().sendText(text);
            System.out.println(user.getId()+"Zweite"+mySession.getId()+"Ich habe die zweite Nachricht gesendet!");
    	}
    	if(text.equals("bye")) onClose(mySession);//Trennen Sie die Verbindung, wenn der Text "Tschüss" ist.
    }

    @OnClose//Wenn der Client die Verbindung trennt
    public void onClose(Session mySession) {
    	System.out.println("disconnect ID:"+mySession.getId());
        user.remove(mySession);//Entfernen Sie die getrennte Client-Sitzung aus der Liste
        try {
			mySession.close();//Trennen Sie die Verbindung mit der Methode zum Schließen
		} catch (IOException e) {
			System.err.println("Ein Fehler ist aufgetreten: " + e);
		}
    }

}

Codebeschreibung

1. 1. Fügen Sie der Klasse die Endpunktanmerkung @ServerEndpoint hinzu und beschreiben Sie den Kontextpfad @ServerEndpoint(value = "/wSck")

2. Erstellen Sie eine Liste, die jeden Client identifiziert private static Set<Session> user = new CopyOnWriteArraySet<>();

3. 3. onOpen-Methode: Client-Sitzung zur Liste hinzufügen user.add(mySession);

Vier. onMessage-Methode: Senden Sie den empfangenen Text unverändert an den Client ⇒ An alle verbundenen Clients mit zur Anweisung senden user.getAsyncRemote().sendText(text);

Fünf. onClose-Methode: Löschen Sie den getrennten Client 5-1. Aus der Benutzerliste entfernen: user.remove (mySession); 5-2. Sitzung löschen und trennen: mySession.close ();

Ausführungsergebnis

Ändern Sie die Adresse des Client-Programms und führen Sie es mit einem Webbrowser aus.

• Informationen zum Code-Inhalt finden Sie in früheren Artikeln var wSck = new WebSocket ("ws: // localhost: 8080 / Projektname / Kontextpfad"); ` (Diesmal "ws: // localhost: 8080 / freeWeb2 / wSck")

Eine Chat-App, die den gesendeten Inhalt anzeigt, ist abgeschlossen. Es unterstützt auch den Zugriff von mehreren Browsern.

Impressionen

Die Socket-Kommunikation war mithilfe der API sehr einfach. Im Vergleich zu dem im letzten Artikel beschriebenen ist die Menge des geschriebenen Codes ungefähr 1/4. Es ist wunderbar. Super einfach.

Außerdem scheint es, dass das Codieren, Decodieren, Verarbeiten und Verarbeiten von JSON-Daten einfach durchgeführt werden kann. Ich habe es diesmal nicht benutzt, aber es wird für die vollständige Entwicklung notwendig sein. Weitere Informationen finden Sie auf der Referenzseite.

Referenzseite

• http://dukelab.hatenablog.com/entry/2014/02/23/145656
• https://cloudear.jp/blog/?p=2053
• https://qiita.com/opengl-8080/items/7ca8484c8579d264e239