网站建设案例怎么样,做淘宝客网站服务器,网页设计的毕业设计,东莞市哪里有做网站公司目录 1.网络编程 2.Echo模型#xff08;服务器与客户端实现通信#xff09; 3.BIO处理模型(实现多用户访问同个服务器) 4.UDP程序 1.网络编程 有两种通信模型 C/S(Client/Server)基于客户端和服务器端#xff0c;实现代码时候需要实现客户端与服务器端 B/S(Browser/S…目录 1.网络编程 2.Echo模型服务器与客户端实现通信 3.BIO处理模型(实现多用户访问同个服务器) 4.UDP程序 1.网络编程 有两种通信模型 C/S(Client/Server)基于客户端和服务器端实现代码时候需要实现客户端与服务器端 B/S(Browser/Server)基于Http网页和服务器端实现时候只需要实现服务器端即可 2.Echo模型服务器与客户端实现通信 所谓Echo模型就是指的是客户端发送消息到服务器端服务器接收到消息然后将客户端接收到的信息进行回送到客户端。所以需要编写两个端口一个客户端一个服务器端。java中可以使用Socket类实现用户端客户端与ServerSocket类服务器端 Socket与ServerSocket都是基于TCP有连接的可靠的传输服务 Socket类(客户端)的常用方法 方法描述public Socket(String host, int port)创建一个套接字连接到指定主机名和端口号public OutputStream getOutputStream()返回此套接字的输出流用于向服务器发送数据一般使用PrintStreampublic InputStream getInputStream()返回此套接字的输入流用于从服务器接收数据 ServerSocket类(服务器端)的常用方法 方法描述ServerSocket(int port)创建一个服务器套接字绑定到指定的端口号Socket accept()监听并接受客户端的连接请求返回一个与客户端通信的新的 Socket 对象void close()关闭服务器套接字停止监听客户端连接请求 Echo模型实现案例代码1.服务器端代码实现 package Example1903;import java.io.PrintStream; import java.net.ServerSocket; import java.net.Socket; import java.util.Date; import java.util.Scanner;//服务器端 public class javaDemo {public static void main(String[] args) throws Exception{Date date new Date();ServerSocket server new ServerSocket(9999);System.out.println(等待客户端运行--------);Socket client server.accept();// 设置服务器的输入输出流保证能接收信息与输入信息Scanner scanner new Scanner(client.getInputStream());PrintStream out new PrintStream(client.getOutputStream());// 接收信息并且将信息传入out输出流boolean flag true;scanner.useDelimiter(\n);while (flag){if (scanner.hasNext()){String value scanner.next().trim();if (byebye.equalsIgnoreCase(value)){out.println(ByeBye);flag false;}else out.println(date [服务器]发送消息:value);}} // 关闭所有服务server.close();client.close();scanner.close();out.close();} }2.客户端代码实现 package Example1904;import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.PrintStream; import java.net.Socket; import java.util.Date; import java.util.Scanner;//客户端 public class javaDemo { // 通过键盘输入信息private static final BufferedReader KEYBOARD_INPUT new BufferedReader(new InputStreamReader(System.in));public static String getString(String promp) throws Exception{System.out.print(promp);String str KEYBOARD_INPUT.readLine();return str;}public static void main(String[] args)throws Exception {Date date new Date();Socket client new Socket(localhost,9999);// 获取同样的输入输出对象Scanner scanner new Scanner(client.getInputStream());PrintStream out new PrintStream(client.getOutputStream());scanner.useDelimiter(\n);//使用分隔符boolean flag true;while (flag){String input getString( date [客户端]请输入要发送的信息:).trim();out.println(input);//将input内容放入PrintStream流中if (scanner.hasNext()){System.out.println(scanner.next());}if (byebye.equalsIgnoreCase(input)){flag false;}}} }服务器端运行结果 客户端运行结果: 代码流程 服务器端启动并等待连接服务器启动后通过 ServerSocket 监听指定端口此处为9999并调用 accept 方法等待客户端连接。一旦有客户端连接成功服务器会创建一个新的线程来处理与该客户端的通信。 客户端连接服务器客户端通过 Socket 构造函数连接到指定的服务器地址此处为 localhost和端口号此处为 9999。 客户端发送消息客户端通过 getString 方法获取用户输入的消息并将消息通过 PrintStream 的 println 方法发送给服务器。 服务器接收消息服务器端在自己的线程中通过 Scanner 的 next 方法读取客户端发送的消息。 服务器处理消息服务器端根据接收到的消息进行相应的处理可以是对消息进行解析、判断、计算等操作。在这个示例中服务器端简单地将接收到的消息原样发送回客户端。 服务器返回消息服务器通过 PrintStream 的 println 方法将处理后的消息发送给客户端。 客户端接收消息客户端通过 Scanner 的 next 方法读取服务器返回的消息并将其打印到控制台。 重复步骤3-7直到客户端发送byebye表示结束通信。 答疑 问1两个代码是如何实现通信的 首先两个进程之间的通信一定需要接收好对应的端口计算机网络应用层知识才能进行通信然后两个代码共用了输入输出流(可以理解为两个人用了同一条电话线)客户端通过其输出流out将信息输出到服务器端对于服务器外部输入就是输入流即输出流变成了服务器的输入流服务器通过scanner输入流接收客户端输出流的信息同理服务器也通过其输出流输出到客户端客户端接收到信息就输出 问2scanner.useDelimiter(\n);useDelimiter方法知道是设置分隔符但是搭配\n是有什么作用吗? scanner.useDelimiter(\n); 设置了扫描器的分隔符为\n即换行符。这样做的作用是让扫描器以每一行作为一个输入元素而不是以空白字符默认情况下作为分隔符。在这个示例中服务器和客户端之间通过换行符来分隔消息的发送和接收。 问3为什么要用到PrintStream正常的输出System.out.println代替不可以吗 可以使用System.out.println 来替代PrintStream它们都用于向控制台输出内容。示例代码中使用 PrintStream 是为了将客户端发送给服务器的消息发送出去以及将服务器返回的消息打印到客户端的控制台。 问4服务器端用Scanner(socket.InputStream)是为了获取客户端数据这个可以理解但是客户端为什么也是用Scanner(socket.InputStream)也是获取客户端 在客户端和服务器端都使用 Scanner(socket.getInputStream()) 是因为它们需要从对应的套接字socket的输入流中读取数据。客户端需要读取服务器发送过来的消息而服务器需要读取客户端发送过来的消息。 问5为什么要有private static final BufferedReader KEYBOARD_INPUT new BufferedReader(new InputStreamReader(System.in));代码不能直接通过ScannerSystem.in替代吗 private static final BufferedReader KEYBOARD_INPUT new BufferedReader(new InputStreamReader(System.in)); 这段代码定义了一个静态的、只读的 BufferedReader 类型的变量通过 System.in 将键盘输入流与该变量关联起来。这样做的目的是为了在客户端使用 KEYBOARD_INPUT.readLine() 来获取用户输入的字符串。由于 Scanner(System.in) 是使用缓冲区扫描输入并不能满足逐行读取的需求因此需要使用 BufferedReader 来实现。 3.BIO处理模型(实现多用户访问同个服务器) 由于上一个模型里面一段时间只能有一个用户与服务器进行交互并且一旦用户输入byebye服务器也就随之关闭但是如果我想要有多个用户去与服务器交互那么该如何实现呢所以引入了BIO处理模型。 如图结构可以知道其解决方法是在ServeSocket内部创建多个Socket实例并且将每一个Socket实例都封装在一个线程内实现多线程通信当有用户连接时候就创建一个独立的通信线程每个用户可以独立关闭自己的线程 所以只需要修改服务器端的代码 服务器端 package Example1907;import java.io.PrintStream; import java.net.ServerSocket; import java.net.Socket; import java.util.Scanner;class EchoServer implements Runnable { // 初始化Socket client null;Scanner scanner null;PrintStream out null;boolean flag true;// 传入通信对象实现创建输入输出流与确认客户端对象public EchoServer(Socket client){try {this.client client;this.scanner new Scanner(client.getInputStream());this.out new PrintStream(client.getOutputStream());}catch (Exception e){e.printStackTrace();}} // 实现通信Overridepublic void run() {while (this.flag){String value scanner.nextLine().trim();if (value.equalsIgnoreCase(byebye)){this.flag false;out.println(Bye Bye~);}else {out.println([服务器端]:value);}} // 实现完通信则关闭所有服务try {scanner.close();out.close();client.close();}catch (Exception e){e.printStackTrace();}}} //服务器端 public class javaDemo {public static void main(String[] args) throws Exception {ServerSocket server new ServerSocket(9999);boolean flag true;System.out.println(等待客户端连接---------); // 通过多线程接收多个客户端while (flag){Socket client server.accept();new Thread(new EchoServer(client)).start();}}}客户端还是一样的这里可以锻炼自己重写一遍代码 package Example1908;import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.PrintStream; import java.net.Socket; import java.util.Scanner;//客户端 public class javaDemo {private static final BufferedReader KEYBOARD_INPUT new BufferedReader(new InputStreamReader(System.in));public static String getString(String promp)throws Exception{System.out.print(promp);String input KEYBOARD_INPUT.readLine().trim();return input;}public static void main(String[] args) throws Exception{Socket client new Socket(localhost,9999);Scanner scanner new Scanner(client.getInputStream());PrintStream out new PrintStream(client.getOutputStream());scanner.useDelimiter(\n);boolean flag true;while (flag){String msg getString([客户端]请输入你想要发送的消息).trim();out.println(msg);if (scanner.hasNext()){System.out.println(scanner.next().trim());}if (byebye.equalsIgnoreCase(msg)){flag false;}}scanner.close();out.close();client.close();} }效果展示 服务器端 以下javaDemo2是用户1javaDemo4是用户2 客户端1 客户端2 这种模型是BIO模式但是可以发现这里没有对线程数量的限制也就意味着一旦用户数量急剧增加的时候就会出现性能大幅下降的情况所以需要追加对线程的限制 也就是真正的BIOBlocking Io 阻塞Io的模式 4.UDP程序 UDP传输与Tcp不同的是其面向的是无连接的不可靠的通信如果Tcp是打电话必须要知道对方号码建立连接才能进行通信那么UDP就是在大街上随便喊一嗓子有些人就听得到你说的话也有些人离你太远听不到但是你并不在乎。 这种传输方式常用于游戏之中所谓的丢包就是因为udp并不可靠出现的问题但是这种传输方式非常快延迟低。 UDP常用类有 DatagramPackage的常用方法 方法名描述public DatagramPacket(byte[] buf, int length)构造一个 DatagramPacket 对象使用指定的字节数组作为数据指定的长度作为有效数据的长度。public byte[] getData()获取该 DatagramPacket 对象中的数据字节数组。public int getLength()获取该 DatagramPacket 对象中数据的长度。 DatagramSocket的常用方法 方法名描述DatagramSocket()创建一个未绑定的数据报套接字。DatagramSocket(int port)创建一个绑定到指定端口的数据报套接字。DatagramSocket(int port, InetAddress address)创建一个绑定到指定端口和指定本地 IP 地址的数据报套接字。void send(DatagramPacket packet)发送指定的数据包到目的地。void receive(DatagramPacket packet)接收一个数据包并将其存储在指定的数据包对象中 以下案例实现一个客户端通过udp发送报文到服务器并输出服务器返回值 在上一个服务器开着的前提下 package Example1910;import java.io.BufferedReader; import java.io.InputStreamReader; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.nio.charset.StandardCharsets;public class javaDemo {public static void main(String[] args)throws Exception { // 通过键盘输入数据System.out.println(请输入你想要发送的数据);BufferedReader input new BufferedReader(new InputStreamReader(System.in));String data input.readLine(); // 发送数据包DatagramSocket client new DatagramSocket(9999);DatagramPacket packet new DatagramPacket(data.getBytes(StandardCharsets.UTF_8),0,data.length(), InetAddress.getByName(localhost),9999);client.send(packet); // 接收数据包byte redata[] new byte[1024];DatagramPacket repacket new DatagramPacket(redata,0,redata.length);client.receive(repacket);System.out.println(接收的数据是new String(redata,0,redata.length,StandardCharsets.UTF_8));client.close();} }