package com.test.socket;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
/**
* socket 简单一对一通讯 服务器
* @author Administrator
*
*/
public class Server {
public static void main(String[] args) throws Exception{
/**绑定端口**/
ServerSocket server = new ServerSocket(8080);
/**接受客户端请求**/
Socket client = server.accept();
/**用语读取客户端发来的信息**/
BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
/**用语返回客户端的响应**/
PrintWriter out = new PrintWriter(client.getOutputStream());
while(true){
String message = in.readLine();
System.out.println(“receive:”+message);
out.println(“has received”);
out.flush();
if(message.equals(“bye”)){
break;
}
}
client.close();
}
}
package com.test.socket;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
/**
* socket 简单一对一通讯 客户端
* @author Administrator
*
*/
public class Client {
public static void main(String[] args) throws Exception {
/**连接服务器**/
Socket server = new Socket(“127.0.0.1”,8080);
/**用于读取服务器信息**/
BufferedReader in = new BufferedReader(new InputStreamReader(server.getInputStream()));
/**用于向客户端输出信息**/
PrintWriter out = new PrintWriter(server.getOutputStream());
/**用于读取键盘输入流**/
InputStreamReader inputstremreader = new InputStreamReader(System.in);
BufferedReader br = new BufferedReader(inputstremreader);
while(true){
String s = br.readLine();
out.println(s);
out.flush();
if(s.equals(“bye”)){
break;
}
System.out.println(in.readLine());
}
server.close();
}
}
//启动dos窗口编译执行代码Server.java 和 Client.java进行测试,可以实现