java socket 单客户端实例代码

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

public class server {
public static void main(String [] args) throws Exception { //声明抛出异常
//创建服务端的socket实例
ServerSocket server = new ServerSocket(2345);
//阻塞 监听端口的连接，如果有连接则创建socket实例
Socket client = server.accept();
//声明接收(输入流)实例 接收来自客户端的数据
BufferedReader read = new BufferedReader( new InputStreamReader( client.getInputStream()));
//声明发送(输出流)实例 将数据发送至连接的客户端
PrintWriter write = new PrintWriter( client.getOutputStream());

//无限的执行请求
while( true ) {
//监听从客户端接收到的信息 如果有则读入一行
String str = read.readLine();
System.out.println("从客户端接收到：" + str);
//向socket客户端发送信息
write.println("这是来自服务端的信息：" + str);
write.flush(); //刷新输出缓冲
//如果接收的是end 退出。
if(str.equals("end")) break;
}
write.close(); //关闭发送
read.close(); //关闭接收
}
}

import java.io.*;
import java.net.*;
public class client {
public static void main(String [] arsg) throws Exception {
//创建客户端实例
Socket client = new Socket( InetAddress.getLocalHost(), 2345);
//声明接收(输入流)
BufferedReader read = new BufferedReader( new InputStreamReader( client.getInputStream()));
//声明发送(输出流)
PrintWriter write = new PrintWriter( client.getOutputStream());
//声明键盘输入流
BufferedReader kbread = new BufferedReader( new InputStreamReader( System.in ));

while( true ) {
//从键盘获取一行输入
String str = kbread.readLine();
//发送
write.println(str);
write.flush();
if(str.equals("end")) break;
System.out.println(read.readLine()); //获取一次返回
}
System.out.println("退出连接!");
read.close();
write.close();

}
}