java网络编程

网络编程概述

地球村：你在西安，你一个美国朋友

计算机网络

计算机网络是指将地理位百不同的具有独立功能能的多台计算九及其外部设备，通过通信线路连接起来，作系统，网络管理软性及网络通信协议的管理和协调下，实现资源共烹和信息传递的计算机系统。

网络编程的目的：

无线电台…传揺交流信息，数据交换。通信
想要达到这个效果需要什么：

如何准确的定位网络上的一台主机192.168,16.124：端口，定位到这个计算机上的某个资源
找到了这个主机，如何传输数据泥？

网络通信的要素

如何实现网络的通信？

通信双方地址：

IP
端口号
192.168.16124.5900

规则：网络通信的协议

TCP/IP参考模型：

小结：

网络编程中有两个主要的问题
- 如何准确的定位到网络上的一台或者多台主机。找到主机之后如何进行通信
- 网络编程中的要素
  IP 和端口号同
  网络通信协议 udp , tcp
万物皆对象

IP地址

ip 地址： InetAddress

唯一定位一台网络上计算机。127.0.0.1：本机 localhost
ip 地址的分类
- ipv4/ipv6iPV4127.0.0.1,4个字节组成。,0-255,42亿～;30亿都在北美，亚洲4亿。2011年就用尽；
- iPV6:128位。8个无符号整数！
```
2001:0bb2: aaaa :0015:0000:0000:1aaa:1312!
```
- 公网（互联网）-私网（局域网）
  - ABCD 类地址
  - 192.168.xx. xx ，专门给组织内部使用的
域名：记忆 IP 问题！
- IP : www . vip . com!

package com.example.demo;
 
import java.net.Inet4Address;
import java.net.InetAddress;
import java.net.UnknownHostException;
 
public class GetIpAddress {
 
	public static void main(String[] args) {
		try {
			InetAddress ip4 = Inet4Address.getLocalHost();
			System.out.println(ip4.getHostAddress());
		} catch (UnknownHostException e) {
			e.printStackTrace();
		}
	}
 
}

端口

端口表示计算机上的一个程序的进程；

不同的进程有不同的端口号！用来区分软件！
被规定0~65535
TCP , UDP :65535*2 tcp :80, udp :80吗，单个协议下，端口号不能冲突
端口分类
- 公有端口0~1023
- - HTTP :80
  - HTTPS :443
  - FTP :21
  - Telent :23
- 程序注册端口：1024~49151，分配用户或者程序
  - Tomcat :8080
  - MysQL :3306 Oracle :1521
- 动态、私有：49152~65535

netstat -ano #查看所有的端口
netstat -ano |findstr “5900” # 查看指定的端口
tasklist|findstr “8696” #查看指定窗口的进程
Ctrl+shift+Esc

package com . kuang .lessone1;

 import java . net . InetSocketAddress ;
 public class TestInetSocketAddress {
 public static void main ( String [] args ){
 InetSocketAddress socketAddress = new InetSocketAddress ( hostname :"127.0.0.1", port :808e); InetSocketAddress socketAddress2= new InetSocketAddress ( hostname :" localhost ＂, port :8080); System . out . println ( socketAddress );
 System . out . println (socketAddress2);
 System . out . println ( socketAddress . getAddress ());
 System . out . println ( socketAddress . getHostName ());// hosts 
 System . out . println ( socketAddresS . getPortO );

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-t8Vp2vYg-1657685729572)(C:Users11915AppDataRoamingTyporatypora-user-imagesimage-20220713111901749.png)]

通信协议

协议：约定，就好比我们现在说的是普通话。
网络通信协议：速率，传输码率，代码结构，传输控制………

问题：非常的复杂？
大事化小：分层！
TCP / IP 协议簇：实际上是一组协议
重要：

TCP ：用户传输协议
UDP ：用户数据报协议

出名的协议：

TCP :
IP ：网络互连协议

TCP udp的对比

TCP ：打电话

连接，稳定

三次握手四次挥手

最少需要三次，保证稳定连接！
A ：你瞅啥？
B ：瞅你咋地？
A ：干一场！

A ：我要走了！
B ：我真的要走了吗？
B ：你真的真的要走了吗？
A ：我的真的要走了！

客户端、服务端
传输完成，释放连接，效率低 UDP ：发短信

UDP：发短信
不连接，不稳定
客户端、服务端：没有明确的界限
不管有没有准备好，都可以发给你
导弹
DDOS ：洪水攻击！（饱和攻击）

TCP

客户端

连接服务器Socket
发送消息

服务器

建立服务的端口 ServerSocket
等待用户的链接accept（）
接收用户的消息

package com . kuang .lessone2; 
import java . io . OutputStream ; 
import java . net . InetAddress ; 
import java . net . Socket ;
import java . net . UnknownHostException ;/／客户端
public class TcpClientDemo01{
public static void main ( String [] args ){
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 (＂你好＂. getBytes ()); catch ( Exception e ){
 e . printStackTrace ();
} finally {
 if ( os !=nul1){
 try {
 os . close ();
} catch ( IOException e ){
 e . printStackTrace ();
 if ( socket !=nul1){
 try {
 socket . close ();
} catch ( IOException e ){
 e . printStackTrace (); 
}

文件上传客户端

package com . kuang .lessone2; import java . io . File ;
import java . io . FileInputStream ;
import java . io . OutputStream ;
import java . net . InetAddress ; 
import java . net . Socket ;
import java . net . UnknownHostException ; public class TcpClientDemo02{
public static void main ( String [] args ) throWs Exception {
//1．创建一个 Socket 连接
 Socket socket = new Socket ( InetAddress . getByName ("127.0.0.1"), port :90ee);
//2、创建一个输出流
 OutputStream os = socket . getOutputStream ();
//3．读取文件
 FileInputStream fis = new FileInputStream ( new File ( pathname :" qinjiang . jpg "));
//4。写出文件
 byte [] buffer = new byte [1024];
int1en;
 while (( len = fis . read ( buffer ))!=-1){
 os . write ( buffer , off : e , len );
 }
//通知服务器，我已经结束了
 socket . shutdownOutput ();//我已经传输完了！
//确定服务器按收完毕，才能够断开连接
 InputStream inputStream = socket . getInputStream ();
// String byte []
 ByteArrayOutputStream baos = new ByteArrayOutputStream (); byte []buffer2= new byte [2014];
 int len2;
 while ((1en2= inputStream . read (buffer2))!=-1){
 baos . write (buffer2, off :0,len2);
//5．关闭资源
 fis . close ();
 os . close ();
 socket . close ();
 }
}

用户段端

package com . kuang .lessone2; import java . io . File ;
import java . io . FileOutputStream ;
import java . io . IOException ;
import java . io . InputStream ; 
import java . net . ServerSocket ; 
import java . net . Socket ;
import java . util . Scanner ;
public class TcpServerDemo02{
public static void main ( String [] args ) throws Exception {
//1。创建服务
 ServerSocket serverSocket = new ServerSocket ( port :9eee);//2．监听客户端的连接
 Socket socket = serverSocket . accept ();/／阻塞式监听，会一直等待客户端连接//3．获取输入流
 InputStream is = socket . getInputStream ();
 FileOutputStream fos = new FileOutputStream ( new File ( pathname :＂ receive "));//4．文件输出
 byte [] buffer = new byte [1024];
 int len ;
 while (( len = is . read ( buffer ))!=-1){
 fos . write ( buffer , off . e , len );
 }
//通知客户端我接收完毕了
 OutputStream os = socket . getOutputStream ();
 os . write (＂我接受完毕了，你可以断开了＂. getBytes ())                                                         
//关闭资源
 fos . close ();
 is . close ();
 socket . close ();
 serverSocket . close ();
   }
}

Tomcat 服务端

自定义 S · Tomcat 服务器客户端
自定义 C
浏览器 B

package com . kuang .lesson03;
import java . net . DatagramPacket ; 
import java . net . DatagramSocket ; 
import java . net . InetAddress ; 
import java . net . SocketEXception ;
/／不需要连接服务器
pub1ic class UdpclientDemo01{
pub1ic static void main ( string [] args ) throws Exception {
//1．建立一个 Socket 
 DatagramSocket socket = new DatagramSocket O ;
//2．建个包
 String msg =＂你好啊，服务器！＂;
 InetAddress 1ocalhost= InetAddress . getByName ("1ocalhost");
 int port =9090;
//数据，数据的长度起始，要发送给谁
 DatagramPacket packet = new DatagramPacket ( msg . getBytes ,0,
 msg . getBytes ). length , localhost , port );
//3．发送包
 socket . send ( packet );
//4．关闭流
 socket . close ;
  }
}

咨询接收端

package network.udpchat;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.util.Arrays;


public class ChatReceiver implements Runnable{
    private DatagramSocket datagramSocket;

    public ChatReceiver(DatagramSocket datagramSocket){
        this.datagramSocket=datagramSocket;
    }

    @Override
    public void run() {
            // 定义一个字节数组用于接收发送端的数据

            byte[] bytes=new byte[1024];
            DatagramPacket packet = new DatagramPacket(bytes, bytes.length);
            while (true){
                try {
                    datagramSocket.receive(packet);
                    // 打印接收到的信息
                    String name=packet.getPort() == 3000?"陈波":"chenbo";

                    String tx =new String(packet.getData(),0,packet.getLength());
                    //System.out.println("收到来自"+packet.getAddress()+"的:"+packet.getPort()+"端口发来的信息:"+tx);

                    System.out.println("收到来自"+name+"发来的消息:"+tx);

                } catch (IOException e) {
                    e.printStackTrace();
                }
            }


    }
}

发送端

package network.udpchat;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;


public class ChatSend implements Runnable{
    private DatagramSocket sender;
    private  int targetPort;

    public ChatSend(DatagramSocket datagramSocket,int targetPort){
        this.sender=datagramSocket;
        this.targetPort=targetPort;
    }
    @Override
    public void run() {
        Scanner scanner = new Scanner(System.in);
        String name = targetPort==9000?"陈波":"chenbo";
        try {
            while (true) {

                // 获取目标ip(此处也是本机)
                InetAddress localHost = InetAddress.getLocalHost();
                // 获取输入的内容
                System.out.println("我:"+"("+name+")"+":n");
                String text = scanner.nextLine();
                // 将输入的内容包装到datagramPacket中发送 目标【ip】和【端口号】
                // 封装数据到字节数组中
                byte[] bytes = text.getBytes();
                DatagramPacket packet = new DatagramPacket(bytes, bytes.length, localHost, targetPort);
                sender.send(packet);//发送数据
                System.out.println("************系统提示:发送信息成功! ***********************");
            }
        }
            catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

Url

地址类： URL
http类： HttpURLConnection
输入流： InputStream
输出流： FileOutputStream

package com.demo01;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Random;
public class TestURL {
    public static void main(String[] args) throws Exception {
    	// 下载地址
        // 地址
        URL url = new URL(downURL);
        // 获取文件后缀名
        String fileName = "";
        int index = url.getFile().lastIndexOf(".");
        if (index != -1) {
            fileName = url.getFile().substring(index);
        }
        // 打开地址
        HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();
        // 获取流
        InputStream is = urlConnection.getInputStream();
        // 写入流
        Random random = new Random();
        FileOutputStream fos = new FileOutputStream("UrlDown" + random.nextInt(1000) + fileName); 
        // 写入文件
        byte[] buffer = new byte[1024];
        int len;
        while ((len = is.read(buffer)) != -1) {
            fos.write(buffer,0,len);
        }
        // 关闭流
        fos.close();
        is.close();
        urlConnection.disconnect(); // 断开连接
    }
}

暑期编程PK赛得CSDN机械键盘等精美礼品！

java网络编程

Java相关栏目本月热门文章