目录
1.概述
计算机网络:
2.网络通信的要素
3.IP
4.端口
5.通信协议
6.TCP
1.聊天实现
2.文件上传实现
Tomcat
7.UDP
发送消息
接收端
循环发送消息
8.URL
1.概述
计算机网络:
计算机网络是指将地理位置不同的具有独立功能的多台计算机及其外部设备,通过通信线路连接起来,在网络操作系统,网络管理软件及网络通信协议的管理和协调下,实现资源共享和信息传递的计算机系统。 网络编程的目的: 无线电台。。传播交流信息,数据交换。通信
想要达到这个效果需要什么: 1. 如何准确的定位网络上的一台主机 192.168.16.124 :端口,定位到这个计算机的某个资源 2. 找到这个主机, 如何传输数据呢?
Javaweb : 网络编程 B/S 网络编程 : TCP/IP C/S
2.网络通信的要素
如何实现网络的通信? 通信双方地址:
小结:
-
网络编程中有两个主要的问题
-
如何准确的定位到网络上的一台或多台主机 -
找到主机之后如何进行通信
-
网络编程中的要素
-
万物皆对象
3.IP
ip地址: InetAddress
-
唯一定位一台网络上的计算机 -
127.0.0.1 : 本机localhost -
ip地址的分类 -
-
ipv4 / ipv6 -
-
Ipv4 127.0.0.1 ,4个字节组成. 0~255 ; 30亿都在北美 , 亚洲4亿; 2011年就用尽了; -
IPV6 fe80::5de2:90fc:c0b4:38ea%14 , 128位; 8个无符号整数 ! -
?2001: 0bb2: bbbb: 0251: 0000: 0000: laaa: 1312
-
公网(互联网) - 私网 (局域网) -
-
域名: 记忆IP问题 ! -
4.端口
端口表示计算机的一个程序的进程;
-
不同的进程有不同的端口号! 用来区分软件! -
被规定 0~65535 -
TCP,UDP : 65535*2 tcp: 80 , udp: 80吗, 单个协议下,端口号不能冲突 -
端口分类 -
?netstat -ano ?#查看所有的端口
?netstat -ano |findstr "5900" #查看指定的端口
?tasklist|findstr "8696" ? #查看指定端口的进程
?Ctrl+ Shift +Esc ?#打开任务管理器
5.通信协议
协议: 约定,就好比我们现在说的是普通话。
网络通信协议: 速率 ,传输码率 , 代码结构 ,传输控制。。。。
问题: 非常复杂?
大事化小: 分层!
TCP、IP协议簇
重要:
出名的协议:实际上是一组协议
TCP UDP 对比
TCP:打电话
-
连接,稳定 -
'三次握手' '四次挥手' -
-
客户端 、服务端 -
传输完成, 释放连接 ,效率低
UDP:发短信
-
不连接 , 不稳定 -
客户端、 服务端: 没有明确的界限 -
不管有没有准备好, 都可以发给你 -
导弹 -
DDOS: 洪水攻击! (饱和攻击)
6.TCP
1.聊天实现
客户端
-
连接服务器 Socket -
发送消息
//客户端
?public class TcpClientDemo01 {
? ? ?public static void main(String[] args) {
? ? ? ? ?Socket socket = null;
? ? ? ? ?OutputStream os = null;
? ? ? ? ?try {
? ? ? ? ? ? ?//1.要知道服务器的地址,端口号
? ? ? ? ? ? ?InetAddress serverIP = InetAddress.getByName("127.0.0.1");
? ? ? ? ? ? ?int port=9999;
? ? ? ? ? ? ?//2. 创建一个socket连接
? ? ? ? ? ? ?socket = new Socket(serverIP, port);
? ? ? ? ? ? ?//3.发送消息 IO流
? ? ? ? ? ? ?os = socket.getOutputStream();
? ? ? ? ? ? ?os.write("你好,欢迎学习Java".getBytes(StandardCharsets.UTF_8));
??
??
? ? ? ? } catch (Exception e) {
? ? ? ? ? ? ?e.printStackTrace();
??
? ? }finally {
? ? ? ? ? ? ?if (os!=null){
? ? ? ? ? ? ? ? ?try {
? ? ? ? ? ? ? ? ? ? ?socket.close();
? ? ? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? ? ? ?e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ?if (socket!=null){
? ? ? ? ? ? ? ? ? ? ?try {
? ? ? ? ? ? ? ? ? ? ? ? ?socket.close();
? ? ? ? ? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? ? ? ? ? ?e.printStackTrace();
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
?}}
服务器
-
建立服务的端口 ServerSocket -
等待用户的链接 accept -
接收用的消息
?//服务端
?public class TcpServerDemo01 {
? ? ?public static void main(String[] args) {
? ? ? ? ?//提升作用域
? ? ? ? ?ServerSocket serverSocket = null;
? ? ? ? ?Socket socket = null;
? ? ? ? ?InputStream is = null;
? ? ? ? ?ByteArrayOutputStream baos = null;
??
? ? ? ? ?try {
? ? ? ? ? ? ?//1. 我得有一个地址
? ? ? ? ? ? ?serverSocket = new ServerSocket(9999);
? ? ? ? ? ? ?//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 (Exception e) {
? ? ? ? ? ? ?e.printStackTrace();
? ? ? ? }finally {
? ? ? ? ? ? ?//关闭资源
? ? ? ? ? ? ?if (baos!= null){
? ? ? ? ? ? ? ? ?try {
? ? ? ? ? ? ? ? ? ? ?baos.close();
? ? ? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? ? ? ?e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? ?if (is!= null){
? ? ? ? ? ? ? ? ?try {
? ? ? ? ? ? ? ? ? ? ?is.close();
? ? ? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? ? ? ?e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? ?if (socket!= null){
? ? ? ? ? ? ? ? ?try {
? ? ? ? ? ? ? ? ? ? ?socket.close();
? ? ? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? ? ? ?e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? ?if (serverSocket!= null){
? ? ? ? ? ? ? ? ?try {
? ? ? ? ? ? ? ? ? ? ?serverSocket.close();
? ? ? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? ? ? ?e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
??
? ? ? ? }
??
? ? }
?}
2.文件上传实现
客户端
?public class TcpClientDemo02 {
? ? ?public static void main(String[] args) throws Exception {
? ? ? ? ?//1.创建一个Socket连接
? ? ? ? ?Socket socket = new Socket(InetAddress.getByName("127.0.0.1"), 9000);
??
? ? ? ? ?//2.创建一个输出流
? ? ? ? ?OutputStream os = socket.getOutputStream();
??
? ? ? ? ?//3.读取文件
? ? ? ? ?File f = new File("D:\\zoo\\Gitee\\网络编程\\you\\logo.jpg");
? ? ? ? ?FileInputStream fis = new FileInputStream(f);
??
? ? ? ? ?//4.写出文件
? ? ? ? ?byte[] buffer = new byte[1024];
? ? ? ? ?int len;
? ? ? ? ?while ((len=fis.read(buffer))!=-1){
? ? ? ? ? ? ?os.write(buffer,0,len);
? ? ? ? }
??
? ? ? ? ?//5. 关闭资源
? ? ? ? ?fis.close();
? ? ? ? ?os.close();
? ? ? ? ?socket.close();
??
??
? ? }
?}
服务器
?public class TcpServerDemo02 {
? ? ?public static void main(String[] args) throws Exception {
??
??
? ? ?//1.创建服务
? ? ?ServerSocket serverSocket = new ServerSocket(9000);
??
? ? ?//2.监听客户端的连接
? ? ? ? ?Socket socket = serverSocket.accept(); //阻塞式监听, 会一直等待客户端连接
??
? ? ?//3.获取输出流
? ? ? ? ?InputStream is = socket.getInputStream();
??
? ? ?//4.文件输出
? ? ? ? ?File f = new File("D:\\zoo\\Gitee\\网络编程\\you\\receive.jpg");
? ? ? ? ?FileOutputStream fos = new FileOutputStream(f);
? ? ? ? ?byte[] buffer = new byte[1024];
? ? ? ? ?int len;
? ? ? ? ?while ((len=is.read(buffer))!=-1){
? ? ? ? ? ? ?fos.write(buffer,0,len);
? ? ? ? }
??
? ? ? ? ?//关闭资源
? ? ? ? ?fos.close();
? ? ? ? ?is.close();
? ? ? ? ?socket.close();
? ? ? ? ?serverSocket.close();
??
? ? }
?}
Tomcat
服务端
-
自定义 s -
Tomcat服务器 S : Java后端开发
客户端
7.UDP
发短信: 不用连接, 需要知道对方的地址!
发送消息
(客户端)
?//不需要连接服务器
?public class UdpClientDemo01 {
? ? ?public static void main(String[] args) throws Exception {
? ? ? ? ?//1.建立一个Socket
? ? ? ? ?DatagramSocket socket = new DatagramSocket(8080);
??
? ? ? ? ?//2.建个包
? ? ? ? ?String msg = "你好,服务器 !";
? ? ? ? ?InetAddress localhost = InetAddress.getByName("localhost");
? ? ? ? ?int port = 9090;
??
? ? ? ? ?//数据, 数据的长度起始, 要发送给谁
? ? ? ? ?DatagramPacket packet = new DatagramPacket(msg.getBytes(),0,msg.getBytes().length,localhost,port);
??
? ? ? ? ?//3.发送包
? ? ? ? ?socket.send(packet);
??
? ? ? ? ?//关闭流
? ? ? ? ?socket.close();
??
? ? }
?}
接收端
?//还是要等待客户端的链接 !
?public class UdpServerDemo01 {
? ? ?public static void main(String[] args) throws Exception {
? ? ? ? ?//开放端口
? ? ? ? ?DatagramSocket socket = new DatagramSocket(9090);
??
? ? ? ? ?//接受数据包
? ? ? ? ?byte[] buffer = new byte[1024];
? ? ? ? ?DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length);
??
? ? ? ? ?socket.receive(packet);//阻塞接收
??
? ? ? ? ?System.out.println(packet.getAddress().getHostAddress());
? ? ? ? ?System.out.println(
? ? ? ? ? ? ? ? ?new String(
? ? ? ? ? ? ? ? ? ? ? ? ?packet.getData(), 0, packet.getLength()));
??
? ? ? ? ?//关闭连接
? ? ? ? ?socket.close();
??
??
? ? }
?}
循环发送消息
?
public class UdpSenderDemo01 {
? ? ?public static void main(String[] args) throws Exception {
? ? ? ? ?DatagramSocket socket =
? ? ? ? ? ? ? ? ?new DatagramSocket(8888);
??
? ? ? ? ?//准备数据: 控制台读取 System.in
??
? ? ? ? ?BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
??
? ? ? ? ?while (true) {
? ? ? ? ? ? ?String data = reader.readLine();
? ? ? ? ? ? ?byte[] datas = data.getBytes();
? ? ? ? ? ? ?DatagramPacket packet = new DatagramPacket(datas, 0, datas.length, new InetSocketAddress("localhost", 6666));
??
? ? ? ? ? ? ?socket.send(packet);
? ? ? ? ? ? ?if (data.equals("bye")) {
? ? ? ? ? ? ? ? ?break;
? ? ? ? ? ? }
? ? ? ? }
??
? ? ? ? ?socket.close();
??
? ? }
?}
?
public class UdpReceiveDemo01 {
? ? ?public static void main(String[] args) throws Exception {
? ? ? ? ?DatagramSocket socket = new DatagramSocket(6666);
??
??
? ? ? ? ?while (true){
??
? ? ? ? ? ? ?//准备接收数据
? ? ? ? ? ? ?byte[] container = new byte[1024];
? ? ? ? ? ? ?DatagramPacket ?packet = new DatagramPacket(container, 0, container.length);
? ? ? ? ? ? ?socket.receive(packet);//阻塞式接收包裹
??
? ? ? ? ? ? ?//断开连接 bye
? ? ? ? ? ? ?byte[] data = packet.getData();
? ? ? ? ? ? ?String receiveData = new String(data, 0, data.length);
? ? ? ? ? ? ?System.out.println(receiveData);
? ? ? ? ? ? ?if (receiveData.equals("bye")){
? ? ? ? ? ? ? ? ?break;
? ? ? ? ? ? }
??
? ? ? ? }
? ? ? ? ?socket.close();
??
??
? ? }
?}
在线咨询 : 两个人都可以是发送方也可以是接受方
8.URL
百度一下,你就知道
统一资源定位符: 定位资源的, 定位互联网上的某一个资源
DNS 域名解析 百度一下,你就知道 180.101.49.11
?协议: //ip地址: 端口/项目名/资源
?public class URLDemo01 {
? ? ?public static void main(String[] args) throws MalformedURLException {
? ? ? ? ?URL url = new URL("http://localhost:8080/");
? ? ? ? ?System.out.println(url.getProtocol()); // 协议
? ? ? ? ?System.out.println(url.getHost()); ? ? // 主机IP
? ? ? ? ?System.out.println(url.getPort()); ? ? // 端口
? ? ? ? ?System.out.println(url.getPath()); ? ? // 文件
? ? ? ? ?System.out.println(url.getFile()); ? ? // 全路径
? ? ? ? ?System.out.println(url.getQuery()); ? ?//参数
??
? ? }
?}
??
?public class URLDown {
? ? ?public static void main(String[] args) throws Exception{
? ? ? ? ?//1. 下载地址
? ? ? ? ?URL url = new URL("地址值");
? ? ? ? ?//2. 连接到这个资源 HTTP
? ? ? ? ?HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();
??
? ? ? ? ?InputStream inputStream = urlConnection.getInputStream();
??
? ? ? ? ?FileOutputStream fos = new FileOutputStream("项目名");
??
? ? ? ? ?byte[] buffer = new byte[1024];
? ? ? ? ?int len;
? ? ? ? ?while ((len=inputStream.read())!=-1){
? ? ? ? ? ? ?fos.write(buffer, 0, buffer.length); // 写出这个数据
? ? ? ? }
??
? ? ? ? ?fos.close();
? ? ? ? ?inputStream.close();
? ? ? ? ?urlConnection.disconnect();// 断开连接
? ? }
?}
|