Wie kann ich eine Client Server Verbindung in Java aufbauen?

Hallo,

ich habe einen Server auf einem VPS installiert, der auf den Port 1234 für eingehende Pakete wartet.

Ich habe einen Client auf meinem Desktop gestartet, der ein Paket an diesen Server sendet. Wenn der Server das Paket empfängt, sendet er ein Bestätigungspaket zurück an den Client.

Die Verbindung wird mit einem Socket und einem SocketServer abgewickelt. Wenn ich das Bestätigungspaket auf dem Client vom Server erhalten möchte, muss ich z.B. einen ServerSocket auf dem Port 4321 öffnen.

Wird das nicht von der Firewall blockiert, weil der Port nicht geöffnet ist? Oder kann Java von sich aus einen Port öffnen?

1 Antwort

Destranix

Von gutefrage auf Grund seines Wissens auf einem Fachgebiet ausgezeichneter Nutzer

Java, Programmieren & Softwareentwicklung

26.07.2022, 13:28

Java kann auf einem Port lauschen oder Pakete an einen Port versenden.

Bei beidem kann die Firewall dazwischenfunken, je nach Konfiguration. Ebenfalls kann es sein, dass der Port bereits durch eine andere Applikation besetzt ist.

QuirinK13

Beitragsersteller

26.07.2022, 17:03

Ein Freund nannte mir den Begriff Reverse SSH, kann das die Lösung sein?

Destranix

26.07.2022, 17:22

@QuirinK13

Wenn du das Problem schilderst könnte ich dir deine Frage evtl. beantworten.

Wenn es darum geht, dass die lokale Firewall verhindert, dass der Server seine Verbindung auf einen nicht slebst geöffneten Port aufbaut, dann kann man das umeghenen ähnlich, wie das beim Passive-Mode von FTP der Fall ist, dass der Server dem Client sagt, welchen Port dieser verwenden soll und dann der Client die Verbindung aufbaut.

Reverse-SSH funktioniert wohl ähnlich.

QuirinK13

Beitragsersteller

26.07.2022, 19:14

@Destranix

Im Grunde ist es sowas. Wenn man ein Online Computer Spiel spielen möchte, öffnet der User ja auch nicht manuell einen Port.

Bei meinem Programm handelt es sich um ein Spiel, das mit Java programmiert wurde. Dort soll ein Lizenzsystem eingebaut werden.

Die Idee ist, dass jede 30 Sekunden ein Paketaustausch des Servers mit dem Client passiert, in dem überprüft wird, ob die Lizenz existiert, der User gebannt oder die Lizenz ausgelaufen ist. In beiden Fällen wird der Client im schlimmsten Fall einen Sperrscreen mit dem Grund beim erneuten Start des Spiels sehen und weiter als das wird man nicht kommen.

Der einfache Part ist der Weg vom Client zum Server. Ich kann beim Server ganz einfach einen beliebigen Port öffnen und den im Client fest hinterlegen. Der Client sendet das Paket an den Server.
Sobald der Server das Paket erhält, soll dieser ein Paket zurück an den Client mit den Lizenzinformationen senden. Dieser Part wird aber schwieriger, da der Port nicht einfach fest in den Server geschrieben werden kann, da nicht jeder User diesen Port freigeschaltet hat. Hier fehlt im Grunde die Lösung

Destranix

26.07.2022, 19:30

@QuirinK13

Du baust dir ein Scoket und arbeitest darüber. Eventuell nutzt du das erste Socket auch nur zum verbindungsaufbau, weist dem Client einen Port zu, über den er sich für das eigene Verbindungssocket an den Server wenden soll.

Über das Socket hast du dann Input- und OutputStream.

Es gab auch irgendwie Sockets und ServerSockets, was da genau der Unterschied ist weiß ich aber gerade nicht.

Destranix

26.07.2022, 19:33

@QuirinK13

Okay, ServerSocket ist für die Serverseite ausgelegt, Socket für die Clieneite.

Ähnliche Beiträge

Java call main() method from another class?

Hallo,

Ich habe ein ServerSocket geschrieben (Server, Client). Jetzt möchte ich, dass auf Knopfdruck sich der Client mit dem Server verbindet. Dazu muss ich jedoch die Client Klasse ausführen.

Wie kann ich die main() methode der Client Klasse von z. B. der Main Klasse ausführen?

Vielen Dank im Vorraus, LG

...zum Beitrag

HTTPS / SSL Verbindung mit angehängter Portangabe?

Hallo,

Ich habe einen Server aufgesetzt und einen dienst darauf laufen. Der dienst wird über einen port aufgerufen. Da der server sich im Internet befindet, habe ich fur die domain ein SSL Zertifikat erstellt. Wenn die domain aufgerufen wird, bestehtauch eine verschlüsselte Verbindung (HTTPS). Wenn ich nun den port an die adresse anhänge, kann die seite nicht aufgerufen werden. Als ungesicherte Seite (HTTP) funktioniert alles.

Wie bekomme ich eine verschlüsselte Verbindung in kombination mit der Portangabe?

https://beispiel@domain.de (funktioniert komme aber nur auf die Apache Seite)

https://beispiel@domain.de:1234 (funktioniert nicht)

http://beispiel@domain.de:1234 (funktioniert)

...zum Beitrag

Woran könnte es liegen, dass die Entschlüsselung der AES verschlüsselten Nachricht vom Client auf der Serverseite nicht korrekt funktioniert?

Beschreibung:

Ich habe eine Client-Server-Anwendung, bei der der Server einen Befehl an den Client sendet, der diesen Befehl auf dem Client ausführt und dann das Ausgaberesultat zurück an den Server schickt. Der Command-Output wird verschlüsselt, bevor er an den Server gesendet wird, und sollte auf der Serverseite entschlüsselt werden, um die Ausgabe anzuzeigen.

Ablauf:

Client:

public void executeCommand() {
    try {
        Process p = Runtime.getRuntime().exec("cmd /c " + commandInput);
        p.getOutputStream().close();


        InputStream processStdOutput = p.getInputStream();
        Reader r = new InputStreamReader(processStdOutput);
        BufferedReader br = new BufferedReader(r);
        String line;


        while ((line = br.readLine()) != null) {
            writeToServerSocket("cmd18721378231dcad2");
            writeToServerSocket(line + "\n");
            writer.flush();
        }


        p.waitFor();
    } catch (Exception ex) {
        System.out.println(ex.getLocalizedMessage());
    }
}

public void writeToServerSocket(String message) {
	try {
		String encodedMessage = EncryptionHelper.encrypt(message);
		writer.write(encodedMessage);
	} catch (Exception e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	}
}

Server:

In einer Dauerschleife wird überprüft:

...
String encryptedInput = scanner.nextLine();
            		String input = EncryptionHelper.decrypt(encryptedInput); // Hier vermutlich Fehler
...
else if (input.contains("cmd18721378231dcad2")) {
    String commandOutput = input.substring(19);
    // Problem: Die Entschlüsselung des commandOutput funktioniert nicht korrekt
    // Hier sollte der entschlüsselte Text angezeigt werden
    controller.updatejTextAreaAllChat(commandOutput + "\n");
}

...

Problem:

Der verschlüsselte Command-Output wird vermutlich (nicht komplett sicher da System.out.println zum debuggen beim Server nicht funktioniert aus welchem Grund auch immer) erfolgreich an den Server gesendet, aber die Entschlüsselung auf der Serverseite funktioniert nicht wie erwartet. Der entschlüsselte Text wird nicht korrekt angezeigt, und es wird sobald ich die Anwendung beende die Fehlermeldung "Input byte array has incorrect ending byte" angezeigt.

Code für die Verschlüsselung/Entschlüsselung:

public class EncryptionHelper {
    private static final String KEY = "mysecretkey";


    public static String encrypt(String plainText) throws Exception {
        // ... (Verschlüsselungslogik)
    }


    public static String decrypt(String encryptedText) throws Exception {
        // ... (Entschlüsselungslogik)
    }
}

Was habe ich bereits versucht:

Die Übertragung der verschlüsselten Daten wurde überprüft und scheint intakt zu sein.
Die Verschlüsselungslogik wurde überprüft und sie scheint korrekt zu sein.
Andere Bereiche des Codes wurden überprüft, um sicherzustellen, dass sie das Entschlüsselungsproblem nicht verursachen.

...zum Beitrag

Python: Wieso kann ich nur eine Nachricht über die Socketverbindung senden?

Moin alle zusammen,

ich habe folgende Frage:

Ich habe zwei Python-Dateien geschrieben:

Client.py:

import socket

W = '\033[0m' # white
R = '\033[31m' # red
G = '\033[32m' # green
O = '\033[33m' # orange
B = '\033[34m' # blue
P = '\033[35m' # purple

def excp():
  print(R+"Es ist ein Fehler aufgetreten!"+W)
   
client = socket.socket()
client.connect((ip, port))
used = []

while True:
  command = str(input("Nachricht: "))
  used.append(command)
  command = command.encode()
  client.send(command)
  msg = client.recv(1024).decode()
  print(msg)
  print(used)

Port und IP sind natürlich definiert.

Server.py:

import socket

W = '\033[0m' # white
R = '\033[31m' # red
G = '\033[32m' # green
O = '\033[33m' # orange
B = '\033[34m' # blue
P = '\033[35m' # purple

def excp():
  print(R+"Es ist ein Fehler aufgetreten!"+W)
  
def sendOutput(msg):
  client.sendto(str(msg).encode(), (ip, port))
 
server = socket.socket()
server.bind((ip, port))
server.listen(1)

while True:
  client, client_addr = server.accept()
  print(f" {client_addr} Client wurde mit dem Server verbunden") 
  msg = client.recv(1024).decode()
  print(msg)

sendOutput(msg)

Das funktioniert auch alles. Nur kann ich vom Client aus nur eine Nachricht schicken, bei der Zweiten kommt nichts mehr beim Server an und auch nicht wieder zurück. Was ist denn falsch?

Vielen Dank im Voraus. :)

...zum Beitrag

Python Socket Programmierung?

Moin Moin,

ich hab grad einen socket chat programmiert. soweit funktioniert auch alles aber ich bekomme immer diesen einen Error. Vielleicht hat wer von euch eine Idee was ich hier falsch gemacht habe.

Server Code:

import socket 
import threading


HEADER = 64
PORT = 5050
SERVER = socket.gethostbyname(socket.gethostname())
ADDR = (SERVER, PORT)
FORMAT = 'utf-8'
DISCONNECT_MESSAGE = "!DISCONNECT"


server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(ADDR)


def handle_client(conn, addr):
    print(f"[NEW CONNECTION] {addr} connected.")


    connected = True
    while connected:
        msg_length = conn.recv(HEADER).decode(FORMAT)
        if msg_length:
            msg_length = int(msg_length)
            msg = conn.recv(msg_length).decode(FORMAT)
            if msg == DISCONNECT_MESSAGE:
                connected = False


            print(f"[{addr}] {msg}")
            conn.send("Msg received".encode(FORMAT))


    conn.close()
        


def start():
    server.listen()
    print(f"[LISTENING] Server is listening on {SERVER}")
    while True:
        conn, addr = server.accept()
        thread = threading.Thread(target=handle_client, args=(conn, addr))
        thread.start()
        print(f"[ACTIVE CONNECTIONS] {threading.activeCount() - 1}")



print("[STARTING] server is starting...")
start()

# Und hier der Client Code:

import socket


HEADER = 64
PORT = 5050
FORMAT = "utf-8"
DISCONNECT_MESSAGE = "!DISCONNECT"
SERVER = "192.168.1.14"
ADRR = (SERVER, PORT)


client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect(ADRR)


def send(msg):
    message = msg.encode(FORMAT)
    msg_length = len(message)
    send_length = str(msg_length).encode(FORMAT)
    send_length += b' ' * (HEADER - len(send_length))
    client.send(send_length)
    client.send(message)
    print(client.recv(2048).decode(FORMAT))


while True:
    input = input("Deine Nachricht: ")
    send(input)

#Der Error:

Name Error: name "hallo" is not defined

...zum Beitrag

Kommunikation zwischen Java Programmen?

Hey,

ich bin nun schon Recht erfahren in Java und mir ist eine Frage aufgekommen. Wie kann man in Java Daten von einem Client zu einem Server austauschen? Gibt es da einen oberfachbegriff für dieses Thema? Es geht mir nicht nur darum, dass der Client beispielsweise was in eine Datenbank reinschreibt und der Server daraus liest sonder es geht mir um einen direkten Austausch von Daten zwischen Client und Server.

Wäre nice wenn dazu jemand was schreiben kann.

Danke

...zum Beitrag

Python Socket Server TCP Status erkennen?

Hi, ich suche jetzt leider schon seit Stunden:

Ich hätte gerne in der Bedingung der While-Schleife irgendetwas stehen was den Status von TCP überprüft, also ob der Client noch anwesend ist, oder nicht, ohne das mit einem Timeout regeln zu müssen.

Geht das?

LG.

import socket
import time

host = '0.0.0.0'
port = 5000
timeout = 5.0

def server_program():
    print('listen on: '+host)
    ss = socket.socket()
    ss.bind((host, port))
    ss.listen(5)
    (conn, address) = ss.accept()
    #WAITNING FOR SOCKET
    
    print("Client: " + str(address))
    
    
    timestamp = time.time()
    while timestamp+timeout>time.time():
        c = 0
        data = conn.recv(1024*10)
        #datay = data.decode()
        if not data:
            None
        else:
            #print('return: "'+str(datay)+'"')
            conn.send(data)
            timestamp = time.time()
        time.sleep(0.1)

    conn.close()


if __name__ == '__main__':
    server_program()

...zum Beitrag

Zielcomputer verweigert Verbindung - Python, Socket?

Moin Freunde, ich bin noch recht neu auf dem Gebiet.

Ich wollte gerne einen Server einrichten, der auf einem PC läuft und mich dann über einen anderen PC verbinden. Und das alles in Python mit Sockets. Ich habe folgendes geschrieben:

Server.py:

import socket

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

port = input("Über welchen Port soll der Server laufen?: ")

s.bind(("0.0.0.0", int(port)))

s.listen(5)

name = socket.gethostname()

while True:

clientsocket, address = s.accept()

print(G+f"Verbindung von " + name + " wurde hergestellt!")

clientsocket.send(bytes("Wilkommen auf dem Server", "utf-8"))

Client.py:

import socket

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

port = input("Über welchen Port soll die Verbindung aufgebaut werden?: ")

ip = input("Wie lautet die IP des Servers?: ")

s.connect((ip, int(port)))

input("")

Das funktioniert alles auch gut soweit, allerdings sagt mir mein zweiter PC, dass mir mein erster PC die Verbindung verweigert: ConnectionRefusedError: [WinError 10061]

Könnt ihr mir helfen?

LG und vielen Dank im Voraus,

Lucskiii

...zum Beitrag

BlueJ Methode für eine private Nachricht?

Hier ist der Code, ich brauche eine Methode mit der ich eine Nachricht an einen User an einen Server senden kann der nur dieser User sieht

public class EchoServer extends Server {

public EchoServer(int port) {

super(port);

System.out.println("Der DBG-ECHO-Server hat die IP " + getIP() + " und lauscht auf Port " + port + "!");

}

public void processNewConnection(String pClientIP, int pClientPort) {

System.out.println("Neue Verbindung von " + pClientIP + " : " + pClientPort + ".");

send(pClientIP, pClientPort, "Herzlich willkommen beim DBG-ECHO-Server, Quit um abzumelden, Everybody für Message an alle");

}

public void processMessage(String pClientIP, int pClientPort, String pMessage) {

if (pMessage.equals("Quit")) {

closeConnection(pClientIP, pClientPort);

}

if (pMessage.substring(0, 9).equals("Everybody")) {

sendToAll(pMessage);

}

System.out.println("Server hat Nachricht \"" + pMessage + "\" vom Client " + pClientIP + ":" + pClientPort + " empfangen.");

send(pClientIP, pClientPort, "Antwort vom DBG-ECHO-Server: Deine Nachricht lautete \"" + pMessage + "\".");

System.out.println("Server hat Nachricht \"" + pMessage + "\" an Client " + pClientIP + ":" + pClientPort + " zurückgesendet.");

//sendToAll(pMessage);

//closeConnection(pClientIP, pClientPort);

}

public void processClosingConnection(String pClientIP, int pClientPort) {

}

public void privateMessage(String pClientIP, int pClientPort, String pMessage) {

if (pMessage.substring(0, 9).equals(pClientIP)) {

System.out.println("User schrieb

send(pMessage);

}

public String getIP() {

try {

String ipAdresse = "" + InetAddress.getLocalHost();

String[] hostUndIP = ipAdresse.split("/");

String adressat = hostUndIP[0].trim();

ipAdresse = hostUndIP[1];

return ipAdresse;

}

catch (UnknownHostException e) {

e.printStackTrace();

...zum Beitrag

Java Dreieck aus Zahlen?

Hallo, Ich soll eine Methode public static void schreibeMuster(int n), schreiben, dass folgendes Muster ausgibt: 1 12 123 1234....n

Und noch eine zweite auch mit derselben void Methode das folgende Muster ausgibt: 54321 4321 321 21 1 Ich bitte um Hilfe, bin noch newbie 🙈

...zum Beitrag

Java: Connection reset by peer: socket write error?

Ich habe bei folgenden (das ist um einen zip Datei zu verschicken) den Error:

java.net.SocketException: Connection reset by peer: socket write error
	at java.net.SocketOutputStream.socketWrite0(Native Method)
	at java.net.SocketOutputStream.socketWrite(Unknown Source)
	at java.net.SocketOutputStream.write(Unknown Source)
	at java.nio.file.Files.copy(Unknown Source)
	at java.nio.file.Files.copy(Unknown Source)
	at x46.Server.Server_in.run(Server_in.java:59)
	at java.lang.Thread.run(Unknown Source)

Mein Client (senden der Datei):

		try {
    Socket client = new Socket("localhost", 16102);

    // strems
    // out
    OutputStream outStream = client.getOutputStream();
    PrintWriter out = new PrintWriter(outStream);

    // in

    InputStream inStream = client.getInputStream();
    BufferedReader in = new BufferedReader(new InputStreamReader(inStream));


    // -------------------------------------------------------
    
			File file = new File("send.zip");
			// init array with file length
			byte[] bytesArray = new byte[(int) file.length()];
			  FileInputStream fis = new FileInputStream(file);
			  fis.read(bytesArray); //read file into bytes[]
			  fis.close();
		

			  outStream.write(bytesArray);
			  outStream.flush();

    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

Server(empfängt die Datei):

		try {
			ExecutorService executor = Executors.newFixedThreadPool(2);
        // server starten
        ServerSocket server01 = new ServerSocket(16102);

        System.out.println("Warte auf clients auf dem Port " + server01.getLocalPort());
        // --------------------------------------------------------------
        while (true) {

            // connection aktiviren
            Socket connection = server01.accept();
            System.out.println("Client verbingung unter: " + connection.getRemoteSocketAddress());

            // -------------------------------------------------------------

            // strems
            // out
            OutputStream outStream = connection.getOutputStream();
            PrintWriter out = new PrintWriter(outStream);

            ObjectOutputStream oos = new ObjectOutputStream(outStream);
            // in

            InputStream inStream = connection.getInputStream();
            BufferedReader in = new BufferedReader(new InputStreamReader(inStream));

            // ------------------------------------------------------------

            // Path path = Paths.get("test.zip");
            File f = new File("test.zip");
            Files.copy(f.toPath(), outStream);
        }
    } catch (IOException e) {
        e.printStackTrace();

    }

Also woher kommt der Error?

...zum Beitrag

Websocket Verbindung zwischen Android Client und Erlang Server?

Hallo,

Nachdem ich vor etwa einem Monat damit begann, meine eigene Handyapp zu entwickeln, um meine Kenntnisse zu festigen, bin ich momentan auf folgenden Stand:

Alte Frage: Kommunikation zwischen App und Webserver? (Computer, App, Server) - gutefrage

Ich kann mich mithilfe des HTTP Protokolls bei der App registrieren und anmelden. Kann Freunde hinzufügen und mit denen einen privaten Chat starten. Jedoch funktioniert alles noch über HTTPS und der Client stellt jede sekunde eine Anfrage an den Server. Nun würde ich gerne eine Websocketverbindung implementieren.

Auf den Server läuft Ubuntu, eine SQL Datenbank und ein Apache Webserver. Serverseitig würde ich gerne den Websocketserver mit Erlang programmieren, da bekannte SocialMedia Konzerne dies ebenfalls nutzen. Ich habe mich reichlich über die Websocketverbindung informiert und weis den Ablauf, jedoch finde ich keine ausreichenden Quellen, wie ich den Client in AndroidStudio/Java umsetzen kann, sodass er auch auf Servernachrichten reagiert. (Bisher habe ich nur zum Websocket hin kommunizieren können und direkte Anworten wahrnehmen können), gleicher Effekt wie mit dem HTTP Protokoll. Manche verwenden die Socketbibliothek, welche aber nur direkte Anworten auffangen kann. Andere verwenden SocketIO, dies habe ich aber nicht zum laufen bekommen.

Welche Bibliotheken sollte ich für meine Anforderungen nutzen und in welche Richtung sollte die Umsetzung erfolgen?

Liebe Grüße

Alex

...zum Beitrag

Docker Container, öffnet Ports nicht nach außen?

Hi,

ich habe das Problem das einer meiner Docker Container, welcher dafür da ist einen tmodloader server zu erstellen, den Port 7777 nach außen hin offenscihtlich nicht öffnet.

ich nutze EXPOSE 7777 in meinem Dockerfile und in meinem docker-compose file

ports:
- "7777:7777"

Soweit ich das verstanden habe, erstellt Docker ja für mich die iptable rules, welche definieren welcher port/adresse zu welchem container gemappt ist.

Der Server ist auch auf jeden fall gestartet. Wenn ich den server auf meinem vps direkt ausführe, dann ist es möglich sich über terraria/tmodloader zu verbinden.
Wenn ich den Docker container auf dem vps starten lasse und dann mit nmap checke ob der port auf meinem vps frei ist, meldet nmap zurück das der port closed ist.

...zum Beitrag

Windows VPS Grafikkarte stopt?

Wenn ich mit mit Windows Remote Desktop Connection zum VPS Server verbinde sehe ich alles, aber wenn man die Verbindung beendet schaltet der vps server automatisch die Grafikkarte aus, weil wenn niemand eine verbindung offen hat, spart sich der VPS Server die Grafikkarte.

Ich habe aber eine art Livestream gestartet auf dem VPS Server und bekomme dann nur ein schwarzes Bild.

Kann man irgendwie den VPS Server so einstellen das er immer die Grafikkarte eingeschlatet laest, auch ohne das jemand verbuden ist?

...zum Beitrag

Was möchtest Du wissen?

Deinen Beitrag erstellen