java中TCP/UDP详细总结

所属分类: 软件编程 / java 阅读数: 26
收藏 0 赞 0 分享

TCP/UDP:TCP主要是面向连接的协议,它包含有建立和拆除连接,保证数据流的顺序和正确性等功能。

每次对TCP中间的数据操作相当于对一个数据流进行访问。它最典型的特征就是那三次握手的建立连接过程。Server端所要做的事情主要是建立一个通信的端点,然后等待客户端发送的请求。典型的处理步骤如下:

1. 构建一个ServerSocket实例,指定本地的端口。这个socket就是用来监听指定端口的连接请求的。

2.重复如下几个步骤:

a. 调用socket的accept()方法来获得下面客户端的连接请求。通过accept()方法返回的socket实例,建立了一个和客户端的新连接。

b.通过这个返回的socket实例获取InputStream和OutputStream,可以通过这两个stream来分别读和写数据。

c.结束的时候调用socket实例的close()方法关闭socket连接。

TCP服务器端:

public class TCPServer {
  public static void main(String[] args){
      try{
        ServerSocket server=new ServerSocket();
        SocketAddress address=new InetSocketAddress(InetAddress.getLocalHost(),10001);
        server.bind(address);
        System.out.println("等待连接客户端...");
        Socket client = server.accept();
        System.out.println("connected with"+client.getRemoteSocketAddress());
        PrintWriter socketOut = new PrintWriter(client.getOutputStream());
        System.out.println("等待客户端的消息...");
        byte buf[] = new byte[1024];
        if ( client.getInputStream().read(buf) > 0 ) {
          System.out.println("收到的消息: " + new String(buf));
        }
        System.out.println("发送消息给客户端...");
        String sendStr = "服务器返回的信息";
        socketOut.write(sendStr);
        socketOut.flush();
        socketOut.close();
        client.close();
        server.close();
      }catch (IOException e) {
        System.out.println(e.getMessage());
        e.printStackTrace();
      }
  }
}

TCP客户端:

1.构建Socket实例,通过指定的远程服务器地址和端口来建立连接。

2.通过Socket实例包含的InputStream和OutputStream来进行数据的读写。

3.操作结束后调用socket实例的close方法,关闭。

public class TCPClient {
  public static void main(String[] args){
    try{
      final Socket socket = new Socket();
      SocketAddress address = new InetSocketAddress(InetAddress.getLocalHost(), 10001);
      System.out.println("连接服务端 ...");
      socket.connect(address);
      PrintWriter socketOut = new PrintWriter(socket.getOutputStream());
      BufferedReader socketIn = new BufferedReader(
          new InputStreamReader(socket.getInputStream()) );
      String sendStr = "客户端发送的消息";
      System.out.println("发送消息给服务端 ...");
      socketOut.write(sendStr);
      socketOut.flush();
      System.out.println("等待服务端的消息 ...");
      String receiveStr = socketIn.readLine();
      System.out.println("收到的消息: " + receiveStr);      
      socketOut.close();
      socketIn.close();
      socket.close();
    }catch (IOException e) {
      System.out.println(e.getMessage());
      e.printStackTrace();
    }
  }
}

UDP(User Datagram Protocol,用户数据报协议)

UDP和TCP有两个典型的区别,一个就是它不需要建立连接,另外就是它在每次收发的报文都保留了消息的边界。

因为UDP协议不需要建立连接,它的过程如下:

1. 构造DatagramSocket实例,指定本地端口。

2. 通过DatagramSocket实例的receive方法接收DatagramPacket.DatagramPacket中间就包含了通信的内容。

3. 通过DatagramSocket的send和receive方法来收和发DatagramPacket.

public class UDPServer {
  public static void main(String args[]) {
    DatagramSocket socket = null;
    DatagramPacket datapacket = null;
    InetSocketAddress address = null;
    try {
      address = new InetSocketAddress(InetAddress.getLocalHost(), 7778);
      socket = new DatagramSocket(address);
      // socket.bind(address);
      byte buf[] = new byte[1024];
      datapacket = new DatagramPacket(buf, buf.length);
      System.out.println("block for receive messages...");
      socket.receive(datapacket);
      buf = datapacket.getData();
      InetAddress addr = datapacket.getAddress();
      int port = datapacket.getPort();
      System.out.println("Message Content: " + new String(buf) );
      System.out.println("Receive From " + addr + ":" + port);      
      SocketAddress toAddress = datapacket.getSocketAddress();
      String sendStr = "I'm Server, this is the message for client.";
      buf = sendStr.getBytes();
      datapacket = new DatagramPacket(buf, buf.length);
      datapacket.setSocketAddress(toAddress);
      socket.send(datapacket);
      System.out.println("message sended");
     //释放资源 
      socket.close(); 
    } catch (UnknownHostException e) {
      e.printStackTrace();
    } catch (SocketException e) {
      e.printStackTrace();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
}

UDP客户端的步骤也比较简单,主要包括下面3步:

1. 构造DatagramSocket实例。

2.通过DatagramSocket实例的send和receive方法发送DatagramPacket报文。

3.结束后,调用DatagramSocket的close方法关闭。

因为和TCP不同,UDP发送报文的时候可以在同一个本地端口随意发送给不同的服务器,一般不需要在UDP的DatagramSocket的构造函数中指定目的服务器的地址。

另外,UDP客户端还有一个重要的不同就是,TCP客户端发送echo连接消息之后会在调用read方法的时候进入阻塞状态,而UDP这样却不行。因为UDP中间是可以允许报文丢失的。如果报文丢失了,进程一直在阻塞或者挂起的状态,则进程会永远没法往下走了。

所以会一般设置一个setSoTimeout方法,指定在多久的时间内没有收到报文就放弃。也可以通过指定一个数字,循环指定的次数来读取报文,读到就返回,否则就放弃。

public class UDPClient {
  public static void main(String args[]) {
    try {
      DatagramSocket getSocket = new DatagramSocket();
      DatagramPacket datapacket = null;
      InetSocketAddress toAddress = new InetSocketAddress(InetAddress.getLocalHost(), 7778);   
      String sendStr = "I'm client, this is the message for server.";
      byte buf[] = sendStr.getBytes();
      datapacket = new DatagramPacket(buf, buf.length);
      datapacket.setSocketAddress(toAddress);
      getSocket.send(datapacket);
      System.out.println("message sended");
      System.out.println("block for receive messages...");
      getSocket.receive(datapacket);
      buf = datapacket.getData();
      System.out.println("Message Content: " + new String(buf));
      getSocket.close(); 
    } catch (SocketException e) {
      e.printStackTrace();
    } catch (UnknownHostException e) {
      e.printStackTrace();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
}

以上内容,需要的朋友可以参考

更多精彩内容其他人还在看

Java的面向对象编程基本概念学习笔记整理

这篇文章主要介绍了Java的面向对象编程基本概念学习笔记整理,包括类与方法以及多态等支持面向对象语言中的重要特点,需要的朋友可以参考下
收藏 0 赞 0 分享

Eclipse下编写java程序突然不会自动生成R.java文件和包的解决办法

这篇文章主要介绍了Eclipse下编写java程序突然不会自动生成R.java文件和包的解决办法 的相关资料,需要的朋友可以参考下
收藏 0 赞 0 分享

基于Java实现杨辉三角 LeetCode Pascal's Triangle

这篇文章主要介绍了基于Java实现杨辉三角 LeetCode Pascal's Triangle的相关资料,需要的朋友可以参考下
收藏 0 赞 0 分享

Java中Spring获取bean方法小结

Spring是一个轻量级的控制反转(IoC)和面向切面(AOP)的容器框架,如何在程序中获取Spring配置的bean呢?下面通过本文给大家介绍Java中Spring获取bean方法小结,对spring获取bean方法相关知识感兴趣的朋友一起学习吧
收藏 0 赞 0 分享

如何计算Java对象占用了多少空间?

在Java中没有sizeof运算符,所以没办法知道一个对象到底占用了多大的空间,但是在分配对象的时候会有一些基本的规则,我们根据这些规则大致能判断出来对象大小,需要的朋友可以参考下
收藏 0 赞 0 分享

剖析Java中的事件处理与异常处理机制

这篇文章主要介绍了Java中的事件处理与异常处理机制,讲解Java是如何对事件或者异常作出响应以及定义异常的一些方法,需要的朋友可以参考下
收藏 0 赞 0 分享

详解Java的Struts2框架的结构及其数据转移方式

这篇文章主要介绍了详解Java的Struts2框架的结构及其数据转移方式,Struts框架是Java的SSH三大web开发框架之一,需要的朋友可以参考下
收藏 0 赞 0 分享

Java封装好的mail包发送电子邮件的类

本文给大家分享了2个java封装好的mail包发送电子邮件的类,并附上使用方法,小伙伴们可以根据自己的需求自由选择。
收藏 0 赞 0 分享

在Java的Struts中判断是否调用AJAX及用拦截器对其优化

这篇文章主要介绍了在Java的Struts中判断是否调用AJAX及用拦截器对其优化的方法,Struts框架是Java的SSH三大web开发框架之一,需要的朋友可以参考下
收藏 0 赞 0 分享

java多线程Future和Callable类示例分享

JAVA多线程实现方式主要有三种:继承Thread类、实现Runnable接口、使用ExecutorService、Callable、Future实现有返回结果的多线程。其中前两种方式线程执行完后都没有返回值,只有最后一种是带返回值的。今天我们就来研究下Future和Callab
收藏 0 赞 0 分享
查看更多