程序员经验分享-hwhale

java网络编程

2023-11-17

java网络编程

1.1 概述

1.2 网络通信的要素

如何实现网络通信？

通信双方地址：

  • 地址ip
  • 端口号
  • 127.0.0.1:8080

OSI七层模型

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-w2Vt3rrJ-1641116549495)(C:\Users\yanyu\AppData\Roaming\Typora\typora-user-images\image-20211225142933939.png)]

img

小结：

  1. 网络编程中有两个主要问题
    • 如何准确定位到网络上的一台或者多台主机
    • 找到主机之后如何通信
  2. 网络编程中的要素
    • IP和端口号 IP
      • 网咯通信协议 UDP、TCP
  3. 万物皆对象

1.3 IP地址

ip地址：InetAdddress

  • 唯一定义网络上的一台或者多台地址
  • ping 127.0.0.1：本机 localhost
  • ip地址的分类
    • IPV4\IPV6
      • IPV4，127.0.0.1,四个字节，32位，0-255，42亿
      • IPV6，128位
    • 公网–私网
      • ABCD类地址
      • 192.168.xx.xx
  • 域名：记忆IP问题
    • IP：纯数字
    • URL：统一资源定界符，DNS服务器
//获取ip，InetAddress类    
public static void main(String[] args) {
        InetAddress ip=null;
        try {
            ip = InetAddress.getByName("127.0.0.1");
            System.out.println(ip);

            ip = InetAddress.getByName("www.baidu.com");
            System.out.println(ip);
            System.out.println(InetAddress.getLocalHost());


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

1.4 端口

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

  • 不同进程具有不同端口，用来区分软件

  • 一个int大小，0-65535

  • TCP,UDP, 单个协议下，同一端口并不冲突

    • 公共端口 0 - 1024

      • http：80

      • https：443

      • ftp：21

      • Telent：23

    • 程序注册端口：1024-49151，用户程序公用

      • Tomcat：8080

      • MySql：3306

      • Oracle：1521

    • 动态、私有：49152-65535

      netstat -ano #查看所有端口
netstat -ano| findstr “5900” #查看指定端口
takelist | findstr "8696" #查看相应端口

socketAddress类，将地址和端口结合

InetAddress ip=null;
try {
    ip = InetAddress.getByName("127.0.0.1");

    InetSocketAddress socketAddress = new InetSocketAddress(ip, 80);
    InetSocketAddress socketAddress1 = new InetSocketAddress("127.0.0.1", 80);
    System.out.println(socketAddress);
    System.out.println(socketAddress1);
    socketAddress.getAddress();
    socketAddress.getPort();



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

1.5 通信协议

procedure、protocol

通信协议：通信规则，波特率，信道，…

TCP协议：传输控制协议，Transmission Control Protocol

UDP协议：用户数据报协议，User Data Protocol

TCP：可靠全双工通信，建立连接后通信

三次握手

A：你好
B：你好
A：我们开始聊天!

img

四次挥手

A:我要断开连接了
B:你真的断开连接了吗
B:你确定你断开连接
A：是的

img

UDP：不可靠半双工通信，不建立连接，直接向ip：端口发送消息

1.6 TCP实现聊天

java socket在创建构造函数的时候是创建的连接对象的地址，如果不使用有参构造，那么需要手动connect()，一般网络连接流程如下：

![img](https://img-blog.csdnimg.cn/img_convert/41eb6e3df828bedae464a1f430ce4aba.png)

package com.zp;

import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class TcpService {
    static OutputStream os =null;
    static InputStream is=null;
    static Socket socket = null;
    static ServerSocket serverSocket = null;
    public static void main(String[] args) {
        Scanner cin = new Scanner (System.in);
        try {
            System.out.println("服务器启动");
            //构造ServerSocket实例，指定端口监听客户端的连接请求
            serverSocket = new ServerSocket(8080);
            // 建立跟客户端的连接
            socket = serverSocket.accept();
            // 向客户端发送消息
            is = socket.getInputStream();
            os = socket.getOutputStream();
            InputStreamReader isr=new InputStreamReader(is,"utf-8");
            OutputStreamWriter osw = new OutputStreamWriter(os,"utf-8");
            //osw.write(msg);
            // 接受客户端的响应
            new Thread() {
                public void run() {
                    // TODO Auto-generated method stub
                    while (true) {
                        //byte b[] = new byte[1024];
                        char[] cha=new char[1024];
                        int len=0;
                        try {
                            len = isr.read(cha);
                        } catch (IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                        System.out.println("小明说："+new String(cha,0,len));
                    }
                }

            }.start();
            //向客户端发送消息
            new Thread(){
                public void run(){
                    // TODO Auto-generated method stub
                    while(cin.hasNext()){
                        String str=cin.next();
                        try {
                            //osw.write(str);
                            os.write(str.getBytes());
                        } catch (IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }
                }
            }.start();

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

        }
    }
}

package com.zp;

import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.Scanner;

public class TcpClient {
    static Socket socket = null;
    static InputStream is = null;
    static OutputStream os = null;
    public static void main(String[] args) {
        Scanner cin = new Scanner (System.in);
        try {
            // 对服务端发起连接请求
            System.out.println("已经连接服务器");
            socket = new Socket("localhost", 8080);
            is = socket.getInputStream();
            os = socket.getOutputStream();
            InputStreamReader isr=new InputStreamReader(is,"utf-8");
            OutputStreamWriter osw = new OutputStreamWriter(os,"utf-8");
            os.write("已经接服务器。".getBytes());
            //接收服务器信息
            new Thread() {
                public void run() {
                    // TODO Auto-generated method stub
                    while (true) {
                        //byte b[] = new byte[1024];
                        char[] cha=new char[1024];
                        int len=0;
                        try {
                            len = isr.read(cha);
                        } catch (IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                        System.out.println("小红说："+new String(cha,0,len));
                    }
                }

            }.start();
            // 给服务端发送响应信息
            new Thread(){
                public void run(){
                    // TODO Auto-generated method stub
                    while(cin.hasNext()){
                        String str=cin.next();
                        try {
                            //osw.write(str);
                            os.write(str.getBytes());
                        } catch (IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }
                }
            }.start();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

注意：

  • socket IO流读不到会自动阻塞，除非遇到了EOF或者IOException
  • 正是因此，我觉得，TCP实现全双工通信就分成两个线程

1.7 UDP

UDP一般工作流程：

img

package com.zp;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;

public class UDPSender implements Runnable{
    DatagramSocket socket = null;
    BufferedReader reader = null;

    private int fromPort;
    private String toIP;
    private int toPort;

    public UDPSender(int fromPort, String toIP, int toPort) {
        this.fromPort = fromPort;
        this.toIP = toIP;
        this.toPort = toPort;

        try {
            socket = new DatagramSocket(fromPort);
            reader = new BufferedReader(new InputStreamReader(System.in));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        while (true){
            try {
                String data = reader.readLine();
                byte[] datas = data.getBytes();
                System.out.println(datas.length);
                DatagramPacket packet = new DatagramPacket(datas, 0, datas.length,
                        new InetSocketAddress(this.toIP, this.toPort));

                socket.send(packet);
                if (data.equals("bye")){
                    break;
                }
            } catch (IOException exception) {
                exception.printStackTrace();
            }
        }

        socket.close();
    }
}


package com.zp;

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

public class UDPReceiver implements Runnable{
    DatagramSocket socket = null;
    private int port;
    private String msgFrom;

    public UDPReceiver(int port, String msgFrom) {
        this.port = port;
        this.msgFrom = msgFrom;

        try {
            socket = new DatagramSocket(port);
        } catch (SocketException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        while (true){
            try {
                //准备接受包裹
                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(msgFrom + "：" + receiveData);

                if (receiveData.equals("bye")){
                    break;
                }
            } catch (IOException exception) {
                exception.printStackTrace();
            }
        }
        socket.close();
    }
}

注意：

  • UDP是只管发送的IP，接受他是没有IP的，因为他是不事先建立连接的通信

1.8 URL

https://www.baidu.com/

统一资源定位符：定位资源的，定位互联网上的某一个资源

DNS 域名解析 www.baidu.com/ xxx.xxx.xxx

  • 协议：//ip地址：端口/项目名/资源
public class URLDemo01 {
    public static void main(String[] args) throws MalformedURLException {
        URL url = new URL("http://localhost:8080/helloworld/index.jsp?username=kuangshen&password=123");
        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("tu.jpg");
    
        byte[] buffer = new byte[1024];
        int len;
        while((len=inputStream.read(buffer)) != -1){
            fos.write(buffer, 0, len);//写出这个数据
        }
    
        fos.close();
        inputStream.close();
        urlConnection.connect();
    }

}
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

Java

网络

udp

java网络编程 的相关文章

随机推荐

  • 用Python写个弹球的游戏

    原创 xinxin 菜鸟学Python 我们前面讲了几篇关于类的知识点 为了让大家更好的掌握类的概念 并灵活的运用这些知识 我写了一个有趣又好玩的弹球的游戏 一来可以把类的知识融会一下 二来加深对Python的兴趣 你会发现哎呀Python

  • eclipse Maven 插件添加第三方远程仓库

    方法一 在maven 配置文件setting xml 添加镜像点 mirror eclipse的 preferences gt maven gt User Settings 你就可以看到你的setting xml文件的地址 打开settin

  • SqueezeNet运用到Faster RCNN进行目标检测+OHEM

    目录 目录 一SqueezeNet介绍 MOTIVATION FIRE MODULE ARCHITECTURE EVALUATION 二SqueezeNet与Faster RCNN结合 三SqueezeNetFaster RCNNOHEM

  • unity出pc的包，然后想调试C#的dll咋办

    加入我们的逻辑代码是以dll的方式 放到unity项目中如下 namespace CSharpDll public class Utils public int Add int a int b int c a b return c publ

  • 2013全球移动游戏产业白皮书

    2013全球移动游戏产业白皮书 在全球移动游戏产业迅猛发展的背景下 中国移动游戏产业也进入了 高铁 时代 2013年 中国国内Android和iOS活跃设备量已达到3 7亿部 并涌现出20余款月流水超过千万元的 明星 移动游戏产品 对其内容

  • mysql数据库各种应用_MySQL数据库常见管理应用（1）

    MySQL数据库常见管理应用 1 创建数据库 创建一个数据库solin mysql gt create database solin 建立一个名为solin gbk的GBK字符集 mysql gt create database solin

  • Java通过反射获取注解以及注解中的信息

    首先自定义两个注解 1 用于描述表名 只能用在类 接口 枚举上 Target ElementType TYPE Retention RetentionPolicy RUNTIME public interface TableName Str

  • 《现代控制系统》第五章——反馈控制系统性能分析 5.3 二阶系统的性能

    现在我们看一个单环二阶系统的单位阶跃响应 一个闭环反馈控制系统如下图所示 已知该闭环系统的转换方程为 把受控系统的转换方程代入进去得到 如果给一个阶跃输入 那么 查拉普拉斯逆变换表我们得到时域输出为 其中 同时也是特征方程在s域的根与原点的

  • 实际项目二次封装axios------request.js和使用

    前言 axios 是一个基于Promise 用于浏览器和 nodejs 的 HTTP 客户端 本质上也是对原生XHR的封装 只不过它是Promise的实现版本 符合最新的ES规范 在项目的实际开发中用到也比较多 这里我介绍一下实际开发中的基

  • 什么是高内聚、低耦合？

    起因 模块独立性指每个模块只完成系统要求的独立子功能 并且与其他模块的联系最少且接口简单 两个定性的度量标准 耦合性和内聚性 耦合性也称块间联系 指软件系统结构中各模块间相互联系紧密程度的一种度量 模块之间联系越紧密 其耦合性就越强 模块的

  • align-items属性

    弹性子元素在 侧轴 交叉轴上的对齐方式 align items stretch 默认值 如果弹性子元素没有高度或高度为auto 将占满整个容器的高度 align items flex start 子元素在侧轴顶端对齐 align items

  • CSS餐厅小游戏练习1~32关（附答案和链接）

    前言 CSS3众多基础常见的选择器都可以小游戏中学习 每天刷一遍 辅助记忆 做好熟练运用CSS3的第一步 小游戏链接 CSS3餐厅练习 玩法 利用各种选择器和选择器之间的关系选中抖动的物体即可通关 文章目录 第一关 Type Selecto

  • postgresql从入门到菜鸟（三）基本命令和窗口函数

    上一篇我们已经在rhel上创建了数据库 并且建立的一张成绩表 之后通过通过客户端连接上服务器端 这一篇将会写一些关于数据库的操作 首先是一些基本的操作的操作如选择数据库 查看表等等 连接至服务器端后可以通过以下命令查看数据库的基本信息 l

  • 记录element-plus + vue3.2 + tsx 开发时的问题

    开发时 select组件无法通过 model value v model value 设置值 查看了一下源码 image png https p1 juejin byteimg com tos cn i k3u1fbpfcp e1e92e6

  • 搞懂了Vue对象与实例的区别！

    很多人把Vue对象和Vue实例混为一谈 但它们还是有区别的 Vue构造函数就像一台智能手机的设计图纸 定义了这款手机的总体结构和组件 而每部依照设计图组装出来的真实手机 就是Vue实例 设计图上注明了屏幕尺寸 CPU型号等静态信息 对应Vu

  • vscode 自动导入包（组件）插件Auto Import安装好后，依旧没有自导导入提示的原因

    在TodoList js中 第一次用AntDesign的

  • Linux系统下搭建(更新)cuda环境

    本人之前ubuntu系统装的是cuda8 因为模型需要升级cuda 因此重新装cuda10 安装和更新cuda和cudnn以及安装和更新显卡驱动 下面操作都适合 一 安装 升级 显卡驱动 升级cuda之前 先要升级显卡驱动 登陆网页http

  • v-show切换显示隐藏失败

    最近在使用element ui时发现使用v show显示某一元素不生效 问题 当切换到日期维度时坐席中心并不会跟着改变 解决方法 将v show替换成v if 总结 v show是不支持template语法的 v if vs v show

  • MySQL分页查询慢怎么办

    今天看到一个问题 MySQL分页查询慢怎么办 第一反应是用limit限制返回的条数 比如 select from table order by idlimit 10 100 实际上我们限制的只是返回的条数是100 并不是查询时就从第10条开

  • java网络编程

    java网络编程 1 1 概述 1 2 网络通信的要素 如何实现网络通信 通信双方地址 地址ip 端口号 127 0 0 1 8080 OSI七层模型 外链图片转存失败 源站可能有防盗链机制 建议将图片保存下来直接上传 img w2Vt3r

热门标签