關(guān)于java socket的問題

2019-11-18 13:52:15

字體：大中小

供稿：網(wǎng)友

要做成這樣的：

客戶端訪問服務(wù)器ip和port，服務(wù)器馬上發(fā)送welcome消息，然后客戶端根據(jù)welcome消息判定是否是想要連接的服務(wù)器和端口，

假如是則開始發(fā)送數(shù)據(jù)，數(shù)據(jù)包括開始和結(jié)束的校驗(yàn)。服務(wù)器端發(fā)送welcome消息后開始接收數(shù)據(jù)，直到結(jié)束。蠻簡(jiǎn)單的事TMD我怎么就搞不定。

CLIENT：

package com.ces.mytest.socket;

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

public class ClientThread extends Thread {    PRivate String ipStr = "";    private int port;    public ClientThread(String ipStr, int port) {        this.ipStr = ipStr;        this.port = port;    }

    public void run() {        try {            Socket client = new Socket(ipStr, port);            BufferedReader read = new BufferedReader(new InputStreamReader(client.getInputStream()));            BufferedWriter write = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));

            if ("歡迎".equals(read.readLine())) {                System.out.println("校驗(yàn)正確");

                write.write("開始");                write.newLine();                write.write("數(shù)據(jù)");                write.newLine();                write.write("結(jié)束");                write.newLine();                write.flush();

                System.out.println("發(fā)送完畢");            }

            write.close();            read.close();            client.close();        } catch (UnknownHostException ex) {            ex.printStackTrace();        } catch (IOException ex) {            ex.printStackTrace();        }    }

    public static void main(String[] args) {        Thread client = new ClientThread("127.0.0.1",10020);        client.start();    }

}

SERVER：

package com.ces.mytest.socket;

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

public class ServerThread extends Thread {    private int port;    public ServerThread(int port) {        this.port = port;    }

    private boolean stop = false;

    public void run() {        try {            ServerSocket server = new ServerSocket(port);            while (!stop) {                Socket client = server.accept();                BufferedReader read = new BufferedReader(new InputStreamReader(client.getInputStream()));                BufferedWriter write = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));                                System.out.println("發(fā)送歡迎信息");                                write.write("歡迎");                write.flush();

//                String lineStr = read.readLine();//                if ("開始".equals(lineStr)) {//                    System.out.println("開始接受數(shù)據(jù)！");////                    while (true) {//                        lineStr = read.readLine();//                        if ("結(jié)束".equals(lineStr)) {//                            break;//                        } else {//                            System.out.println("數(shù)據(jù)是" + lineStr);//                        }//                    }//                }

                write.close();                read.close();                client.close();            }

        } catch (IOException ex) {            ex.printStackTrace();        }    }

    public static void main(String[] args) {        Thread server = new ServerThread(10020);        server.start();    }

    public boolean isStop() {        return stop;    }

    pu

上一篇：關(guān)于JAVA　import 的一個(gè)小問題

下一篇：關(guān)于cachedRowSet的一篇文章(java.sun.com)