本文实例为大家分享了Java实现在线聊天功能的具体代码,供大家参考,具体内容如下 效果 关键代码 创建 Client.java import java.io.IOException;import java.net.Socket;import java.net.UnknownHostException;/
本文实例为大家分享了Java实现在线聊天功能的具体代码,供大家参考,具体内容如下
效果
关键代码
创建Client.java
import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException; /** * @author Lete * @乐特的程序永无BUG * @createDate 2020- 07-04 22:13 * * 1. SendThread 发送消息线程 * 2. RecieveThread 接受消息线程 */ public class Client { public static void main(String[] args) { try { // 创建8888端口 Socket s = new Socket("127.0.0.1", 8888); // 启动发送消息线程 new SendThread(s).start(); // 启动接受消息线程 new RecieveThread(s).start(); } catch (UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
创建Server.java
import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; /** * @author Lete * @乐特的程序永无BUG * @createDate 2020- 07-04 22:13 * * 1. SendThread 发送消息线程 * 2. RecieveThread 接受消息线程 */ public class Server { public static void main(String[] args) { try { // 监听8888端口 ServerSocket ss = new ServerSocket(8888); System.out.println("监听在端口号:8888"); Socket s = ss.accept(); //启动发送消息线程 new SendThread(s).start(); //启动接受消息线程 new RecieveThread(s).start(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
创建RecieveThread.java
import java.io.*; import java.net.Socket; /** * @author Lete * @乐特的程序永无BUG * @createDate 2020- 07-04 22:13 * * 1. SendThread 发送消息线程 * 2. RecieveThread 接受消息线程 */ public class RecieveThread extends Thread { private Socket s; public RecieveThread(Socket s) { this.s = s; } public void run() { try { // 接收对方输入的内容 InputStream is = s.getInputStream(); DataInputStream dis = new DataInputStream(is); while (true) { String msg = dis.readUTF(); System.out.println(msg); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
创建SendThread.java
import java.io.*; import java.net.Socket; import java.util.Scanner; /** * @author Lete * @乐特的程序永无BUG * @createDate 2020- 07-04 22:13 * * 1. SendThread 发送消息线程 * 2. RecieveThread 接受消息线程 */ public class SendThread extends Thread { private Socket s; public SendThread(Socket s) { this.s = s; } public void run() { try { // 获取输入的内容 OutputStream os = s.getOutputStream(); DataOutputStream dos = new DataOutputStream(os); while (true) { Scanner sc = new Scanner(System.in); String str = sc.next(); dos.writeUTF(str); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持自由互联。