java网络多线程专题(代码片段)

温文艾尔 温文艾尔     2022-12-10     571

关键词:


一、网络的相关概念:

网络的相关概念:

  • 网络通信
  • 概念:两台设备之间通过网络实现数据传输

  • 网络通信:将数据通过网络从一台设备传输到另一台设备

  • java.net包下提供了一系列的类或接口,供程序员使用,完成网络通信

  • ip地址
  • 概念:用于唯一标识网络中的每台计算机

  • 查看ip地址:ipconfig

  • ip地址的表示形式:点分十进制 xx.xx.xx.xx

  • 每一个十进制数的范围:0~255

  • ip地址的组成=网络地址+主机地址,比如:192.168.16.69,192.168.16为网络地址(例如家庭地址中的北京市海淀区朝阳小区),69为主机地址(相当于门牌号)

  • ilPv6是互联网工程任务组设计的用于替代IPv4的下一代IP协议,其地址数量号称可以为全世界的每一粒沙子编上一个地址

  • 由于IPv4最大的问题在于网络地址资源有限,严重制约了互联网的应用和发展。IPv6的使用,不仅能解决网络地址资源数量的问题,而且也解决了多种接入设备连入互联网的障碍

  • ipv4地址分类


  • 域名
  1. 举例:www.baidu.com
  2. 好处:为了方便记忆,解决记ip的困难
  3. 概念:将ip地址映射成域名
  • 端口号
  1. 概念:用于标识计算机上某个特定的网络程序
  2. 表示形式:以整数形式,范围0~65535
  3. 0~1024已经被占用,比如ssh 22,ftp 21,smtp 25,http 80
  4. 常见的网络程序端口号
  • tomcat:8080
  • mysql:3306
  • oracle:1521
  • sqlserver:1433

ip定位主机,端口定位服务,访问要ip+端口

  • 网络协议

协议(tcp/ip)

TCP/IP中文译名传输控制协议/因特网互联协议,又叫网络通讯协议,是Internet国际互联网络的基础

TCP和UDP:

  • TCP协议:
  1. 使用TCP协议前,须先建立TCP连接,形成传输数据通道
  2. 传输前,采用三次握手方式,是可靠的
  3. TCP协议进行通信的两个应用进程:客户端,服务端
  4. 在连接中可进行大数据量的传输
  5. 传输完毕,需释放已建立的连接,效率低
  • UDP协议:用户数据协议
  1. 将数据、源、目的封装成数据包,不需要建立连接
  2. 每个数据包的大小限制在64K内
  3. 因无需连接,故是不可靠的
  4. 发送数据结束时无需释放资源(因为不是面向连接的),速度快
  5. 举例:(厕所通知:发短信)

三次握手举例:

UDP举例:

不进行握手确认,直接发送数据,类似于发短信

InetAddress类:

相关方法:

  1. 获取本机InetAddress对象 getLocalHost
  2. 获取指定主机名/域名获取ip地址对象 getByName
  3. 获取InetAddress对象的主机名 getHostName
  4. 获取InetAddress对象的地址 getHostAddress

代码展示:

package com.hsp.net;

import java.net.InetAddress;
import java.net.UnknownHostException;

/**
 * Description
 * User:
 * Date:
 * Time:
 * InetAddress类方法的使用
 */
public class test01 
    public static void main(String[] args) throws UnknownHostException 
        //获取本机的InetAddress对象
        InetAddress localHost = InetAddress.getLocalHost();
        System.out.println(localHost);//LAPTOP-2UERK2QG/192.168.205.1

        //根据指定的主机名获取对象
        InetAddress localhost2 = InetAddress.getByName("LAPTOP-2UERK2QG");

        //根据域名获取对象
        InetAddress localHost3 = InetAddress.getByName("www.baidu.com");

        //通过InetAddress对象获取对应的主机名地址等信息

        //获取主机名
        String hostName = localHost.getHostName();
        System.out.println("主机名:"+hostName);

        //获取ip地址
        String hostAddress = localHost.getHostAddress();
        System.out.println("ip地址:"+hostAddress);
    

Socket:

基本介绍:

  1. 套接字(Socket)开发网络应用程序被广泛采用,以至于成为事实上的标准
  2. 通信的两端都要有Socket,是两台机器间通信的端点
  3. 网络通信其实就是Socket间的通信
  4. Socket允许程序把网络连接当成一个流,数据在两个Socket间通过IO传输
  5. 一般主动发起通信的应用程序属客户端,等待通信请求的为服务端

TCP网络通信编程应用案例(使用字节流)

  1. 编写一个服务器端和一个客户端
  2. 服务器端在9999端口监听
  3. 客户端连接到服务器端,发送hello world然后退出
  4. 服务器端接收到客户端发送的信息,输出,并退出

服务端代码

package com.hsp.net.socket;



import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

/**服务端
 * Description
 * User:
 * Date:
 * Time:
 */
public class SSocketTCP01Server 
    public static void main(String[] args) throws IOException 
        // 1.在本季的9999端口监听,等待连接
        //前提是9999端口没有被占用
        //细节:这个ServerSocket可以通过accept()返回多个Socket[高并发]
        ServerSocket serverSocket = new ServerSocket(9999);
        System.out.println("服务端,在9999端口监听,等待连接");
        //2.当没有客户端连接9999端口时,程序会阻塞,等待连接
        //如果有客户端连接,则会返回socket对象,程序继续
        Socket socket = serverSocket.accept();
        System.out.println("服务端 socket ="+socket.getClass());
        //3.通过socket.getInputStream()读取客户端写入到数据通道的数据,显示
        InputStream in = socket.getInputStream();
        byte[] bt = new byte[1024];
        int readLen = 0;
        while((readLen= in.read(bt)) != -1)
            System.out.println(new String(bt,0,readLen));
        
        //关闭流和socket
        in.close();
        socket.close();
        serverSocket.close();

    


客户端代码:

package com.hsp.net.socket;

import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

/**客户端
 * Description
 * User:
 * Date:
 * Time:
 */
public class SocketTCP01Client 
    public static void main(String[] args) throws IOException 
        //1.连接服务器(ip,端口)
        //连接本机的9999端口
        Socket socket = new Socket(InetAddress.getLocalHost(), 9999);
        System.out.println("客户端:"+socket.getClass());
        //2.连接上后,生成Socket,通过
        //socket.getOutputStream()
        OutputStream out = socket.getOutputStream();
        //3.通过输出流,写入数据到数据通道
        out.write("hello server".getBytes());
        //4.关闭流对象和socket,必须关闭
        out.close();
        socket.close();
        System.out.println("客户端退出了");
    

TCP网络通信编程应用案例2

  1. 编写一个服务器端和一个客户端
  2. 服务端在9999端口监听
  3. 客户端连接到服务器端,发送hello server,并接收服务器端返回的hello,client再退出
  4. 服务器端接收到客户端发送的信息,输出hello client再退出

服务端代码:

package com.hsp.net.socket;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * Description
 * User:
 * Date:
 * Time:
 */
public class SSocketTCP02Server 
    public static void main(String[] args) throws IOException 
        ServerSocket serverSocket = new ServerSocket(9999);
        System.out.println("服务端等待连接中...");
        Socket socket = serverSocket.accept();
        System.out.println("服务端 端口号9999 收到连接");
        System.out.println("服务端向用户端发送信息");
        OutputStream out = socket.getOutputStream();
        out.write("hello client".getBytes());

        socket.shutdownOutput();

        InputStream in = socket.getInputStream();
        System.out.println("服务端接收来自用户端的信息");
        byte[] bt = new byte[1024];
        int length = 0;
        while((length=in.read(bt))!=-1)
            System.out.println(new String(bt,0,length));
        

        socket.shutdownInput();

        in.close();
        out.close();
        socket.close();
        serverSocket.close();
        System.out.println("服务端退出");
    

客户端代码:

package com.hsp.net.socket;


import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

/**
 * Description
 * User:
 * Date:
 * Time:
 */
public class SocketTCP02Client 
    public static void main(String[] args) throws IOException 
        Socket socket = new Socket(InetAddress.getLocalHost(),9999);
        System.out.println("用户端:"+socket);
        OutputStream out = socket.getOutputStream();
        System.out.println("用户端向服务端发送信息");
        out.write("hello serve".getBytes());

        socket.shutdownOutput();

        InputStream in = socket.getInputStream();
        System.out.println("用户端接收来自服务端的信息");
        byte[] bt = new byte[1024];
        int length = 0;
        while((length=in.read(bt))!=-1)
            System.out.println(new String(bt,0,length));
        

        socket.shutdownInput();

        in.close();
        out.close();
        socket.close();
        System.out.println("用户端退出");

    

TCP网络通信编程应用案例3(使用字符流)

  1. 编写一个服务器端和一个客户端
  2. 服务端在9999端口监听
  3. 客户端连接到服务器端,发送hello server,并接收服务器端返回的hello,client再退出
  4. 服务器端接收到客户端发送的信息,输出hello client再退出

这里需要现将字节流利用转换流转换成字符流,服务端接收到字节流,在转换成字符流进行输出

服务端代码:

package com.hsp.net.socket;

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

/**
 * Description
 * User:
 * Date:
 * Time:
 */
public class SSocketTCP03Server 
    public static void main(String[] args) throws IOException 
        ServerSocket serverSocket = new ServerSocket(9999);
        System.out.println("服务端等待连接中...");
        Socket socket = serverSocket.accept();
        System.out.println("服务端 端口号9999 收到连接");
        System.out.println("服务端向用户端发送信息");
        OutputStream out = socket.getOutputStream();
        BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(out));
        bufferedWriter.write("hello client:字符流");
        bufferedWriter.flush();//如果使用的字符流,需要手动刷新,否则数据不会写入数据通道
        bufferedWriter.newLine();//插入一个换行符,表示写入的内容结束,注意,要求对方使用readLine()
        socket.shutdownOutput();

        InputStream in = socket.getInputStream();
        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(in));
        System.out.println("服务端接收来自用户端的信息");
        String s = bufferedReader.readLine();
        System.out.println(s);

        socket.shutdownInput();

        in.close();
        out.close();
        socket.close();
        serverSocket.close();
        System.out.println("服务端退出");
    


用户端代码:

package com.hsp.net.socket;


import java.io.*;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

/**
 * Description
 * User:
 * Date:
 * Time:
 */
public class SocketTCP03Client 
    public static void main(String[] args) throws IOException 
        Socket socket = new Socket(InetAddress.getLocalHost(),9999);
        System.out.println("用户端:"+socket);
        OutputStream out = socket.getOutputStream();
        BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(out));
        bufferedWriter.write("hello serve:字符流");
        bufferedWriter.flush();
        bufferedWriter.newLine();
        System.out.println("用户端向服务端发送信息");

        socket.shutdownOutput();

        InputStream in = socket.getInputStream();
        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(in));
        System.out.println("用户端接收来自服务端的信息");
        String s = bufferedReader.readLine();
        System.out.println(s);

        socket.shutdownInput();

        in.close();
        out.close();
        socket.close();
        System.out.println("用户端退出");

    


TCP网络通信编程应用案例4

  1. 编写一个服务器端和一个客户端
  2. 服务端在9999端口监听
  3. 客户端连接到服务器端,发送一张图片e:\\qie.png
  4. 服务器端接收到客户端发送的图片,保存在src下发送“收到图片”再退出
  5. 客户端接收到服务端发送的收到图片再退出
  6. 该程序要求使用StreamUtils.java

StreamUtils的作用:将输入流转换成byte[],即可以把文件的内容读入到byte[]

示意图:

使用BufferedInputStream和BufferedOutputStream字节流

服务端代码:

package com.hsp.net.socket;

import com.hsp.net.StreamUtils;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.stream.Stream;

/**
 * Description
 * User:
 * Date:
 * Time:
 */
public class SSocketTCP04Server 
    public static void main(String[] args) throws IOException 
        ServerSocket serverSocket = new ServerSocket(9999);
        Socket socket = serverSocket.accept();

        //接收用户端传递的图片数组,并将其输出在src目录下
        BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
        byte[] bytes = StreamUtils.streamTobytes(bis);
        socket.shutdownInput();

        String filepath = "src/test.png";
        BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(filepath));
        bos.write(bytes);


        //服务端向用户端发送信息
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
        bw.write("图片发送成功");
        bw.flush();
        bw.newLine();
        socket.shutdownOutput()并发编程专题(代码片段)

进程和线程概念进程:资源分配的基本单位。线程:独立调度的基本单位,一个进程中可以包含多个线程,它们之间共享进程资源,同一进程中线程切换不会引发进程切换,不同进程中的线程切换会引发进程切换。为什么要使用... 查看详情

2023-javase最新整理面试题-io和多线程专题(代码片段)

Java基础面试题一、IO和多线程专题1.介绍下进程和线程的关系进程:一个独立的正在执行的程序线程:一个进程的最基本的执行单位,执行路径多进程:在操作系统中,同时运行多个程序多进程的好处:可... 查看详情

并发编程专题(代码片段)

什么是多线程通讯?多线程通讯就是多个线程同时操作一个资源,但是操作的动作不同代码实现packagecom.kernel;classResprivateStringname;privateStringsex;privateBooleanflag;publicStringgetName()returnname;publicvoidsetName(Stringname)this.name=name;publicStringgetSex... 查看详情

并发编程专题-线程的状态(代码片段)

1.线程状态Java中,线程的状态使用一个枚举类型来描述的。这个枚举一共有6个值:NEW(新建)、RUNNABLE(运行)、BLOCKED(锁池)、TIMED_WAITING(定时等待)、WAITING(等待)、TERMINATED(终止、结束)。但是大多数人的理解和上面的这六种还是有些差... 查看详情

jvm技术专题java各种类型对象占用内存情况分析「上篇」(代码片段)

...层次,需要了解JVM内部运行机制,或者高并发多线程下,你写的代码对内存有影响,你想做性能优化。当你想深入了解java对象在内存中,如何存储,或者每个对象占用多大空间时。内存公式Java对象的内存... 查看详情

并发编程专题-线程的创建方式

1.创建多线程几种方式1.1继承Thread,重写父类的run()方法Java使用​​java.lang.Thread​​类代表线程,所有的线程对象都必须是Thread类或其子类的实例。每个线程的作用是完成一定的任务,实际上就是执行一段程序流即一段顺序执行... 查看详情

多线程(代码片段)

多线程[Thread]多线程是Java语言的重要特性,大量应用于网络编程、服务器端程序的开发,最常见的UI界面底层原理、操作系统底层原理都大量使用了多线程。1、程序、进程与线程程序Program  ?程序是一段静态的代码,指令的集... 查看详情

hdu-2686matrix(多线程dp?)2017寒假集训(代码片段)

...,查题解是最大流????然后问了大佬,说这题也可以网络流做,不过呢。。。然后我就了解到了这个叫多线程DP的东西多线程。。????这不是C语言的那啥玩意。。。吗?课设好像还要用呢orz 查看详情

181115网络通信----多线程(代码片段)

 下面是一个 多线程 运算 调用了threading 模块  可以同时在一个程序中 跑两个函数 importthreadingdeftext1():foriinrange(5):print("-----%d-----"%i)deftext2():foriinrange(5):print("-----%d--- 查看详情

java学习网络编程全总结——tcpudp多线程io流socket简易在线咨询聊天室java爬虫(代码片段)

目录网络编程1.1、概述1.2、网络通信的要素1.3、IP1.4、端口(port)1.5、通信协议1.6、TCP文件上传Tomcat1.7、UDP发送消息构造方法摘要构造方法摘要咨询DatagramPacket.getData()与DatagramPacket.getLength()的误区trimstartsWith在线咨询:两个人都... 查看详情

jvm专题-虚拟机栈(代码片段)

...内存的分配越大越好吗?3.3.方法内的局部变量是否是线程安全的?3.4.栈内存溢出3.5.线程诊断_CPU占用过高3.6.线程诊断_迟迟得不到结果1.定义JavaVirtualMachineStacks(Java虚拟机栈)每个线程运行需要的内存空间&# 查看详情

网络编程之多线程(代码片段)

线程理论:线程是什么?线程是CPU的基本执行单位线程里面包括就是要执行的代码进程是一个资源单位其中包括了这个程序需要的所有资源就像是一个工厂里面包括了生产所需所有资源线程像一条流水线包含具体的执行步骤一个... 查看详情

关于进程,线程,多进程和多线程的网络编程(代码片段)

进程线程网络多任务编程:可以有效的利用计算机资源,同时执行多个任务进程:进程就是程序在计算机中一次执行的过程进程和程序的区别:程序是一个静态文件的描述,不占计算机的系统资源进程是一个动态的过程,占有cpu... 查看详情

java多线程编程——多线程技能(代码片段)

第一章Java多线程技能文章目录第一章Java多线程技能前言一、进程和多线程概述二、使用多线程1.继承Thread类2.线程随机性的展现3.实现Runnable接口4.使用Runnable接口实现多线程的优点5.实例变量共享造成的非线程安全问题与解决方... 查看详情

java多线程——异常记录(代码片段)

Java多线程——异常记录摘要:本文主要介绍了Java多线程中遇到的奇怪的异常。部分内容来自以下博客:https://blog.csdn.net/historyasamirror/article/details/6709693java.lang.IllegalMonitorStateException在测试多线程通信的代码时,出现了这个... 查看详情

java技术专题综述之线程篇

本文详细介绍JAVA技术专题综述之线程篇编写具有多线程能力的程序经常会用到的方法有:run(),start(),wait(),notify(),notifyAll(),sleep(),yield(),join()还有一个重要的关键字:synchronized本文将对以上内容进行讲解。一:run()和start()示例1:pub... 查看详情

java基础——多线程(代码片段)

文章目录1、线程、进程、多任务多任务多线程程序(进程)多进程与多线程的区别多线程解释2、线程状态1.新线程创建(new)三种创建方式:(只关注前两种)方法1方法2总结方法三(了解即可)2.线程停... 查看详情

多线程--线程安全(代码片段)

多线程--线程安全1.java进程如何运行2.线程安全3.线程不安全的原因3.1代码层面3.2原理层面3.2.1原子性3.2.2可见性3.2.3有序性4.如何解决线程安全问题?5.解决多线程安全问题5.1synchronized关键字5.2volatile关键字1.java进程如何运行java类名... 查看详情