- 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("客户端退出~");
- }
- }