Java基础之TCP与UDP

OSI 7层参考模型

物理层 --> 数据链路层 --> 网络层 --> 传输层 --> 会话层 --> 表示层 --> 应用层

557778.com_【官方首页】-福利彩票按此顺序称为拆包,反之为封包。

TCP/IP参考模型

主机至网络层 --> 网际层 --> 传输层 --> 应用层

IP地址:127.0.0.1默认IP,主机名是localhost,每台PC都有的

端口号:应用程序的标识

传输协议:TCP/UDP

  • UDP:不需建立连接,速度快,不可靠,可能丢包,如对讲机。可以及时通信而不管对方在不在。
  • TCP:需要建立连接。三次握手,效率稍低,可靠。不在后,停止传输。比如打电话,下载数据。

557778.com_【官方首页】-福利彩票Socket:数据在两个Socket之间通过I/O传输,通信两方都有。

TCP传输中:有一个客户端(client),有一个服务端(server),两方传输经过Socket。Socket是底层建立好了的,既可以输入又可以输出。

UDP传输例子

发送端

// 发送端
package Test;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
// 实现Runnable并覆盖run方法实现多线程
public class Send implements Runnable {
    private DatagramSocket ds;
    // 发送端和接收端都有各自的Socket来传输
    public Send(DatagramSocket ds) {
        this.ds = ds;
    }

    @Override
    public void run() {
        System.out.println("发送端启动");

        try {
          // 从键盘读入
            BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
            String line;
            while ((line = br.readLine()) != null) {
              // 读到的字符变成字节数组
                byte[] buf = line.getBytes();
              // 数据打包,传入ip地址和端口
                DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("10.175.214.114"), 10005);
              // 通过Socket传输数据包
                ds.send(dp);
              // 发送端输入88,就下线
                if (line.equals("88")) {
                    System.out.println("退出聊天");
                    break;
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            ds.close();
        }

    }
}

接收端

package Test;


import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class Rec implements Runnable {
    private DatagramSocket ds;

    public Rec(DatagramSocket ds) {
        this.ds = ds;
    }

    @Override
    public void run() {
        System.out.println("接收端启动");

        try {
            while (true) {
                byte[] buf = new byte[1024];
                DatagramPacket dp = new DatagramPacket(buf, buf.length);
              // 这个Socket指定端口号,就能收到发送端发过来的数据
                ds.receive(dp); // 阻塞式的,等待

                String ip = dp.getAddress().getHostAddress();
                int port = dp.getPort();
                String text = new String(dp.getData(), 0, dp.getLength());
                System.out.println(ip + ":" + port + ":" + text);
                if (text.equals("88")) {
                    System.out.println(ip + ": 退出聊天室");
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            ds.close();
        }
    }
}

运行试试

package Test;


import java.net.DatagramSocket;
import java.net.SocketException;

public class UDPDemo {
    public static void main(String[] args) throws SocketException {
      // 接收端和发送端有各自的Socket
        DatagramSocket se = new DatagramSocket();
        DatagramSocket re = new DatagramSocket(10005);
        new Thread(new Rec(re)).start();
        new Thread(new Send(se)).start();
    }
}

TCP传输例子

客户端

package Test;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class TransClient {
    public static void main(String[] args) throws IOException {
        Socket s = new Socket("10.175.160.121", 10003);
        // 读取键盘输入
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        // 获取socket输出流,写给服务端
        PrintWriter out = new PrintWriter(s.getOutputStream(), true);

        String line;
        // socket输入流,读取服务端发来的
        BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
      // 从键盘读取后写给服务端
        while ((line = br.readLine()) != null) {
            if (line.equals("over"))
                break;
            out.println(line);
            // 读取服务端发回的大写字母
            String uper = bufIn.readLine();
            System.out.println(uper);
        }
        s.close();
    }
}

服务端

package Test;


import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class TransServer {
    public static void main(String[] args) throws IOException {
        ServerSocket ss = new ServerSocket(10003);
        // 接收从客户端发来的socket
        Socket socket = ss.accept();
        // 获取ip
        String ip = socket.getInetAddress().getHostAddress();
        // 获取socket读取流
        BufferedReader bufr = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        // socket输出流,将大写后的写到客户端
        PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
        String line;
        while ((line=bufr.readLine()) != null) {
          // 服务端打印从客户端发来的数据
            System.out.println(line);
          // 服务端发送给客户端转化大写后的数据
            out.println(line.toUpperCase());
        }
        socket.close();
        ss.close();
    }
}

by @sunhaiyu

2016.1.13

推荐阅读更多精彩内容

  • 个人认为,Goodboy1881先生的TCP /IP 协议详解学习博客系列博客是一部非常精彩的学习笔记,这虽然只是...
    贰零壹柒_fc10阅读 2,177评论 0赞 2
  • 1.这篇文章不是本人原创的,只是个人为了对这部分知识做一个整理和系统的输出而编辑成的,在此郑重地向本文所引用文章的...
    SOMCENT阅读 6,742评论 6赞 166
  • 1.1 TCP/IP协议组 TCP/IP协议(传输控制协议)由网络层的IP协议和传输层的TCP协议组成 IP层负责...
    F麦子阅读 1,432评论 0赞 24
  • 参考:http://www.2cto.com/net/201611/569006.html TCP HTTP UD...
    F麦子阅读 1,220评论 0赞 12
  • 1. 网络编程概述 1.1 计算机网络 是指将地理位置不同的具有独立功能的多台计算机及其外部设备,通过通信线路连接...
    JackChen1024阅读 289评论 0赞 3