齐齐哈尔铁峰建设局网站,济南装修公司排名前十强,环保网站建设的目的,wordpress媒体文件位置TCP和UDP通信——多发多收
UDP通信
1.客户端可以反复发送数据
客户端实现步骤 #xff08;1#xff09;创建DatagramSocket对象#xff08;发送端对象#xff09; #xff08;2#xff09;使用while死循环不断的接收用户的数据输入#xff0c;如果用户输入”886”则退…TCP和UDP通信——多发多收
UDP通信
1.客户端可以反复发送数据
客户端实现步骤 1创建DatagramSocket对象发送端对象 2使用while死循环不断的接收用户的数据输入如果用户输入”886”则退出程序 3使用DatagramSocket对象的send方法将数据包对象进行发送 4释放资源 public class UDPClient {public static void main(String[] args) throws IOException {Scanner sc new Scanner(System.in);DatagramSocket client new DatagramSocket(); //使用随机端口while (true) {//发送的信息由键盘录入System.out.println(请输入聊天内容);String info sc.next();byte[] bytes info.getBytes();DatagramPacket dp new DatagramPacket(bytes,bytes.length,InetAddress.getByName(127.0.0.1),20000);client.send(dp);//循环发送如果输入886退出if (info.contains(886)) {System.out.println(正在下线..);client.close();break;}}}
}2.接收端可以反复接收数据
1.接受端可以反复接收数据
接收端实现步骤 1创建DatagramSocket对象并指定端口接收端对象 2创建DatagramSocket对象接收数据数据包对象 3使用DatagramSocket对象的receive方法传入DatagramPacket对象 4暂且不释放资源使用while死循环不断的进行第3步 public class UDPServer {public static void main(String[] args) throws IOException {System.out.println( 聊天室 );DatagramSocket server new DatagramSocket(20000);//循环接收while (true) {byte[] bytes new byte[1024];DatagramPacket dp new DatagramPacket(bytes, bytes.length);server.receive(dp);//展示数据System.out.println(new String(bytes,0, dp.getLength()));//DatagramPacket对象获取客户端其他信息System.out.println(dp.getAddress().getHostAddress() / dp.getPort());//不要关闭服务器Socket对象否则只能接一次System.out.println(-------------------);}}
}TCP通信
1.客户端可以反复发送数据
实现步骤 1客户端使用死循环让用户不断输入消息 2服务端也使用死循环控制服务端接收完消息继续等到接收下一个消息 public class TCPClient {public static void main(String[] args) throws Exception {Scanner sc new Scanner(System.in);Socket client new Socket(127.0.0.1, 8888);OutputStream os client.getOutputStream();DataOutputStream dos new DataOutputStream(os);while (true) {System.out.println(请输入联调内容);String info sc.next();dos.writeUTF(info);dos.flush();//循环发送如果输入886退出if (info.contains(886)) {System.out.println(正在下线..);client.close();dos.close();break;}}}
}2.接收端可以反复接收数据
public class TCPServer {public static void main(String[] args) throws Exception {System.out.println( 聊天室 );ServerSocket server new ServerSocket(8888);Socket serverSocket server.accept();InputStream is serverSocket.getInputStream();DataInputStream dis new DataInputStream(is);//循环接收while (true) {try {String info dis.readUTF(); //有用户下线会抛异常SocketExceptionSystem.out.println(info);} catch (Exception e) {//有人下线则释放资源System.out.println(serverSocket.getRemoteSocketAddress() 离线了);System.out.println(-----------------------);server.close();dis.close();break;}}}
}TCP通信-支持与多个客户端同时通信多线程
如何实现服务端同时接收多个客户端的消息的
主线程定义了循环负责接收客户端Socket管道连接没接收到一个Socket通信管道后分配给一个独立的线程负责处理它
客户端
public class TCPClient {public static void main(String[] args) throws Exception {Scanner sc new Scanner(System.in);Socket client new Socket(127.0.0.1, 8888);OutputStream os client.getOutputStream();DataOutputStream dos new DataOutputStream(os);while (true) {System.out.println(请输入联调内容);String info sc.next();dos.writeUTF(info);dos.flush();//循环发送如果输入886退出if (info.contains(886)) {System.out.println(正在下线..);client.close();dos.close();break;}}}
}任务类封装本次连接的客户端要完成的逻辑
public class ServerThread implements Runnable {//serverSocket本次连接的客户端的Socket对象private Socket serverSocket;public ServerThread(Socket serverSocket) {this.serverSocket serverSocket;}Overridepublic void run() {try {//接收数据InputStream is serverSocket.getInputStream();DataInputStream dis new DataInputStream(is);//循环接收while (true) {try {String info dis.readUTF(); //有用户下线会抛异常SocketExceptionSystem.out.println(info);} catch (Exception e) {//有人下线则释放资源System.out.println(serverSocket.getRemoteSocketAddress() 离线了);System.out.println(-----------------------);serverSocket.close();dis.close();break;}}} catch (IOException e) {e.printStackTrace();}}
}服务端使用线程循环接收
package com.demo12_TCP多发多收_多线程实现;// TODO: 能够完成TCP通信下服务端可以同时接收多个客户端的消息import java.net.ServerSocket;
import java.net.Socket;public class TCPServer {public static void main(String[] args) throws Exception {System.out.println( 聊天室 );ServerSocket server new ServerSocket(8888);while (true) {Socket serverSocket server.accept();//每当服务器监听到一个连接请求获取serverSocket对象开启一个线程处理任务new Thread(new ServerThread(serverSocket)).start();}}
}
