wordpress资讯站模板,双语版网站怎么做,一小时学会网站建设,做网站需要ui设计吗十四、网络编程 java.net.*包下提供了网络编程的解决方案! 基本的通信架构 基本的通信架构有2种形式: CS架构( Client客户端/Server服务端)、BS架构(Browser浏 览器/Server服务端)。无论是CS架构#xff0c;还是BS架构的软件都必须依赖网络编程!。 1、网络通信的三要素 网络通…十四、网络编程 java.net.*包下提供了网络编程的解决方案! 基本的通信架构 基本的通信架构有2种形式: CS架构( Client客户端/Server服务端)、BS架构(Browser浏 览器/Server服务端)。无论是CS架构还是BS架构的软件都必须依赖网络编程!。 1、网络通信的三要素 网络通信的三要素IP地址、端口、协议。 1.1 InetAddress 代表IP地址是一个操作IP地址的类。 InetAddress的常用方法说明public static InetAddress getLocalHost()获取本机IP会以一个InetAddress对象返回public static InetAddress getByName( String host )根据ip地址或者域名返回一个InetAddress对象public String getHostName()获取指定IP对象对应的主机名public String getHostAddress()获取指定IP地址对象中的IP地址信息public boolean isReachableint timeout 在指定毫秒内判断主机与该IP对应的主机是否能连通
public class InetAddressTest {public static void main(String[] args) throws Exception {//获取本机IP地址对象InetAddress localhostInetAddress.getLocalHost();//获取指定IP对象的IP地址String lip localhost.getHostAddress();//获取指定IP对象的主机名String namelocalhost.getHostName();System.out.println(lip);System.out.println(name);//获取指定IP地址或域名的Ip对象InetAddress baidu InetAddress.getByName(www.baidu.com);//获取指定IP对象的IP地址System.out.println(baidu.getHostAddress());//获取指定IP对象的主机名System.out.println(baidu.getHostName());//判断指定IP对象在1秒内是否与本机是否可以连通boolean isCommbaidu.isReachable(1000);System.out.println(isComm);}
}1.2、端口 端口号标记正在计算机设备.上运行的应用程序的被规定为-个16位的二进制范围是0~65535。 周知端口0~1023被预先定义的知名应用占用(如: HTTP占用80FTP占用21) 注册端口: 1024~49151,分配给用户进程或某些应用程序。 动态端口: 49152到65535,之所以称为动态端口是因为它-般不固定分配某种进程而是动态分配。 注意我们自己开发的程序-般选择使用注册端口,且一个设备中不能出现两个程序的端口号一样否则出错。 1.3、协议 开放式网络互联标准:OSI网络参考模型是全球网络互联标准。 TCP/IP网络模型事实.上的国际标准。 UDP(User Datagram Protocol): 用户数据报协议; TCP(Transmission Control Protocol) :传输控制协议。 1.3.1 UDP协议 特点:通信效率搞、无连接、不可靠通信。 不事先建立连接,数据按照包发,一包数据包含:自己的IP、程序端口目的地IP、程序端口和数据(限制在64KB内)超过就分包发送。 发送方不管对方是否在线数据在中间丢失也不管如果接收方收到数据也不返回确认故是不可靠的。 场景视频语音通话、网络直播。 1.3.2、TCP协议 特点通信效率相对不高、面向连接、可靠通信。 TCP的最终目的:要保证在不可靠的信道上实现可靠的传输。 TCP主要有三个步 骤实现可靠传输三次握手建立连接传输数据进行确认,四次挥手断开连接。 场景文件下载、网页、支付。 2、UDP通信 特点无连接、不可靠通信。 不事先建立连接发送端每次把要发送的数据(限制在64KB内)、接收端IP、 等信息封装成一个数据包 发出去就不管了。 Java提供了一个java.net.DatagramSocket类来实现UDP通信。 DatagramSocket用于创建客户端、服务端
构造器说明public DatagramSocket()创建客户端的Socket对象系统会随机分配一个端口号public DataGramSocket( int port )创建服务器的Socket对象并指定端口号
DatagramSocket对象提供的方法说明public void sendDatagramPacket dp发送数据包public void receive( DatagramPacket p )使用数据包接收数据
DatagramPacket创建数据包
构造器说明public DatagramPacket(byte[] buf , int length , InetAddress address , int port )创建发出去的数据包对象public DatagramPacketbyte[] buf , int length 创建用来接收数据的数据包
方法说明public int getLength()获取数据包实际接收到的字节个数
1、客户端向服务端发送UDP信息——一发一收
//客户端
public class Client {public static void main(String[] args) throws Exception {//1、获取客户端对象DatagramSocket socketnew DatagramSocket();//2、准备数据将字符串转为字符数组byte[] hi 你好JavaHello Java.getBytes();//3、创建发送数据的数据包,参数(发送数据的字节数组数据字节大小接收方的IP地址对象(这里是本机)接收方开放的端口)DatagramPacket packetnew DatagramPacket(hi,hi.length, InetAddress.getLocalHost(),6060);//4、调用客户端对象的发送方法将数据包对象作为参数发送数据。socket.send(packet);//5、关闭发送接口socket.close();System.out.println(客户端发送完毕);}
}//服务端
public class Service {public static void main(String[] args) throws Exception {//1、创建服务端的对象端口号要和客户端一样DatagramSocket socketnew DatagramSocket(6060);System.out.println(-----服务端启动----);//限制接收数据的字节数最大64kbbyte[] buffernew byte[1024*64];//2、创建接收数据包的对象参数接收字节的数组限制接收字节的大小DatagramPacket packetnew DatagramPacket(buffer,buffer.length);//3、通过服务端对象的方法接收数据socket.receive(packet);//4、获取到接收的数据//获取接收数据的大小int lenpacket.getLength();//由于用来装数据的数组是最大来算的64kb很可能装不满所有接收多少倒多String strnew String(buffer,0,len);System.out.println(str);//关闭服务端socket.close();}
}2、客户端向服务端发送UDP信息——用户控制多次发送 使用死循环来实现 //客户端
public class Client {public static void main(String[] args) throws Exception {Scanner scannernew Scanner(System.in);//1、获取客户端对象DatagramSocket socketnew DatagramSocket();while (true) {System.out.print(请输入发送内容);//2、准备数据将字符串转为字符数组String say scanner.next();if (!say.equals(0)) {//3、创建发送数据的数据包,参数(发送数据的字节数组数据字节大小接收方的IP地址对象(这里是本机)接收方开放的端口)DatagramPacket packetnew DatagramPacket(say.getBytes(),say.getBytes().length, InetAddress.getLocalHost(),6060);//4、调用客户端对象的发送方法将数据包对象作为参数发送数据。socket.send(packet);System.out.println(已发送);}else {break;}}//5、关闭发送接口socket.close();}
}//服务端
public class Service {public static void main(String[] args) throws Exception {//1、创建服务端的对象端口号要和客户端一样DatagramSocket socketnew DatagramSocket(6060);System.out.println(-----服务端启动----);//限制接收数据的字节数最大64kbbyte[] buffernew byte[1024*64];while (true) {//2、创建接收数据包的对象参数接收字节的数组限制接收字节的大小DatagramPacket packetnew DatagramPacket(buffer,buffer.length);//3、通过服务端对象的方法接收数据socket.receive(packet);//4、获取到接收的数据//获取接收数据的大小int lenpacket.getLength();//由于用来装数据的数组是最大来算的64kb很可能装不满所有接收多少倒多String strnew String(buffer,0,len);System.out.println(已接收内容str);}//关闭服务端// socket.close();}
}3、TCP通信 特点面向连接、可靠通信。 通信双方事先会采用“三次握手”方式建立可靠连接实现端到端的通信;底层能保证数据成功传给服务端。 1、TCP客户端开发 Java提供了一个java.net.Socket类 来实现TCP通信。 Socket类构造器说明public SocketString hostint port根据指定的服务器IP、端口号请求与服务器建立连接连接通过就获得了客户端socket
方法说明public OutputStream getOutputStream( )获得字节输出流对象public InputStream getInputStream()获得字节输入流对象
public class TcpClient {public static void main(String[] args) throws Exception {//1、创建一个Socket对象,并同时请求服务器进行连接(传入要发送给服务端的IP和对应的端口号)Socket socketnew Socket(InetAddress.getLocalHost().getHostAddress(),6060);//2、通过调用字节输出流OutputStream os socket.getOutputStream();//3、将原始字节输出流转为数据字节输出流性能更好DataOutputStream dosnew DataOutputStream(os);//4、调用写出方法dos.writeUTF(通过TCP协议发送信息);//5、关闭字节流dos.close();//6、释放连接资源socket.close();}
}2、TCP服务端开发 服务端是通过java.net包下的ServerSocket类来实现的。 ServerSocket类构造器说明public ServerSocket( int port )为服务端程序注册端口
方法说明public Socket accept()阻塞等待客户端的连接请求一旦与某个客户端连接成功则返回服务端这边的Socket对象
//服务端
public class TcpService {public static void main(String[] args) throws Exception {//1、创建一个服务端连接对象serverSocket并设置服务端端口ServerSocket serverSocketnew ServerSocket(6060);//2、调用accept方法监测是否又客户端发起连接连接成功返回Socket对象Socket socketserverSocket.accept();//3、通过Socket对象调用字节输入流InputStream issocket.getInputStream();//4、为提高性能将原始字节流转换为数据字节流DataInputStream disnew DataInputStream(is);//5、调用读方法读出发送过来的数据String str dis.readUTF();System.out.println(str);//6、关闭字节流dis.close();//7、释放资源serverSocket.close();}
}3.1 TCP客户端和服务端开发-多收多发 这个案例只能接收一个程序的信息没法实现接收多个客户端发送的信息因为服务端现在只有一个主线程只能处理一个客户端的消息。 //服务端
public class TcpService {public static void main(String[] args) throws Exception {System.out.println(------服务端已启动--------);//1、创建一个服务端连接对象serverSocket并设置服务端端口ServerSocket serverSocketnew ServerSocket(6060);//2、调用accept方法监测是否又客户端发起连接连接成功返回Socket对象Socket socketserverSocket.accept();//3、通过Socket对象调用字节输入流InputStream issocket.getInputStream();//4、为提高性能将原始字节流转换为数据字节流DataInputStream dis new DataInputStream(is);while (true) {//5、调用读方法读出发送过来的数据try {String str dis.readUTF();System.out.println(已接收str);} catch (Exception e) {//如果客户端退出那么服务端会出异常这时就可以捕获异常进行处理获取离线的IPSystem.out.println(socket.getRemoteSocketAddress()已离线);//释放资源dis.close();socket.close();break;}}}
}//客户端
public class TcpClient {public static void main(String[] args) throws Exception {//1、创建一个Socket对象,并同时请求服务器进行连接(传入要发送给服务端的IP和对应的端口号)Socket socketnew Socket(InetAddress.getLocalHost().getHostAddress(),6060);//2、通过调用字节输出流OutputStream os socket.getOutputStream();//3、将原始字节输出流转为数据字节输出流性能更好DataOutputStream dosnew DataOutputStream(os);Scanner scannernew Scanner(System.in);while (true) {System.out.print(请说);String strscanner.nextLine();if(str.equals(0)){//5、关闭字节流dos.close();//6、释放连接资源socket.close();break;}//4、调用写出方法dos.writeUTF(str);}}
}3.2 TCP客户端和服务端开发-接收多客户端信息 通主线程接接收倒Socket对象主线程将其交给一个子线程来处理每多一个socket就交给一个子线程。 //客户端
public class TcpClient {public static void main(String[] args) throws Exception {//1、创建一个Socket对象,并同时请求服务器进行连接(传入要发送给服务端的IP和对应的端口号)Socket socketnew Socket(InetAddress.getLocalHost().getHostAddress(),6060);//2、通过调用字节输出流OutputStream os socket.getOutputStream();//3、将原始字节输出流转为数据字节输出流性能更好DataOutputStream dosnew DataOutputStream(os);Scanner scannernew Scanner(System.in);while (true) {System.out.print(请说);String strscanner.nextLine();if(str.equals(0)){//5、关闭字节流dos.close();//6、释放连接资源socket.close();break;}//4、调用写出方法dos.writeUTF(str);}}
}//服务端
public class TcpService {public static void main(String[] args) throws Exception {System.out.println(------服务端已启动--------);//1、创建一个服务端连接对象serverSocket并设置服务端端口ServerSocket serverSocketnew ServerSocket(6060);Socket socket null;while (true) {//2、调用accept方法监测是否又客户端发起连接连接成功返回Socket对象socket serverSocket.accept();//将Socket对象交给子线程进行处理new SocketServerThread(socket).start();}}
}//线程类
public class SocketServerThread extends Thread {
private Socket socket;
public SocketServerThread(Socket socket){this.socketsocket;
}Overridepublic void run() {try {//调用Accent方法获取字节输入流InputStream issocket.getInputStream();//将原始流转换为数据流DataInputStream disnew DataInputStream(is);//可以获取到是哪个客户端发送的IPSystem.out.println(socket.getRemoteSocketAddress()已上线);while (true) {try {//读取客户端发送的信息(只要不下线就一直处理该客户端的信息)String str dis.readUTF();System.out.println(str);} catch (Exception e) {//下线System.out.println(socket.getRemoteSocketAddress()一下线);//释放资源dis.close();socket.close();}}} catch (Exception e) {e.printStackTrace();}super.run();}
}3.3 案例 实现群聊一个客户端发送的信息会被其它所有在线的客户端接收到。 每个客户端的socket还是交给服务端一个子线程进行处理如果上线就将socket对象用集合保存起来用来转发信息如果下线就将其删除掉。 3.4 B/S架构 HTTP协议规定:响应给浏览器的数据格式必须满足如下格式 通过浏览器进行访问直接访问环路地址加端口127.0.0.1:8080 //服务端
public class Server {public static void main(String[] args) throws Exception {System.out.println(------服务端启动-------);//1、创建一个serverSocket对象开放服务器端口ServerSocket serverSocketnew ServerSocket(8080);//2、创建一个线程池防止高并发ThreadPoolExecutor poolnew ThreadPoolExecutor(4*2,4*2,5, TimeUnit.MINUTES,new ArrayBlockingQueue(8), Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());while (true) {//3、通过serverSocket对象获取socket对象Socket socketserverSocket.accept();//4、创建线程对象并将线程对象交给线程池pool.execute(new ServerRunnable(socket));}}
}//线程类
public class ServerRunnable implements Runnable {private Socket socket;public ServerRunnable(Socket socket) {this.socketsocket;}Overridepublic void run() {try {//1、通过传过来的socket对象获取字节输出流OutputStream ossocket.getOutputStream();//2、将原始输出流转换为输出字节流PrintStream psnew PrintStream(os);//3、调用输出流方法按照浏览器输出规则输出对应内容ps.println(HTTP/1.1 200 OK);ps.println(Content-Type:text/html);ps.println(); //必须换行ps.println(div stylefont-size:200px;color:green; text-align:center;Hello worlddiv/); //输出html格式或者直接字符串//释放资源ps.close();socket.close();} catch (Exception e) {e.printStackTrace();}}
}
