Java網絡編程一：Socket用法，簡單模擬一對一聊天

1、socket和serverSocket通信簡單介紹如下，注意客戶端與服務器端是怎麼交換數據的

2、模擬qq聊天功能，實現客戶端與服務器（一對一）的聊天功能

服務器端代碼：

1. package demo.net;
3. import java.io.DataInputStream;
4. import java.io.DataOutputStream;
5. import java.io.IOException;
6. import java.net.ServerSocket;
7. import java.net.Socket;
8. import java.util.Scanner;
10. /**
11. * 模擬qq聊天功能： 實現客戶端與服務器（一對一）的聊天功能，客戶端首先發起聊天，輸入的內容在服務器端和客戶端顯示，
12. * 然後服務器端也可以輸入信息，同樣信息也在客戶端和服務器端顯示
13. */
15. // 服務器類
16. public class ChatServer {
17. private int port = 8189;// 默認服務器端口
19. public ChatServer() {
20. }
22. // 創建指定端口的服務器
23. public ChatServer(int port) {
24. this.port = port;
25. }
27. // 提供服務
28. public void service() {
29. try {// 建立服務器連接
30. ServerSocket server = new ServerSocket(port);
31. // 等待客戶連接
32. Socket socket = server.accept();
33. try {
34. // 讀取客戶端傳過來信息的DataInputStream
35. DataInputStream in = new DataInputStream(socket
36. .getInputStream());
37. // 向客戶端發送信息的DataOutputStream
38. DataOutputStream out = new DataOutputStream(socket
39. .getOutputStream());
40. // 獲取控制台輸入的Scanner
41. Scanner scanner = new Scanner(System.in);
42. while (true) {
43. // 讀取來自客戶端的信息
44. String accpet = in.readUTF();
45. System.out.println(accpet);
46. String send = scanner.nextLine();
47. System.out.println("服務器：" + send);
48. // 把服務器端的輸入發給客戶端
49. out.writeUTF("服務器：" + send);
50. }
51. } finally {// 建立連接失敗的話不會執行socket.close();
52. socket.close();
53. }
54. } catch (IOException e) {
55. e.printStackTrace();
56. }
57. }
59. public static void main(String[] args) {
60. new ChatServer().service();
61. }
62. }

客戶端代碼：

1. package demo.net;
3. import java.io.DataInputStream;
4. import java.io.DataOutputStream;
5. import java.io.IOException;
6. import java.net.Socket;
7. import java.util.Scanner;
9. /**
10. * 注意用到的輸入輸出流DataInputStream和DataOutputStream，成對出現，最好用字節流
11. */
12. // 客戶端類
13. public class ChatClient {
14. private String host = "localhost";// 默認連接到本機
15. private int port = 8189;// 默認連接到端口8189
17. public ChatClient() {
19. }
21. // 連接到指定的主機和端口
22. public ChatClient(String host, int port) {
23. this.host = host;
24. this.port = port;
25. }
27. public void chat() {
28. try {
29. // 連接到服務器
30. Socket socket = new Socket(host, port);
32. try {
33. // 讀取服務器端傳過來信息的DataInputStream
34. DataInputStream in = new DataInputStream(socket
35. .getInputStream());
36. // 向服務器端發送信息的DataOutputStream
37. DataOutputStream out = new DataOutputStream(socket
38. .getOutputStream());
40. // 裝飾標准輸入流，用於從控制台輸入
41. Scanner scanner = new Scanner(System.in);
43. while (true) {
44. String send = scanner.nextLine();
45. System.out.println("客戶端：" + send);
46. // 把從控制台得到的信息傳送給服務器
47. out.writeUTF("客戶端：" + send);
48. // 讀取來自服務器的信息
49. String accpet = in.readUTF();
50. System.out.println(accpet);
51. }
53. } finally {
54. socket.close();
55. }
56. } catch (IOException e) {
57. e.printStackTrace();
58. }
59. }
61. public static void main(String[] args) {
62. new ChatClient().chat();
63. }
64. }

運行結果：

注意運行的時候要先開服務器，再開客戶端，聊天由客戶端發起。運行結果中綠色的字表示輸入。