To do this:
The client access server IP and Port, the server immediately sends a Welcome message, and the client determines if the Welcome message is determined whether it is the server and port you want to connect.
If it is, the data is started, and the data includes the start and end check. The server is sent to the Welcome message and start receiving data until the end. It's a very simple thing TMD, I am not engaged.
Client:
Package com.cs.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 ("Welcome" .Equals (read.readline ())) {system.out.println ("Check the correct");
Write.Write ("Start"); Write.Write ("Data"); Write.Newline (); Write.write ("End"); Write.Newline (); write.flush () ;
System.out.println ("Send");
Write.close (); read.close (); client.close ();} catch (unknownhostException ex);} catch (ooException ex) {ex.printstacktrace ();}}
Public static void main (string [] args) {thread client = new clientthread ("127.0.0.1", 10020); client.start ();
}
Server:
Package com.cs.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 (Client.getStreamWriter ()); System.out.Println ("Send Welcome Information"); Write.write ("Welcome"); Write.flush ();
// String linestr = read.readline (); // if ("Start" .Equals (linestr)) {// system.out.println ("Start Accept Data!"); //// While (TRUE) { // Linestr = read.readline (); // if ("End" .Equals (linestr)) {// BREAK; //} else {// system.out.println ("data" 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 () {returnit.
Public void setStop (Boolean Stop) {this.stop = stop;}}
