大體實現(xiàn)功能可以選擇房間，可以與房間中的用戶進(jìn)行實時的交流

說在前面的話:

serverSocket.accept() 會形成阻塞

scanner.hasNextLine() 和 scanner.nextLine() 也會形成阻塞

windows 下需要打開telnet服務(wù)。請自行百度

實現(xiàn)思路:

用戶連接上服務(wù)器后選擇房間號，進(jìn)入房間。進(jìn)入房間后會向房間中所有的用戶打印出用戶進(jìn)入房間的提醒。

用戶進(jìn)入房間后，輸入姓名即可發(fā)言。

說起來很簡單，代碼實現(xiàn)更簡單。我們需要一個保存房間用戶的容器。我這里使用的是。

// 保存聊天室中的用戶數(shù)據(jù)

private static Map>> charScnnerMap = new HashMap<>();

使用 try-with-resource 語法防止出現(xiàn)資源未關(guān)閉的情況出現(xiàn)。

直接上代碼

package com.annie;

import com.sun.org.apache.xml.internal.resolver.readers.ExtendedXMLCatalogReader;

import java.io.*;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.*;

public class App {

// 保存聊天室中的用戶數(shù)據(jù)

private static Map>> charScnnerMap = new HashMap<>();

public static void print(List> charNames, String conn) {

for (Map charName : charNames) {

Set> entries = charName.entrySet();

for (Map.Entry entry : entries) {

entry.getValue().println(conn);

}

}

}

public static void main(String[] args) throws InterruptedException {

charScnnerMap.put("1", new ArrayList>());

charScnnerMap.put("2", new ArrayList>());

charScnnerMap.put("3", new ArrayList>());

// 監(jiān)控本機(jī)端口 9189

try (ServerSocket serverSocket = new ServerSocket(9189)) {

while (true) {

Socket accept = serverSocket.accept();

new Thread(() -> {

try (InputStream inputStream = accept.getInputStream();

OutputStream outputStream = accept.getOutputStream();

Scanner scanner = new Scanner(inputStream, "UTF-8");

PrintWriter out = new PrintWriter(new OutputStreamWriter(outputStream, "UTF-8"), true)) {

// 定位房間

String number = "-1";

out.println("Please enter the room number.(1-3): ");

number = scanner.nextLine();

if (!number.equals("1") && !number.equals("2") && !number.equals("3")) {

while (true) {

out.println("Please enter the correct room.(1-3): ");

number = scanner.nextLine();

if (number.equals("1") || number.equals("2") || number.equals("3")) {

break;

}

}

}

// 顯示姓名

out.println("Please enter your name: ");

String name = scanner.nextLine();

List> charNames = charScnnerMap.get(number);

Map m = new HashMap<>();

m.put(name, out);

charNames.add(m);

// 打印內(nèi)容

print(charNames, "Welcome [" + name + "] to the room.");

boolean b = true;

while (b && scanner.hasNextLine()) {

String s = scanner.nextLine();

print(charNames, name + ": " + s);

if (s.equals("BB")) {

print(charNames, "[" + name + "]Exit the room");

b = false;

}

}

} catch (Exception e) {

e.printStackTrace();

}

}).start();

}

} catch (IOException e) {

e.printStackTrace();

}

}

}

結(jié)尾：如果您覺得這邊文章對您有幫助，麻煩

，

加

。您的支持是對筆者的最大幫助😘😘😘

總結(jié)

以上是生活随笔為你收集整理的java的serversocket_Java ServerSocket 实现聊天室功能（简易版）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。