服务器端代码
package teststock;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class Server2 {
public static void main(String[] args) {
try {
ServerSocket server = new ServerSocket(5678);
Socket client = server.accept();
System.out.println("接收到客户端的请求");
BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
PrintWriter out = new PrintWriter(client.getOutputStream());
while(true){
String str = in.readLine();
System.out.println(str);
out.print("has receive...");
out.flush();
if(str.toLowerCase().equals("end")){
break;
}
}
client.close();
} catch (Exception e) {
// TODO: handle exception
}
}
}
客户端代码
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
public class Client2 {
static Socket socket;
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
try {
socket = new Socket(InetAddress.getLocalHost(),5678);
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream());
BufferedReader wt = new BufferedReader(new InputStreamReader(System.in));
while(true){
String str = wt.readLine();
System.out.println("客户端输入"+str);
out.print(str);
out.flush();
if(str.toLowerCase().equals("end")){
break;
}
// System.out.println(in.readLine());
}
socket.close();
} catch (Exception e) {
// TODO: handle exception
}
}
}
java socket客户端向服务器端发送消息,可以使用socket类,实例如下: