[java] socket lezen schrijven - Softwareontwikkeling

maandag 9 juni 2003 14:41

Acties:

Topicstarter

Hallo,

Ik ben nu al een tijdje bezig met een client / server maar zit toch met iets waar ik nog steeds niet uit kom.

Ik maak gebruik van DataSockets, overstappen op corba/rmi/objectsockets heeft geen zin meer ivm met tijd

.

Het zit zo:

De client heeft een thread die luisterd naar de socket. Hij ontvangt ook de data goed enzo.

Maar nu wil ik bijvoorbeeld dat er wat naar de server gestuurt word, en er een hele string terug gestuurt word en die wil ik opvangen gelijk in die methode die ook de opdracht verstuurde. Maar als ik dan de run() methode ff stop met de while lus false te maken dan loopt de gui ook vast en krijg niet altijd de data dan binnen.:(

Het gaat dan nu vooral om de getPlayers() methode.

Die stuurt "15" naar de server en die stuurt dan naar de client een lijst met ip adressen. Maar ik wil dus in die methode zelf die lijst ontvangen en niet in de run() methode. Hij roept eerst send(String) aan en daarna print hij read() op het scherm, maar dat werkt dus niet

Wat moet ik dan anders doen?

Al vast bedankt.

Java:

import java.net.*;
import java.io.*;
import java.util.*;
import java.lang.*;
import javax.swing.*;

public class Link extends Thread implements Runnable,ConstantsClient{

//private Client client;
private DataInputStream in;
private DataOutputStream out;
private Socket socket;
private JFrame frame;
private boolean running = true;
//private listener list;
private String rmsg; 

    public Link(JFrame frame){
        
        //this.client = client;
        try {
            try{
        
        this.frame = frame;
        this.socket = new Socket("127.0.0.1",10);
        in = new DataInputStream(new BufferedInputStream(this.socket.getInputStream()));
        out = new DataOutputStream(new BufferedOutputStream(this.socket.getOutputStream()));

        }catch(UnknownHostException e){}
        }catch(IOException e){}
        
    }
    
    public void send(String msg){
    
            try{
            out.writeUTF(msg);
            out.flush();
            }catch(IOException e){}
            System.out.println("out: "+msg);
    }
    
    public Set getPlayers(){
        Set b = new HashSet();
        running = false;
        send("15");
        System.out.println("READER: "+read());
        return b;
      }
        
        
    public String read(){
            running = false;
            String m = null;
            try{
                //try{
                //wait(100);
                m = in.readUTF();
                if ( m != null) {
                    System.out.println("READ:"+m );
                    
                }
                }catch(IOException e){}
                running = true;
        return m;
    }   
                        
    
        public void run(){
            
        while (running) {
            try{
                System.out.println("listening started");
                String m = in.readUTF();
                if ( m != null) {
                    rmsg = m; 
                    System.out.println("Net in:"+m );
                    
                    if (m.indexOf("83") == 0){
                        
                        Object[] options = {"OK"};
                        int n = JOptionPane.showOptionDialog(frame,
                        "battleship met " + m.substring(2),
                        "Verzoek tot spelen",
                        JOptionPane.OK_OPTION,
                        JOptionPane.WARNING_MESSAGE,
                        null,
                        options,
                        options[0]);
                    
                    
                    }               
                    
                    if (m.indexOf("66")==0){
                        
                        System.out.println("raak");
                    }
            } 
                        
            }catch(IOException e){}
        }   
    }
}

[ Voor 15% gewijzigd door eppie op 09-06-2003 15:03 ]

maandag 9 juni 2003 14:56

Acties:

curry684

left part of the evil twins

Met [code=java] krijg je zoals je ziet gratis correcte syntax-highlighting

Daarnaast: zijn al die 131 regels code relevant?

Let wel dat mensen minder geneigd zijn 131 regels code voor je door te lezen dan 10, dus probeer even te schrappen zodat er alleen echt relevante code voor je probleem overblijft.

[ Voor 3% gewijzigd door curry684 op 09-06-2003 14:57 . Reden: oeps ]

Professionele website nodig?

maandag 9 juni 2003 15:02

Acties:

ACM

Software Architect

Werkt hier

Ik gok erop dat het probleem erin zit dat de run-methode nog bij de readUTF staat te wachten op input, terwijl jij er vanuit gaat dat op het moment dat je zegt running=false ie dan ineens uit die while stapt?

Hoe op te lossen? Zou ik zo niet weten, ik denk dat je het best de readUTF maar op één plaats kan aanroepen en dus ook de afhandeling van de in- en output op één plaats (daar heb je heel die running-methode voor tenslotte).

Btw, met de ObjectStream kan je misschien veel makkelijker en mooier messages oversturen. Bijvoorbeeld door een Message-klasse te maken en daarin o.a. een string en een message-id ofzo te stoppen. Die hoef je om over te sturen alleen nog Serializable te definieren.

maandag 9 juni 2003 15:15

Acties:

eppie

Topicstarter

Bedankt voor de snelle reply's.
Nou ik heb de code aangepast en nu krijgt heel soms de data binnen andere keren niet.

ObjectStream heb ik al is vaker na gekeken, maar ik kan nergens een goeie uitleg over hoe je die gebruikt vinden

En dan hou je het probleem van waar je de stream wil uitkunnne lezen nog

Java:

import java.net.*;
import java.io.*;
import java.util.*;
import java.lang.*;
import javax.swing.*;

public class Link extends Thread implements Runnable,ConstantsClient{

//private Client client;
private DataInputStream in;
private DataOutputStream out;
private Socket socket;
private JFrame frame;
private boolean running = true;
//private listener list;
private String rmsg; 



    public Link(JFrame frame){
        
        //this.client = client;
        try {
            try{
        
        this.frame = frame;
        this.socket = new Socket("127.0.0.1",10);
        in = new DataInputStream(new BufferedInputStream(this.socket.getInputStream()));
        out = new DataOutputStream(new BufferedOutputStream(this.socket.getOutputStream()));

        }catch(UnknownHostException e){}
        }catch(IOException e){}
        
    }
    
    public void send(String msg){
    
            try{
            out.writeUTF(msg);
            out.flush();
            }catch(IOException e){}
            System.out.println("out: "+msg);
    }
    
        
    
    public Set getPlayers(){
        Set b = new HashSet();
        running = false;
        send("15");
        System.out.println("READER: "+read());
        return b;
      }
        
        
    public String read(){
            running = false;
            String m = null;
            try{
                //try{
                //wait(100);
                m = in.readUTF();
                if ( m != null) {
                    System.out.println("READ:"+m );
                    
                }
                }catch(IOException e){}
                running = true;
        return m;
    }   
                        
    
        public void run(){
            
        while (running) {
            
                System.out.println("listening started");
                String m = read();
                if ( m != null) {
                    rmsg = m; 
                    System.out.println("Net in:"+m );
                    
                    if (m.indexOf("83") == 0){
                        
                        Object[] options = {"OK"};
                        int n = JOptionPane.showOptionDialog(frame,
                        "battleship met " + m.substring(2),
                        "Verzoek tot spelen",
                        JOptionPane.OK_OPTION,
                        JOptionPane.WARNING_MESSAGE,
                        null,
                        options,
                        options[0]);
                    
                    
                    }               
                    
                    if (m.indexOf("66")==0){
                        
                        System.out.println("raak");
                    }
                } 
                        
            m = null;
            
            }   
    

}




}

Sorry, had niet gezien dat ik alle code weer geplakt had

Heb ff wat weggehaald

[ Voor 18% gewijzigd door eppie op 09-06-2003 15:54 ]

maandag 9 juni 2003 15:32

Acties:

curry684

left part of the evil twins

Uhm no offence maar nog 1 keer een lap van 140 regels code in dit topic en hij gaat dicht wegens enorme spam. Beperk je tot het relevante aub

Professionele website nodig?

maandag 9 juni 2003 17:41

Acties:

Feyd-Rautha

misschien kan ik ook nog iets bijbrengen (ik heb het topic nog niet doorlezen). Ik zie reeds een opmerking die ik kan geven over uw code

als je overerft van de class Thread, moet je de Interface 'runnable' niet meer implementeren hoor. Het is overerven van thread, of implementeren van runnable.

voordeel van overerfen van Thread, is dat je al de methods in de classe thread ook kunt gebruiken zoals Interrupt() enzo ...
Als je de interface 'runnable' implementeert, dan zul je enkel de method run() moeten specificeren.

En idd, post eens wat relevante code

[ Voor 27% gewijzigd door Feyd-Rautha op 09-06-2003 17:43 ]

I must not fear. Fear is the mind-killer. Fear is the little-death that brings total obliteration. I will face my fear. I will permit it to pass over me and through me. Where the fear has gone there will be nothing. Only I will remain.