TCP编程案例

发布于:2024-12-06 ⋅ 阅读:(128) ⋅ 点赞:(0)

笔记:(本题可能需要的)

TCP协议:

TCP协议进行通信的两个应用进程:客户端、服务端。

使用TCP协议前,须先建立TCP连接,形成基于字节流的传输数据通道

传输前,采用“三次握手”方式,点对点通信,是可靠的

传输完毕,需释放已建立的连接,效率低

在发送数据的准备阶段,客户端与服务器之间的三次交互,以保证连接的可靠

在发送数据结束后,释放连接时需要经过四次挥手

Socket类

网络上具有唯一标识的IP地址和端口号组合在一起构成唯一能识别的标识符套接字(Socket)

Socket相关类API

   ServerSocket类

ServerSocket类的构造方法:

ServerSocket(int port) :创建绑定到特定端口的服务器套接字。

ServerSocket类的常用方法:

Socket accept():侦听并接受到此套接字的连接。

     Socket类

Socket类的常用构造方法

public Socket(InetAddress address,int port):创建一个流套接字并将其连接到指定 IP 地址的指定端口号。

public Socket(String host,int port):创建一个流套接字并将其连接到指定主机上的指定端口号。

   Socket类的常用方法

public InputStream getInputStream():返回此套接字的输入流,可以用于接收消息

public OutputStream getOutputStream():返回此套接字的输出流,可以用于发送消息

public void close():关闭此套接字。套接字被关闭后,便不可在以后的网络连接中使用(即无法重新连接或重新绑定)。需要创建新的套接字对象。 关闭此套接字也将会关闭该套接字的 InputStream 和 OutputStream。

例题1:客户端发送内容给服务端,服务端将内容打印到控制台上。
     注意点:先启动服务端,在启动客户端
           这里的IP地址和端口号使用自己电脑的
           查询IP地址:在运行框输入ipconfig
           查询端口号:在运行框输入netstas -ano
客户端创建步骤:
》1创建一个Socket
      创建一个IP地址,创建一个端口号;Socket是由IP地址和端口号组合在一起组合在一起的;----------IP地址和端口号都是服务端的
      将IP地址和端口号传入Socket构造器中,创建Socket对象(即创建一个流套接字)
》发送数据
      通过Socket对象调用getOutputStream()方法------返回此套接字的输出流
      通过输出流对象调用write()方法--------书写要发送的信息
》关闭资源(在关闭前都要判断该对象是否创建成功)
      关闭流资源
      关闭流套接字资源
  @Test// 客户端
    public void client() throws IOException {
        Socket socket = null;
        OutputStream os = null;
        try {
            //创建一个Socket
            InetAddress inetAddress = InetAddress.getByName("192.168.242.33");//声明对方的IP地址
            int port=10620;//声明对方的端口号
            socket = new Socket(inetAddress, port);
            //发送数据
            os = socket.getOutputStream();
            os.write("你好,我是客户端,请多多关照".getBytes());
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            //关闭Socket
            try {
                if(socket!=null)
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                if(os!=null)
                os.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
服务端创建步骤
》创建一个ServerSocket(即创建绑定到特定端口的服务器套接字)
》调用accept(),接受客户端的Socket
      通过前面ServerSocket的对象调用accept()方法(阻塞式方法)-----------侦听并接受到此套接字的连接。
      调用accept()方法返回的是一个Socket类的对象--------表示连接成功,接受客户端的Socket
》接收数据
      通过前面得到的Socket的对象来调用getInputStream()------------得到流对象
      通过流的对象来读取数据
》关闭资源(在关闭前都要判断该对象是否创建成功)
      关闭ServerSocket资源
      关闭Socket资源
      关闭流资源
 @Test//服务端
    public void server() throws IOException {
        ServerSocket serverSocket = null;
        Socket socket = null;//阻塞式的方法
        InputStream is = null;
        try {
            //创建一个ServerSocket
            int port=10620;
            serverSocket = new ServerSocket(port);
            //调用accept(),接受客户端的Socket
            socket = serverSocket.accept();
            //接收数据
            is = socket.getInputStream();
            byte[] buffer=new byte[1024];
            int len;
            ByteArrayOutputStream baos = new ByteArrayOutputStream();//内部维护了一个byte数组
            while ((len=is.read(buffer))!=-1){
                //错误的
//                String str = new String(buffer, 0, len);
//                System.out.println(str);
                //正确的
                baos.write(buffer,0,len);
            }
            System.out.println(baos.toString());
            System.out.println("数据接收完毕");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            //关闭Socket,ServerSocket,流
            try {
                if(socket!=null)
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                if(serverSocket!=null)
                serverSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                if(is!=null)
                is.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }