Форум программистов [Powered by Invision Power Board]

Код


public class TcpIp {
    private MainFrame main = null;
    private int port;
    private InetAddress ip = null;
    private boolean b = true;
    private ServerSocket ss = null;
    private Socket s = null;

    public TcpIp(MainFrame main, int port, InetAddress ip) {
        this.port = port;
        this.main = main;
        this.ip = ip;
    }

    public void killThread(){
        b = false;
        try {
            ss.close();
            if (s!=null){
                s.close();
            }
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }

    public void listening(){
        Thread t = new Thread(new Runnable(){
            public void run() {
                try {
                    ss = new ServerSocket(port);
                    while (b) {
                        s = ss.accept();
                        Reader in = new InputStreamReader(s.getInputStream());
                        BufferedReader buff = new BufferedReader(in);
                        String message = buff.readLine();
                        if (message != "pinging"){
                            main.console.append("Found comp:" +
                                                message + "\n");
                        }else{
                            Writer out = new OutputStreamWriter(s.getOutputStream());
                            out.write(InetAddress.getLocalHost().toString());
                            out.flush();
                        }
                        s.close();
                    }
                } catch (Exception ex) {
                    if (b) ex.printStackTrace();
                }
            }
        });
        t.setPriority(Thread.NORM_PRIORITY);
        t.start();
    }

    public void tcpPing() throws IOException {
        System.out.println(ip+", "+port);
        Socket sock = new Socket(ip, port);
        System.out.println("Opening socket....");
        main.console.append("Pinging[tcp/ip] " + ip + "\n");
        String message = "pinging";
        Writer out = new OutputStreamWriter(sock.getOutputStream());
        out.write(message);
        out.flush();
        out.close();
    }
}

Код


public class Udp {
    private int port;
    private MainFrame main = null;
    private InetAddress ip = null;
    private DatagramSocket ds = null;
    private boolean curr = true;
    private  byte[] ggg = {111};

    public Udp(MainFrame main, int port, InetAddress ip) {
        this.port = port;
        this.main = main;
        this.ip = ip;
        try {
           ds = new DatagramSocket(this.port);
        } catch (SocketException ex) {
            ex.printStackTrace();
        }
    }

    public void killThread(){
        ds.close();
        curr = false;
    }

    public void listening(){
        Thread t = new Thread(new Runnable() {
            public void run() {
                try {
                    byte[] b = new byte[30];
                    DatagramPacket dp = new DatagramPacket(b, b.length);
                    while(curr){
                        ds.receive(dp);
                        byte[] message = dp.getData();
                        if (!Arrays.equals(ggg, message)){
                            main.console.append("Found comp: " + dp.getAddress() + "\n");
                        }else{
                            dp.setData(ggg);
                            ds.send(dp);
                        }
                    }
                } catch (IOException ex) {
                    if (curr) ex.printStackTrace();
                }
            }
        });
        t.start();
    }

    public void udpPing(){
        try {
            byte[] b = new byte[30];
            main.console.append("Pinging[udp] " + ip + "\n");
            DatagramPacket dp = new DatagramPacket(b, b.length);
            dp.setSocketAddress(new InetSocketAddress(ip,port));
            dp.setData(ggg);
            ds.send(dp);
        } catch (Exception ex) {
            ex.printStackTrace();
        }

    }
}