Server/klient

http://www.eksperten.dk/artikler/515 har nogle eksemler paa client/server over socket !

(artiklens formaal er at vise .NET---Java men eksemplerne virker fint med
Java---Java)

På klient delen, har jeg banket det her sammen:

public void startnet(){
        try {
              s = new Socket("127.0.0.1", 12345);
              pw = new PrintWriter(s.getOutputStream());
              br = new BufferedReader(new InputStreamReader(s.getInputStream()));
              recvThread = new recvNet();
              recvThread.start();
        }
        catch (NumberFormatException e){
            e.printStackTrace();
        }
        catch (UnknownHostException e){
            e.printStackTrace();
        }
        catch (IOException e) {
            e.printStackTrace();
        }
    }
public void send(String msg){
        pw.println(msg); 
        pw.flush();
    }
public void stopnet(){
        try{
              br.close();
              pw.close();
              s.close();
        }
        catch (NumberFormatException e){
            e.printStackTrace();
        }
        catch (UnknownHostException e){
            e.printStackTrace();
        }
        catch (IOException e) {
            e.printStackTrace();
        }
    }

- Det fungere udemærket, men nu vil jeg gerne have et recieve loop til at køre i baggrunden, så derfor opretter den tråden:

package Main;

import java.net.*;
import java.io.*;
import Main.Client;

public class recvNet extends Thread
{
    public void run(){
        String line;
        while(true){
            //Modtag kommando fra serveren, og put i line.
            //Tjek om line betyder noget, og gør dit og dat.
        }
    }
}

- Men er lidt blank nu, hvordan overføre jeg socket, så den kan lytte på den socket, i den nye tråd?

Jeg har nu fået tråden bygget sådan her sammen:
/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/

package Main;

import java.io.*;
import java.net.*;
import Main.Client;

public class recvNet extends Thread
{
    Socket b;
   
    recvNet(Socket s){
      b=s;
    }
    public void run(){
        System.out.print("Tråd startet med socket: "+b);
        try{               
            BufferedReader br = new BufferedReader(new InputStreamReader(b.getInputStream()));
            while(true){
                System.out.print("Modtog: "+br.readLine());
            }               
        }
        catch (NumberFormatException e){           
            e.printStackTrace();       
        }
        catch (UnknownHostException e) {           
            e.printStackTrace();
        }
        catch (IOException e){           
            e.printStackTrace();       
        }
    }
}


- Men jeg modtager intet fra serveren, på trods af at serveren sender afsted :S

Neeeej, problemet er løst .. Det var mig, som havde glemt at få flush efter beskeden hos serveren.

Men, hvordan undgår jeg en masse grimme fejlmeddelser på serveren hvis klienten lukker webbrowseren? Og hvordan får jeg serveren til at skrive en besked til en bestemt klient?

Hvis serveren mister forbindelse til en client så skal du catch den exception.

Hvis serveren skal skrive til bestemte klienter, så skal den have referencer til dem.

Følgende eksempel sender til alle klienter:

import java.io.*;
import java.net.*;

public class Server {
    public static void main(String[] args) {
        try {
            ServerSocket ss = new ServerSocket(9999);
            while(true) {
                Socket s = ss.accept();
                ClientHandler cli = new ClientHandler(s);
                cli.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

class ClientHandler extends Thread {
    private BufferedReader br;
    private PrintWriter pw;
    public ClientHandler(Socket s) {
        try {
            br = new BufferedReader(new InputStreamReader(s.getInputStream()));
            pw = new PrintWriter(s.getOutputStream(), true);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public void run() {
        try {
            String line;
            while((line = br.readLine()) != null) {
                System.out.println(line);
                pw.println(line);
                pw.flush();
            }
        } catch (IOException e) {
            // nothing
        } finally {
            System.out.println("Client leaving");
        }
    }
}

Hvis klienter har et navn, så kan det nemt modificeres til at sende til en bestemt klient.

Hvor er det nøjagtigt at den sender til alle? Kan ikke lige spotte, hvad forskellen er mellem mit og dit ..

Hm, den sender ikke til alle klienterne, de andre applets, modtager intet .. Hm .. Og det går egentlig ret langsomt, i forhold til min server i C++ ..

Sorry - forkert kode - her er den rigtige:

import java.io.*;
import java.net.*;
import java.util.*;

public class Server {
    public static void main(String[] args) {
        try {
            List lst = new ArrayList();
            ServerSocket ss = new ServerSocket(12345);
            while(true) {
                Socket s = ss.accept();
                ClientHandler cli = new ClientHandler(s, lst);
                cli.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

class ClientHandler extends Thread {
    private Socket s;
    private BufferedReader br;
    private PrintWriter pw;
    private List lst;
    private String user;
    public ClientHandler(Socket s, List lst) {
        try {
            this.s = s;
            br = new BufferedReader(new InputStreamReader(s.getInputStream()));
            pw = new PrintWriter(s.getOutputStream(), true);
            this.lst = lst;
            user = "not logged in";
            lst.add(this);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public void run() {
        try {
            String line;
            while((line = br.readLine()) != null) {
                if(line.substring(0,6).equals("LOGIN ")) {
                    user = line.substring(6);
                    System.out.println(user + " login");
                } else if(line.substring(0,5).equals("SEND ")) {
                    String msg = line.substring(5);
                    for(int i = 0; i < lst.size(); i++) {
                        ClientHandler cli = (ClientHandler)lst.get(i);
                        if(cli != this) {
                            cli.send(msg);
                            System.out.println(msg + " send to " + cli.user);
                        }
                    }
                } else {
                    System.out.println("Unknown command : " + line);
                }
            }
        } catch (IOException e) {
            // nothing
        } finally {
            lst.remove(this);
        }
    }
    public void send(String msg) {
        pw.println(msg);
    }
}

Det fungere udemærket, men ved ikke om det blot er mig, men synes at en C++ server kører betydentligvis hurtigere end javaserver .. Er det bare mig?

Hov, og endnu en fejl, den sender kun beskeden hver anden gang .. Hvis man benytter send("streng"), sender den kun hver anden gang.

Der burde ikke være nogen nævneværdig forskel på dette Java program og et tilsvarende
C++ program.

Flaskehalsen er netværks delen.

Da jeg testede sendet den hver gang.

Når jeg kigger lidt på koden syne sjeg dog at der mangler et flush kald. Prøv evt. med det.

Jeg forsøgte faktisk med flush her i går middags, det virkede hurtigere, men løste ikke problemet, men jeg begav mig ud i at skrive det hele forfra, med stor inspiration fra dit eksempel, og der løste problemet sig selv.. Så nu virker det hele korrekt :) Du må gerne ligge et svar.

svar