TCP实现聊天

package edu.wtbu;

import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

public class Demo02 {
    /*
    通信协议
      协议：约定，比如我们都在讲普通话，所以我们可以沟通
      网络通信协议：速率，传输码率，代码结构，传输控制

    TCP/IP协议簇：实际上是一组协议
      重要的协议：
        TCP：用户传输协议
        UDP：用户数据报协议
      出名的协议:
        TCP:用户传输协议
        IP:网络互连协议
      TCP/IP四层模型：应用层，传输层，网络层，数据链路层

      TCP和UDP的对比
        TCP:打电话
          连接，稳定
          三次握手，四次挥手：
          三次握手：最少需要三次，保证稳定连接
          A：你愁啥？
          B：瞅你咋地？
          A：干一场！

          四次挥手：
          A：我们分手吧！
          B：你真的要分手吗？
          B：你真的真的要分手吗？
          A：我真的要分手了！

          客户端:1.连接服务器Socket   2.发送消息
          服务端:1.建立服务的端口ServerSocket   2.等待用户的连接accept   3.接收用户的消息
          传输完成，释放连接，效率低
        UDP:发短信
          不连接，不稳定
          客户端，服务端，没有明确的界限
          不管有没有准备好，都可以发给你
     */

    //客户端
    public static void main(String[] args) throws IOException {
        OutputStream os=null;
        Socket socket=null;
        try {
            //1.要知道服务器的地址和端口号
            InetAddress serverIp = InetAddress.getByName("127.0.0.1");
            int port=8888;

            //2.创建一个socket连接
             socket = new Socket(serverIp,port);

            //3.发送消息IO流
             os = socket.getOutputStream();
             os.write("你好".getBytes());

        } catch (UnknownHostException e) {
            throw new RuntimeException(e);
        }finally {
            if(os!=null){
                try {
                    os.close();
                }catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
            if(socket!=null){
                try {
                    socket.close();
                }catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
        }
    }

}

package edu.wtbu;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

//服务器
public class Demo03 {
    public static void main(String[] args) {
        ServerSocket serverSocket=null;
        Socket socket=null;
        InputStream is=null;
        ByteArrayOutputStream baos=null;
        try {
            //1.服务器必须得有一个地址
             serverSocket = new ServerSocket(8888);

            //2.等待客户端连接
             socket = serverSocket.accept();

            //3.读取客户端信息
             is = socket.getInputStream();

            //管道流
             baos = new ByteArrayOutputStream();
            byte[] buffer = new byte[1024];
            int len;
            while ((len=is.read(buffer))!=-1){
                baos.write(buffer,0,len);
            }
            System.out.println(baos.toString());

        } catch (IOException e) {
            throw new RuntimeException(e);
        }finally {
            if(baos!=null){
                try {
                    baos.close();
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
            if(baos!=null){
                try {
                    is.close();
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
            if(baos!=null){
                try {
                    socket.close();
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
            if(baos!=null){
                try {
                    serverSocket.close();
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
        }
    }
}