public class SocketTCP01Server {public static void main(String[] args) throws IOException {/**1.在本机的 9999 端口监听 ,等待连接细节: 要求在本机没有其他服务在监听999细节:这个ServerSocket 可以通过accept()返回多个Socket[多个客户端连接服务求的并发]*/ServerSocket serverSocket = new ServerSocket(9999);System.out.println("服务端,在9999端口监听,等待连接...");/**当没有客户端连接9999端口时,在9999端口阻塞,等待连接*如果有客户端连接,则会返回Socket对象,程序连接*/Socket socket =serverSocket.accept();System.out.println("Socket="+socket.getClass());/**3.通过socket.getInputStream()获取* 客户端写入到数据通道的数据,显示*/InputStream inputStream = socket.getInputStream();//4.IO获取byte[] buf =new byte[1024];int readlen = 0;while((readlen=inputStream.read(buf))!=-1){System.out.println(new String(buf,0,readlen));//根据实际}inputStream.close();socket.close();serverSocket.close();System.out.println("服务器端退出~");}
}
//客户端,发送“hello,server”给服务端
public class SocketTCP01Client {public static void main(String[] args) throws IOException {//1.连接服务器(ip,端口)Socket socket = new Socket(InetAddress.getLocalHost(),9999);System.out.println("客户端 socekt返回="+socket.getClass());//2.连接上后,生成Socket,通过socket.getOutputStream()//得到 和 socket 对象关联的输出流对象OutputStream outputStream = socket.getOutputStream();//3.通过输出流,写入数据到 数据通道outputStream.write("hello server".getBytes());//4.关闭流对象和socket,必须关闭outputStream.close();socket.close();System.out.println("客户端退出~");}
}