cms自助建站,网站内链建设和外链的推广,威海百姓网免费发布信息网,app软件做得比较好的公司目录
1.什么是网络编程#xff1f;
2.基本的通信架构
3.网络通信三要素
4.UDP通信-快速入门
5.UDP通信-多发多收
6.TCP通信-快速入门
7.TCP通信-多发多收
8.TCP通信-同时接收多个客户端
9.TCP通信-综合案例 1.什么是网络编程#xff1f; 网络编程是可以让设…目录
1.什么是网络编程
2.基本的通信架构
3.网络通信三要素
4.UDP通信-快速入门
5.UDP通信-多发多收
6.TCP通信-快速入门
7.TCP通信-多发多收
8.TCP通信-同时接收多个客户端
9.TCP通信-综合案例 1.什么是网络编程 网络编程是可以让设备中的程序与网络上其他设备中的程序进行数据交互的技术
2.基本的通信架构 CS架构Client客户端/Server服务端 BS架构Browser浏览器/Server服务端 无论是CS架构还是BS架构的软件都必须依赖网络编程
3.网络通信三要素 1.IP地址 IPInternet Protocol全称”互联网协议地址”是分配给上网设备的唯一标识可以用来定位网络上的设备。 IP地址有两种形式 IPv4 32位4个字节 点分十进制: 192.168.1.66 IPv6: 128位 冒分十六进制: 2001:0db8:0000:0023:0008:0800:200c:417a IP域名: 网址 公网IP, 内网IP 公网IP是可以连接互联网的IP地址内网IP也叫局域网IP只能组织机构内部使用。 内网IP192.168. 开头的就是常见的局域网地址范围即为192.168.0.0--192.168.255.255专门为组织机构内部使用。 特殊IP地址127.0.0.1、localhost代表本机IP只会寻找当前所在的主机。 IP常用命令 ipconfig 查看本机IP地址 ping IP地址检查网络是否连通 Java中IP地址的表示 InetAddress package com.itheima.day13.teacher.demo02_ip;import java.io.IOException;
import java.net.InetAddress;
import java.net.UnknownHostException;/*** IP用于在一个网络里找到某个计算机设备。一般使用IPv4比如192.168.29.33* 域名因为IP比较难记所以有了域名系统更方便记忆* IP和域名的关系类似于 手机通讯录里 手机号和姓名备注的关系* 百度的ip110.242.68.4* 百度的域名www.baidu.com* IP地址对象InetAddress**/
public class DemoInetAddress {public static void main(String[] args) throws IOException {//获取本机ip信息InetAddress local InetAddress.getLocalHost();String localIp local.getHostAddress();System.out.println(本机ip localIp);String localName local.getHostName();System.out.println(本机名 localName);//获取指定ip或指定域名的信息// InetAddress baidu InetAddress.getByName(www.baidu.com);InetAddress baidu InetAddress.getByName(110.242.68.4);String baiduName baidu.getHostName();System.out.println(baiduName baiduName);String baiduIp baidu.getHostAddress();System.out.println(baiduIp baiduIp);//测试指定域名的网络是否畅通200ms之内能否ping通百度boolean reachable baidu.isReachable(200);System.out.println(reachable reachable);}
}2.端口号 标记正在计算机设备上运行的应用程序的被规定为一个 16 位的二进制范围是 0~65535 分类 周知端口0~1023被预先定义的知名应用占用如HTTP占用 80FTP占用21 注册端口1024~49151分配给用户进程或某些应用程序 动态端口49152到65535之所以称为动态端口是因为它 一般不固定分配某种进程而是动态分配 注意我们自己开发的程序一般选择使用注册端口且一个设备中不能出现两个程序的端口号一样否则出错。 3.协议 1.网络上通信的设备事先规定的连接规则以及传输数据的规则被称为网络通信协议。 2.开放式网络互联标准 OSI网络参考模型全球网络互联标准 TCP/IP网络模型事实上的国际标准 3.传输层的2个通信协议 UDP用户数据报协议 特点 无连接、不可靠通信通信效率高 不事先建立连接数据按照包发一包数据包含自己的IP、程序端口目的地IP、程序端口和数据限制在64KB内等。 发送方不管对方是否在线数据在中间丢失也不管如果接收方收到数据也不返回确认故是不可靠的 。 应用场景语音通话、视频直播 TCP传输控制协议 特点 面向连接、可靠通信 要保证在不可靠的信道上实现可靠的传输 TCP主要有三个步骤实现可靠传输 三次握手建立可靠连接目的确定通信双方收发消息都是正常无问题的全双工 传输数据进行确认目的保证传输数据的可靠性 四次挥手断开连接目的确保双方数据的收发都已经完成 应用场景网页、文件下载、支付
4.UDP通信-快速入门 Java提供了一个java.net.DatagramSocket类来实现UDP通信。 构造器、方法 客户端实现步骤 创建DatagramSocket对象客户端对象 创建DatagramPacket对象封装需要发送的数据数据包对象 使用DatagramSocket对象的send方法传入DatagramPacket对象 释放资源 服务端实现步骤 创建DatagramSocket对象并指定端口服务端对象 创建DatagramPacket对象接收数据数据包对象 使用DatagramSocket对象的receive方法传入DatagramPacket对象 释放资源 package com.itheima.day13.teacher.demo01_udp;import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;/***/
public class Sender {public static void main(String[] args) throws Exception {//1. 创建DatagramSocket对象因为它提供了收发udp数据包的方法DatagramSocket ds new DatagramSocket();//2. 准备数据包byte[] data hello.getBytes();DatagramPacket packet new DatagramPacket(data, data.length, InetAddress.getLocalHost(), 7788);//3. 把数据包里的数据发送出去ds.send(packet);//4. 释放资源ds.close();}
}----------------
package com.itheima.day13.teacher.demo01_udp;import java.net.DatagramPacket;
import java.net.DatagramSocket;/***/
public class Receiver {public static void main(String[] args) throws Exception {//1. 创建DatagramSocket对象并监听7788端口DatagramSocket ds new DatagramSocket(7788);//2. 准备数据包。用于存储 接收到的数据。UDP的数据包64Kbyte[] buffer new byte[1024 * 64];DatagramPacket packet new DatagramPacket(buffer, buffer.length);//3. 接收数据。接收到的数据会被放到packet对象里ds.receive(packet);//4. 把接收到的数据打印出来String str new String(packet.getData(), packet.getOffset(), packet.getLength());System.out.println(str str);//5. 释放资源ds.close();}
}5.UDP通信-多发多收 客户端实现步骤 创建DatagramSocket对象发送端对象 使用while死循环不断的接收用户的数据输入如果用户输入的exit则退出程序 如果用户输入的不是exit, 把数据封装成DatagramPacket 使用DatagramSocket对象的send方法将数据包对象进行发送 释放资源 服务端实现步骤 创建DatagramSocket对象并指定端口接收端对象 创建DatagramPacket对象接收数据数据包对象 使用DatagramSocket对象的receive方法传入DatagramPacket对象 使用while死循环不断的进行第3步 package com.itheima.day13.teacher.demo03_udp;import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;/*** 1. 发送的消息内容由用户进行输入用Scanner* Scanner scanner new Scanner(System.in);* String line scanner.nextLine();* 2. 可以多次发送消息进行持续通信* 发送者持续多次发送* 如果用户输入的是“byebye”就结束循环*/
public class Sender {public static void main(String[] args) throws Exception {//1. 创建DatagramSocket对象因为它提供了收发udp数据包的方法DatagramSocket ds new DatagramSocket();//2. 准备一个扫描器用于读取用户的输入Scanner scanner new Scanner(System.in);//3. 持续通信不断读取用户的输入把内容发送出去while (true) {//读取用户输入的内容String line scanner.nextLine();//封装到数据包里byte[] data line.getBytes();DatagramPacket packet new DatagramPacket(data, data.length, InetAddress.getLocalHost(), 7788);//把数据包里的数据发送出去ds.send(packet);//如果用户输入的是byebye就结束循环if (byebye.equals(line)) {break;}}//4. 释放资源ds.close();}
}---------------------
package com.itheima.day13.teacher.demo03_udp;import java.net.DatagramPacket;
import java.net.DatagramSocket;/*** author liuyp* since 2024/02/28*/
public class Receiver {public static void main(String[] args) throws Exception {//1. 创建DatagramSocket对象并监听7788端口DatagramSocket ds new DatagramSocket(7788);//2. 准备数据包。用于存储 接收到的数据。UDP的数据包64Kbyte[] buffer new byte[1024 * 64];DatagramPacket packet new DatagramPacket(buffer, buffer.length);//3. 持续通信不断的接收数据并打印出来while (true) {//4. 接收数据。接收到的数据会被放到packet对象里ds.receive(packet);//5. 把接收到的数据打印出来String str new String(packet.getData(), packet.getOffset(), packet.getLength());System.out.println(packet.getSocketAddress() 发送了 str);}//5. 释放资源// ds.close();}
}6.TCP通信-快速入门 1.Java提供了一个java.net.Socket类来实现TCP通信。 2.客户端实现步骤 创建客户端的Socket对象请求与服务端的连接。 使用socket对象调用getOutputStream()方法得到字节输出流。 使用字节输出流完成数据的发送。 释放资源关闭socket管道。 3.服务端实现步骤 创建ServerSocket对象注册服务端端口。 调用ServerSocket对象的accept()方法等待客户端的连接并得到Socket管道对象。 通过Socket对象调用getInputStream()方法得到字节输入流、完成数据的接收。 释放资源关闭socket管道
package com.itheima.day13.teacher.demo04_tcp;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;/***/
public class Client{public static void main(String[] args) throws IOException {//1. 使用TCP连接 本机的8888端口创建Socket对象Socket socket new Socket(127.0.0.1, 8888);//2. 通过Socket把数据发出去到服务端DataOutputStream dos new DataOutputStream(socket.getOutputStream());dos.writeUTF(hello);//3. 通过Socket接收服务端返回的数据DataInputStream dis new DataInputStream(socket.getInputStream());String answer dis.readUTF();System.out.println(收到服务端返回结果 answer);//4. 释放资源dis.close();dos.close();socket.close();}
}----------------------
package com.itheima.day13.teacher.demo04_tcp;import java.io.DataInput;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;/*** author liuyp* since 2024/02/28*/
public class Server {public static void main(String[] args) throws IOException {//1. 监听8888端口创建ServerSocketServerSocket serverSocket new ServerSocket(8888);//2. 获取客户端的连接Socket对象。是阻塞方法。如果没有客户端连接进来就一直阻塞等待Socket socket serverSocket.accept();//3. 通过Socket接收客户端发过来的数据DataInputStream dis new DataInputStream(socket.getInputStream());String data dis.readUTF();System.out.println(接收到客户端发来的数据 data);//4. 通过Socket给客户端返回数据DataOutputStream dos new DataOutputStream(socket.getOutputStream());dos.writeUTF(hi);//5. 释放资源dos.close();dis.close();socket.close();serverSocket.close();}
}7.TCP通信-多发多收 客户端使用死循环让用户不断输入消息。 服务端也使用死循环控制服务端收完消息继续等待接收下一个消息。
package com.itheima.day13.teacher.demo05_tcp;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;/*** 1. 客户端给服务端发送的内容由用户输入* 2. 实现客户端和服务端的持续通信*/
public class Client{public static void main(String[] args) throws IOException {//1. 使用TCP连接 本机的8888端口创建Socket对象Socket socket new Socket(127.0.0.1, 8888);Scanner scanner new Scanner(System.in);DataOutputStream dos new DataOutputStream(socket.getOutputStream());DataInputStream dis new DataInputStream(socket.getInputStream());while (true) {//2. 通过Socket把数据发出去到服务端使用Scanner读取用户输入的内容把内容发出去String line scanner.nextLine();dos.writeUTF(line);//3. 通过Socket接收服务端返回的数据String answer dis.readUTF();System.out.println(收到服务端返回结果 answer);//如果用户输入的内容是byebye就结束if (byebye.equals(line)) {break;}}//4. 释放资源dis.close();dos.close();socket.close();}
}-----------------
package com.itheima.day13.teacher.demo05_tcp;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;/*** author liuyp* since 2024/02/28*/
public class Server {public static void main(String[] args) throws IOException {//1. 监听8888端口创建ServerSocketServerSocket serverSocket new ServerSocket(8888);//2. 获取客户端的连接Socket对象。是阻塞方法。如果没有客户端连接进来就一直阻塞等待Socket socket serverSocket.accept();DataInputStream dis new DataInputStream(socket.getInputStream());DataOutputStream dos new DataOutputStream(socket.getOutputStream());while (true) {//3. 通过Socket接收客户端发过来的数据String data dis.readUTF();System.out.println(接收到客户端发来的数据 data);//4. 通过Socket给客户端返回数据dos.writeUTF(hi);if (byebye.equals(data)) {break;}}//5. 释放资源dos.close();dis.close();socket.close();serverSocket.close();}
}8.TCP通信-同时接收多个客户端 主线程定义了循环负责接收客户端Socket管道连接 每接收到一个Socket通信管道后分配一个独立的线程负责处理它。
package com.itheima.day13.teacher.demo06_tcp;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;/***/
public class ServerWorkerRunnable implements Runnable{private Socket socket;public ServerWorkerRunnable(Socket socket) {this.socket socket;}Overridepublic void run() {try {DataInputStream dis new DataInputStream(socket.getInputStream());DataOutputStream dos new DataOutputStream(socket.getOutputStream());while (true) {//通过Socket接收客户端发过来的数据。也是阻塞方法即如果当前socket里没有数据可读取就阻塞String data dis.readUTF();System.out.println(接收到客户端发来的数据 data);//通过Socket给客户端返回数据dos.writeUTF(hi);if (byebye.equals(data)) {break;}}//释放资源dos.close();dis.close();socket.close();} catch (IOException e) {System.out.println(连接已断开);}}
}--------------------
package com.itheima.day13.teacher.demo06_tcp;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;/***/
public class Server {public static void main(String[] args) throws IOException {//1. 监听8888端口创建ServerSocketServerSocket serverSocket new ServerSocket(8888);//2. 死循环不断尝试接受客户端的连接。有几个客户端连接进来就接受几个连接while (true) {//3. 获取客户端的连接Socket对象。是阻塞方法。如果没有客户端连接进来就一直阻塞等待Socket socket serverSocket.accept();//4. 创建一个线程由这个新线程专门负责它的通信。线程本身是异步的new Thread(new ServerWorkerRunnable(socket)).start();}// serverSocket.close();}
}----------------
package com.itheima.day13.teacher.demo06_tcp;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;/*** 1. 客户端给服务端发送的内容由用户输入* 2. 实现客户端和服务端的持续通信*/
public class Client{public static void main(String[] args) throws IOException {//1. 使用TCP连接 本机的8888端口创建Socket对象Socket socket new Socket(127.0.0.1, 8888);Scanner scanner new Scanner(System.in);DataOutputStream dos new DataOutputStream(socket.getOutputStream());DataInputStream dis new DataInputStream(socket.getInputStream());while (true) {//2. 通过Socket把数据发出去到服务端使用Scanner读取用户输入的内容把内容发出去String line scanner.nextLine();dos.writeUTF(line);//3. 通过Socket接收服务端返回的数据String answer dis.readUTF();System.out.println(收到服务端返回结果 answer);//如果用户输入的内容是byebye就结束if (byebye.equals(line)) {break;}}//4. 释放资源dis.close();dos.close();socket.close();}
}9.TCP通信-综合案例 1.即时通信-群聊 是指一个客户端把消息发出去其他在线的全部客户端都可以收到消息。 需要用到端口转发的设计思想。 服务端需要把在线的Socket管道存储起来一旦收到一个消息要推送给其他管道。 2.实现一个简易版的BS架构 BS架构的基本原理 package com.itheima.day13.teacher.demo07_tcp_tomcat;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;/***/
public class TomcatWorkerRunnable implements Runnable {private Socket socket;public TomcatWorkerRunnable(Socket socket) {this.socket socket;}Overridepublic void run() {// while (true) {try {//如果想要接收客户端提交过来的数据// InputStream is socket.getInputStream();// is.read();//直接给客户端返回结果OutputStream os socket.getOutputStream();os.write(HTTP/1.1 200\r\n.getBytes());os.write(Content-Type: text/html;charsetUTF-8\r\n.getBytes());os.write(\r\n.getBytes());os.write(h1Hello World!!!/h1.getBytes());os.write(a hrefhttp://www.baidu.com百度/a.getBytes());//必须给浏览器返回一个结束标志否则浏览器会一直转圈socket.shutdownOutput();} catch (IOException e) {System.out.println(断开连接);}// }}
}----------------------
package com.itheima.day13.teacher.demo07_tcp_tomcat;import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;/***/
public class TomcatServer {public static void main(String[] args) throws IOException {//1. 监听8080端口。浏览器访问地址的格式 http://ip地址:8080ServerSocket serverSocket new ServerSocket(8080);//2. 死循环while (true) {//3. 不断尝试接受客户端的连接得到SocketSocket socket serverSocket.accept();//4. 把socket交给一个新线程进行处理new Thread(new TomcatWorkerRunnable(socket)).start();}}
}
