网络编程实现

1.网络编程三要素
1.IP地址:网络中设备的唯一标识IPv4:4个字节组成,点分十进制表示法IPv6:16个字节组成,冒分十六进制表示法"127.0.0.1"本地主机网络地址【用于测试】相关命令:ipconfig: 查看本机在当前网络环境下的ip地址ping: 查看当前主机和指定的ip地址是否连通2.端口号:在网络设备中应用程序的标识,用一个整数表示。范围:[0~65535][0-1023]可能被操作系统占用,建议使用1024以后的端口号80: 浏览器中访问服务器的默认端口号8080: Tomcat服务器默认的端口号3306: MySQL数据库的端口号3.网络协议:网络中数据传输的规则UDP: 面向无连接的,不可靠的协议,一次只能传输64K的数据TCP: 面向有链接的,可靠的协议,对数据大小没有限制 对当前网络通讯质量要求不高的时候,要求网络通讯速度尽量的快,这时就使用UDP1.QQ语音   2.QQ视频    3.TFTP当对网络通信质量有要求时,比如:整个数据要准确无误的传递给对方,这往往对于一些要求可靠的应用1.浏览器使用的:HTTP   2.FlashFXP:FTP3.Outlook:POP,SMTP   4.QQ文件传输
2.InetAddress类【ip相关】
//InetAddress类
public class Demo1 {public static void main(String[] args) throws UnknownHostException {//确定主机名称的IP地址。主机名称可以是机器名称,也可以是IP地址//static InetAddress getByName (string host)InetAddress inetAddress = InetAddress.getByName("192.168.83.152");//获取此IP地址的主机名//string getHostName ()如果主机名[安全问题]隐藏,则返回ip地址System.out.println("主机名为 "+inetAddress.getHostName());//string getHostAddress ()返回文本显示中的IP地址字符串System.out.println("ip为 "+inetAddress.getHostAddress());//局域网为192.168.83.113//外网为10.254.3.213}
}打印结果:
------------------------------------------------------------------------
主机名为 192.168.83.152
ip为 192.168.83.152
3.UDP通信【协议】

【过程与码头送包裹类似】

//发送端
public class ClientDemo {public static void main(String[] args) throws IOException {//创建码头DatagramSocket ds = new DatagramSocket();//打包数据Scanner sc = new Scanner(System.in);String s = sc.nextLine();byte[] bytes = s.getBytes();InetAddress address = InetAddress.getByName("127.0.0.1");DatagramPacket dp = new DatagramPacket(bytes,bytes.length,address,10001);//发送包裹【sent方法发送,并将包裹传入】ds.send(dp);//释放资源ds.close();}
}打印结果:
----------------------------------------------------------------------------------------------------
你好

【注:需要先打开接收端,再打开发送端才可测试】

//接收端[码头需要释放资源]
//注意点:
//1.要先运行接收端,再运行发送端
//2.如果接收端再启动之后,没有接收到数据,那么会死等(阻塞).
//3.在接收数据的时候,需要调用一个getLength方法,表示接收到了多少字节
public class ServerDemo {public static void main(String[] args) throws IOException {//找到码头DatagramSocket ds = new DatagramSocket(10001);//创建新包//DatagramPacket (byte[] buf, int length)byte[] bytes = new byte[1024];DatagramPacket dp = new DatagramPacket(bytes,bytes.length);//将客户端发送的包裹放进新包里ds.receive(dp);//拆包展示//DatagramPacket getData(获取字节数组) getLength(获取数据的长度)byte[] data = dp.getData();int length = dp.getLength();System.out.println(new String(data, 0, length));//释放资源ds.close();}
}打印结果:
----------------------------------------------------------------------------------------------------
/127.0.0.1 来信息
你好
4.UDP中的组播和广播

组播代码实现
组播地址:224.0.0.0~239.255.255.255
其中224.0.0.0~224.0.0.255为预留的组播地址

//UDP组播
//发送端
public class ClientDemo {public static void main(String[] args) throws IOException {//1.创建码头DatagramSocket ds = new DatagramSocket();//2.打包byte[] bytes = "hello组播".getBytes();//netsh interface ipv4 show joins查看组播地址InetAddress address = InetAddress.getByName("224.0.0.1");//int ip =10000;DatagramPacket dp = new DatagramPacket(bytes,bytes.length,address,10000);//发送ds.send(dp);//释放资源ds.close();}
}
打印结果:
----------------
你好组播public class ServerDemo {public static void main(String[] args) throws IOException {//找码头的组MulticastSocket ms = new MulticastSocket(10000);//准备新箱子DatagramPacket dp = new DatagramPacket(new byte[1024],1024);//放包:把当前计算机绑定一个组播地址,表示添加到这一组中ms.joinGroup(InetAddress.getByName("224.0.0.1"));ms.receive(dp);//拆包System.out.println(new String(dp.getData(), 0, dp.getLength()));ms.close();}
}

广播代码实现
广播地址:255.255.255.255

//UDP广播[广播地址不一定全部写成255,可以网段+255]
//发送端
public class ClientDemo {public static void main(String[] args) throws IOException {//1.创建码头DatagramSocket ds = new DatagramSocket();//2.打包byte[] bytes = "hello广播".getBytes();//255.255.255.255或者自己的网段+255InetAddress address = InetAddress.getByName("192.168.83.255");//int ip =10000;DatagramPacket dp = new DatagramPacket(bytes,bytes.length,address,10000);//发送ds.send(dp);//释放资源ds.close();}
}
打印结果:
----------------------------
你好,广播//接收端
public class ServerDemo {public static void main(String[] args) throws IOException {//找码头的组DatagramSocket ds = new DatagramSocket(10000);//准备新箱子DatagramPacket dp = new DatagramPacket(new byte[1024],1024);//放包:把当前计算机绑定一个组播地址,表示添加到这一组中ds.receive(dp);//拆包System.out.println(new String(dp.getData(), 0, dp.getLength()));ds.close();}
}
5.TCP通信【协议】

【使用Socket和ServerSocket发送一张图片】
测试也是先开启服务端,再开启客户端发送

客户端

public class ClientDemo {public static void main(String[] args) throws IOException {//1.创建客户端Socket对象Socket socket = new Socket("192.168.83.113", 10002);//2.本地输入流读取文件BufferedInputStream bis = new BufferedInputStream(new FileInputStream("C:\\Users\\Inuyasha\\Desktop\\2.jpg"));//网络输出流输出文件BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());//边读边写byte[] bytes = new byte[1024];int len = bis.read(bytes);while (len != -1) {bos.write(bytes, 0, len);len = bis.read(bytes);}//给服务端读取结束符号socket.shutdownOutput();//关闭本地流bis.close();//3.等待服务器响应并读取//使用网络输入流对取并打印BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));String s = br.readLine();System.out.println(s);//4.释放资源socket.close();}
}

服务端

public class ServerDemo {public static void main(String[] args) throws IOException {//1.创建客户端ServerSocket对象ServerSocket serverSocket = new ServerSocket(10002);//2.监视客户端,等待请求Socket socket = serverSocket.accept();//3.网络输入流读取客户端信息BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());//本地输出流将文件写入硬盘BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("day15_mySocket\\a.jpg"));//边读边写byte[] bytes = new byte[1024];int len = bis.read(bytes);while (len != -1) {bos.write(bytes, 0, len);len = bis.read(bytes);}//关闭本地流bos.close();//4.读写完毕,传递客户端//网络输出流BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bw.write("上传成功");bw.newLine();bw.flush();//释放资源serverSocket.close();socket.close();}
}

服务端改进【服务端的对客户端传输的信息的操作可以写成线程任务,从而创建多线程】

public class ServerDemo {public static void main(String[] args) throws IOException {//1.创建客户端ServerSocket对象ServerSocket serverSocket = new ServerSocket(10002);//2.监视客户端,等待请求while (true) {Socket socket = serverSocket.accept();//socket有参构造,得到一个socket的线程任务ThreadSocket threadSocket = new ThreadSocket(socket);Executors.newFixedThreadPool(10).submit(threadSocket);//也可自定义线程池new ThreadPoolExecutor(5,//核心线程数8,//最大线程数1,//临时线程存在时间TimeUnit.MINUTES,//时间单位new ArrayBlockingQueue<>(8),//阻塞队列Executors.defaultThreadFactory(),//线程工程new ThreadPoolExecutor.AbortPolicy()//拒绝策略).submit(threadSocket);}}
}//线程任务实现类
public class ThreadSocket implements Runnable {private Socket socket;public ThreadSocket(Socket socket) {this.socket = socket;}@Overridepublic void run() {BufferedOutputStream bos = null;try {//3.网络输入流读取客户端信息BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());//本地输出流将文件写入硬盘String s = UUID.randomUUID().toString();bos = new BufferedOutputStream(new FileOutputStream("day15_mySocket\\src\\com\\A\\" + s + ".jpg"));//边读边写byte[] bytes = new byte[1024];int len = bis.read(bytes);while (len != -1) {bos.write(bytes, 0, len);len = bis.read(bytes);}//4.读写完毕,传递客户端//网络输出流BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bw.write("上传成功");bw.newLine();bw.flush();} catch (IOException e) {e.printStackTrace();} finally {//关闭本地流if (bos != null) {try {bos.close();} catch (IOException e) {e.printStackTrace();}}if (socket != null) {//释放资源try {socket.close();} catch (IOException e) {e.printStackTrace();}}}}
}
6.TCP代码实现注意点

<1>阻塞方法

a.使用accept()【ServerSocket对象调用】来监听客户端,并返回一个Socket对象【阻塞,等待客户端请求】
——解决客户端ip地址和端口号与服务端一致,即可发送请求
b.read()【输入流读取】阻塞,等待客户端输入【结束标记】
——关闭流,或者调用socket.shutdownOutput()方法给与一个结束标记,但不会影响socket流的继续使用

<2>三次握手【建立连接】
在这里插入图片描述

<3>四次挥手【取消连接】

在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/330808.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

通用唯一标识码UUID的介绍及使用

转载自 通用唯一标识码UUID的介绍及使用。什么是UUID&#xff1f; UUID全称&#xff1a;Universally Unique Identifier&#xff0c;即通用唯一识别码。 UUID是由一组32位数的16进制数字所构成&#xff0c;是故UUID理论上的总数为16^32 2^128&#xff0c;约等于3.4 x 10^38。也…

IEEE论文检测的字体未嵌入问题Times New Roman,Bold, Times New Roman,Italic is not embedded解决方法

【1】README 毕业前写了一篇 英文paper&#xff0c; 接受后&#xff0c;需要提交到 IEEE PDF Express 做格式检测&#xff1b;&#xff1b;latex源码中引用了 Visio生成的算法流程图&#xff0c;PDF文件&#xff1b; 谁料&#xff0c;哥子提交上去后&#xff0c;报如下错误&…

类加载器的创建

1.什么是类加载器 <1>概念&#xff1a;类加载器是用来加载类的工具(从硬盘加载到JVM内存) <2>类加载器的加载时机【类在使用时才被加载&#xff0c;不使用不加载】 a.创建类的对象时 b.通过类名调用静态方法时 c.通过反射加载类 <3>3.类加载器的分类 a.启动…

Java 必看的 Spring 知识汇总

转载自 Java 必看的 Spring 知识汇总Spring框架是由于软件开发的复杂性而创建的。Spring使用的是基本的JavaBean来完成以前只可能由EJB完成的事情。然而&#xff0c;Spring的用途不仅仅限于服务器端的开发。从简单性、可测试性和松耦合性的角度而言&#xff0c;绝大部分Java应用…

Java 截取反斜杠--java使用split拆分特殊字符

orgn link : http://blog.csdn.net/scy411082514/article/details/7987852 Java 截取反斜杠 replaceAll和split &#xff08;“\”&#xff09; 问题解决办法 2009年07月15日 星期三 上午 11:26 xxx.split("\\") 显然得不到想要的结果 正确方法 xxx.split(&qu…

反射的实现

1.获取类的字节码对象 //获取类的字节码对象 public class Demo1 {public static void main(String[] args) throws ClassNotFoundException {//方式1&#xff1a;类名.ClassClass<?> clazz1 Student.class;//方式2&#xff1a;对象名.getClass()Student student new…

thinking-in-java(11) 持有对象

【11.1】泛型和类型安全的容器 &#xff08;1&#xff09;ArrayList<Apple> 中尖括号括起来的是&#xff1a; 类型参数&#xff0c;它指定了这个容器实例可以保存的类型&#xff1b; 【荔枝&#xff1a;有泛型和没有泛型的区别】 class Apple {private static long coun…

JDK9新特性实战:简化流关闭新姿势

转载自 JDK9新特性实战&#xff1a;简化流关闭新姿势。做Java开发的都知道&#xff0c;每个资源的打开都需要对应的关闭操作&#xff0c;不然就会使资源一直占用而造成资源浪费&#xff0c;从而降低系统性能。 关于资源的关闭操作&#xff0c;从JDK7-JDK9有了不少的提升及简化。…

XML配置文件

XML的语法 1.xml是由自定义的标签组成 <开始标签>标签体</结束标签> <自闭合标签/> 2.xml文件的语法 1)必须要有一个文档声明 <?xml version"1.0" encoding"UTF-8" ?>2)只有一个根标签3)特殊字符 如< > & 必须使用…

DevExperience(1710)

【1】Date 和 String 互转 // Date 和 String 互转。public static void main(String[] args) {SimpleDateFormat formatter new SimpleDateFormat("yyyyMMdd");// Date 转 StringString curDateStr formatter.format(new Date());System.out.println("curDat…

Java Jar包的压缩、解压使用指南

转载自 Java Jar包的压缩、解压使用指南什么是jar包 JAR&#xff08;Java Archive&#xff09;是Java的归档文件&#xff0c;它是一种与平台无关的文件格式&#xff0c;它允许将许多文件组合成一个压缩文件。 如何打/解包 使用jdk/bin/jar.exe工具&#xff0c;配置完环境变量后…

枚举的实现

1.枚举的概念 枚举就是把几个固定的常量列举出来。枚举本质上也是一个类&#xff0c;只不过这个类的对象是几个固定的值&#xff0c;不能让外界创建对象【因为其内部的构造方法私有】 2.定义一个枚举类 public enum Week {//枚举项表示Week类的对象&#xff0c;带括号表示使…

think-in-java(17)容器深入研究

注意&#xff1a; 17章接着 11章继续分析 java容器&#xff0c; think-in-java(11) 【17.1】完整的容器分类方法 【容器分类网络解说】 1&#xff09;接口&#xff1a;虚线框&#xff0c;没有实线入边&#xff08;没有实体类继承关系&#xff0c;只有接口继承关系&#xff09…

浅析负载均衡的6种算法,Ngnix的5种算法

转载自 浅析负载均衡的6种算法&#xff0c;Ngnix的5种算法。 常见的几种负载均衡算法 1、轮询法 将请求按顺序轮流地分配到后端服务器上&#xff0c;它均衡地对待后端的每一台服务器&#xff0c;而不关心服务器实际的连接数和当前的系统负载。 2、随机法 通过系统的随机算法…

注解的实现

1.概念 注解表示一个标识(标注、标记)&#xff0c;它可以用在类上、方法上、变量上等&#xff0c;给类的各个组成部分一些额外的表示&#xff0c;能够被编译器识别。 2.常见注解 Override: 描述一个方法是复写的父类方法 Deprecate: 描述一个方法是过时的方法&#xff0c;调…

Java对象引用四个级别(强、软、弱、虚)

转载自 Java对象引用四个级别&#xff08;强、软、弱、虚&#xff09; 最近&#xff0c;高级Java技术栈微信群中&#xff0c;有一些猿友在讨论JVM中对象的周期问题&#xff0c;有谈到引用的级别&#xff0c;现在为大家做个总结吧&#xff0c;虽然大多数公司并没有意识或者用到这…

反射和配置文件的实际应用

1.利用反射完成不同参数赋值 <1>无参构造[默认赋值] Student 和 Teacher皆为JavaBean类 public class Demo1 {public static void main(String[] args) throws InvocationTargetException, NoSuchMethodException, InstantiationException, IllegalAccessException {//…

thinking-in-java(13) String字符串

【13.1】不可变String 1&#xff09;String对象是不可变的&#xff0c;具有只读特性&#xff1b; 【荔枝-String对象是不可变的】 public class Immutable {public static String upcase(String s) {return s.toUpperCase();}public static void main(String[] args) {Strin…

Java7任务并行执行神器:ForkJoin框架

转载自 Java7任务并行执行神器&#xff1a;Fork&Join框架Fork/Join是什么&#xff1f;Fork/Join框架是Java7提供的并行执行任务框架&#xff0c;思想是将大任务分解成小任务&#xff0c;然后小任务又可以继续分解&#xff0c;然后每个小任务分别计算出结果再合并起来&#…

单元测试和日志技术

1.Junit使用的基本流程 <1>将junit的jar包导入到工程中 <2>编写测试方法该测试方法必须是公共的无参数无返回值的非静态方法在测试方法上使用Test注解标注该方法是一个测试方法 <3>选中测试方法右键通过junit运行该方法 Junit点击下载 2.Junit常用的三个注…