下面的是服务器端代码:
package 一对一聊天; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import java.util.Scanner; /** * 模拟qq聊天功能: 实现客户端与服务器(一对一)的聊天功能,客户端首先发起聊天,输入的内容在服务器端和客户端显示, * 然后服务器端也可以输入信息,同样信息也在客户端和服务器端显示 */ // 服务器类 public class ChatServer { private int port = 8189;// 默认服务器端口 public ChatServer() { } // 创建指定端口的服务器 public ChatServer(int port) { this.port = port; } // 提供服务 public void service() { try {// 建立服务器连接 ServerSocket server = new ServerSocket(port); // 等待客户连接 Socket socket = server.accept(); try { // 读取客户端传过来信息的DataInputStream DataInputStream in = new DataInputStream(socket .getInputStream()); // 向客户端发送信息的DataOutputStream DataOutputStream out = new DataOutputStream(socket .getOutputStream()); // 获取控制台输入的Scanner Scanner scanner = new Scanner(System.in); while (true) { // 读取来自客户端的信息 String accpet = in.readUTF(); System.out.println(accpet); String send = scanner.nextLine(); System.out.println("服务器:" + send); // 把服务器端的输入发给客户端 out.writeUTF("服务器:" + send); } } finally {// 建立连接失败的话不会执行socket.close(); socket.close(); } } catch (IOException e) { e.printStackTrace(); } } public static void main(String[] args) { new ChatServer().service(); } }
客户端代码:
package 一对一聊天; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.Socket; import java.util.Scanner; /** * 注意用到的输入输出流DataInputStream和DataOutputStream,成对出现,最好用字节流 */ // 客户端类 public class ChatClient { private String host = "localhost";// 默认连接到本机 private int port = 8189;// 默认连接到端口8189 public ChatClient() { } // 连接到指定的主机和端口 public ChatClient(String host, int port) { this.host = host; this.port = port; } public void chat() { try { // 连接到服务器 Socket socket = new Socket(host, port); try { // 读取服务器端传过来信息的DataInputStream DataInputStream in = new DataInputStream(socket .getInputStream()); // 向服务器端发送信息的DataOutputStream DataOutputStream out = new DataOutputStream(socket .getOutputStream()); // 装饰标准输入流,用于从控制台输入 Scanner scanner = new Scanner(System.in); while (true) { String send = scanner.nextLine(); System.out.println("客户端:" + send); // 把从控制台得到的信息传送给服务器 out.writeUTF("客户端:" + send); // 读取来自服务器的信息 String accpet = in.readUTF(); System.out.println(accpet); } } finally { socket.close(); } } catch (IOException e) { e.printStackTrace(); } } public static void main(String[] args) { new ChatClient().chat(); } }
注意,要先运行服务器端代码,再运行客户端。怎么显示2个控制台呢?
我们首先要显示控制台: