Java BIO實現(xiàn)聊天程序
更新時間：2021年11月24日 10:16:45 作者：java碩哥
這篇文章主要為大家詳細(xì)介紹了Java BIO實現(xiàn)聊天程序，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下
本文實例為大家分享了Java BIO實現(xiàn)聊天程序的具體代碼，供大家參考，具體內(nèi)容如下
我們使用一個聊天程序來說本文的主題
1、BIO 客戶端服務(wù)器通訊
public class ChatServer {
public static void main(String[] args) throws IOException {
ServerSocket serverSocket = new ServerSocket(9000);
while (true) {
try {
System.out.println("聊天服務(wù)已啟動，等待客戶連接....");
Socket socket = serverSocket.accept();
System.out.printf("建立了與%s的連接!\n",socket.getRemoteSocketAddress());
loopReadRequest(socket);
} catch (IOException e) {
e.printStackTrace();
}
}
}
public static String loopReadRequest(Socket socket) throws IOException {
InputStreamReader reader = new InputStreamReader(socket.getInputStream());
StringBuilder sb = new StringBuilder();
char[] cbuf = new char[256];
// 循環(huán)讀取socket的輸入數(shù)據(jù)流
while (true) {
// read方法，讀出內(nèi)容寫入 char 數(shù)組,read 方法會一直阻塞
// 直到有輸入內(nèi)容 或 發(fā)生I/O錯誤 或 輸入流結(jié)束(對方關(guān)閉了socket)
// 正常讀取時方法會返回讀取的字符數(shù),當(dāng)輸入流結(jié)束時(對方關(guān)閉了socket)方法返回 -1
int readed = reader.read(cbuf);
SocketAddress remoteSocketAddress = socket.getRemoteSocketAddress();
// 客戶端執(zhí)行了socket.close()
if (readed == -1) {
System.out.println(remoteSocketAddress + " 斷開了連接!");
reader.close();
socket.close();
break;
}
String readedStr = new String(cbuf, 0, readed);
sb.append(readedStr);
// ready()用來判斷流是否可被讀取,如果reader緩沖區(qū)不是空則返回true，否則返回false
if (!reader.ready()) {//reader緩沖區(qū)為空，表示數(shù)據(jù)流已讀完
// 數(shù)據(jù)流已讀完,此時向客戶端發(fā)送響應(yīng)
socket.getOutputStream().write((remoteSocketAddress+"你好，"+sb+"已收到").getBytes());
System.out.println("收到內(nèi)容:"+sb);
// 清除sb的內(nèi)容，準(zhǔn)備接收下一個請求內(nèi)容
sb.setLength(0);
System.out.println("等待客戶端消息....");
}
}
return sb.toString();
}
}
public class ChatClient {
public static void main(String[] args) {
try {
Socket socket = new Socket("localhost", 9000);
Scanner scanner = new Scanner(System.in);
while (true) {
System.out.print(">");
String line = scanner.nextLine();
if("".equals(line)){
continue;
}
if ("quit".equals(line)) {
scanner.close();
socket.close();
break;
}
socket.getOutputStream().write(line.getBytes());
System.out.println(readRequest(socket));
}
} catch (IOException e) {
e.printStackTrace();
}
}
public static String readRequest(Socket socket) throws IOException {
InputStreamReader reader = new InputStreamReader(socket.getInputStream());
StringBuilder sb = new StringBuilder();
char[] cbuf = new char[256];
while (true) {
int readed = reader.read(cbuf);
// 讀出內(nèi)容寫入 char 數(shù)組,read 方法會一直阻塞
// 直到有輸入內(nèi)容 或 發(fā)生I/O錯誤 或 輸入流結(jié)束(對方關(guān)閉了socket)
// 正常讀取，方法會返回讀取的字符數(shù)，而當(dāng)輸入流結(jié)束(對方關(guān)閉了socket)則返回 -1
if (readed == -1) {
System.out.println(socket.getRemoteSocketAddress() + " 斷開了連接!");
reader.close();
socket.close();
break;
}
String readedStr = new String(cbuf, 0, readed);
sb.append(readedStr);
if(!reader.ready()){
break;
}
}
return sb.toString();
}
}
ChatServer與ChatClient建立了長連接，且ChatServer阻塞等待ChatClient發(fā)送消息過來，程序中 Server端只能與一個Client建立連接。程序這么寫，只能實現(xiàn)一個客戶端和服務(wù)端進(jìn)行通信。
如何支持多個Client的連接呢？ 使用獨(dú)立的線程去讀取socket
2、多線程實現(xiàn)單聊，群聊
單聊發(fā)送 格式：-c 對方端口號 消息內(nèi)容， 群聊直接發(fā)送信息就可以了，具體發(fā)送邏輯看下面的程序
public class ChatServer {
private static Map<String, Socket> connnectedSockets = new ConcurrentHashMap<>();
public static void main(String[] args) throws IOException {
// 1、服務(wù)端初始化工作
ServerSocket serverSocket = new ServerSocket(9000);
ExecutorService executorService = getExecutorService();
// 2、主線程- 循環(huán)阻塞接收新的連接請求
while (true) {
Socket socket = serverSocket.accept();
cacheSocket(socket);
// 3、一個socket對應(yīng)一個讀取任務(wù),交給線程池中的線程執(zhí)行
// 如果使用fixed線程池,會操作讀取任務(wù)分配不到線程的情況
// 現(xiàn)象就是發(fā)送的消息別人收不到（暫存在Socket緩存中）
executorService.submit(createLoopReadTask(socket));
}
}
private static Runnable createLoopReadTask(Socket socket) {
return new Runnable() {
public void run() {
try {
loopReadRequestAndRedirect(socket);
} catch (IOException e) {
e.printStackTrace();
}
}
};
}
private static ExecutorService getExecutorService() {
ExecutorService executorService = Executors.newCachedThreadPool();
int nThreads = Runtime.getRuntime().availableProcessors();
nThreads = 1;
// 如果只設(shè)置一個線程，那么最先連接進(jìn)來的客戶端可以發(fā)送消息
// 因為程序阻塞讀取第一個socket連接的數(shù)據(jù)流，沒有其他線程資源去讀后面建立的socket了
executorService = Executors.newFixedThreadPool(nThreads);
return executorService;
}
private static void cacheSocket(Socket socket) {
SocketAddress remoteSocketAddress = socket.getRemoteSocketAddress();
String[] split = remoteSocketAddress.toString().split(":");
connnectedSockets.put(split[1], socket);
}
public static String loopReadRequestAndRedirect(Socket socket) throws IOException {
InputStreamReader reader = new InputStreamReader(socket.getInputStream());
StringBuilder sb = new StringBuilder();
char[] cbuf = new char[256];
while (true) {
SocketAddress remoteSocketAddress = socket.getRemoteSocketAddress();
System.out.println(Thread.currentThread() + "執(zhí)行 " + remoteSocketAddress + "發(fā)送的消息");
// 讀出內(nèi)容寫入 char 數(shù)組,read 方法會一直阻塞
// 直到有輸入內(nèi)容 或 發(fā)生I/O錯誤 或 輸入流結(jié)束(對方關(guān)閉了socket)
// 正常讀取時方法會返回讀取的字符數(shù)，當(dāng)輸入流結(jié)束(對方關(guān)閉了socket)時返回 -1
int readed = reader.read(cbuf);
if (readed == -1) {
System.out.println(remoteSocketAddress + " 斷開了連接!");
reader.close();
socket.close();
break;
}
String readedStr = new String(cbuf, 0, readed);
sb.append(readedStr);
//ready()用來判斷流是否可被讀取,如果reader緩沖區(qū)不是空則返回true，否則返回false
boolean oneReqeustStreamReaded = !reader.ready();
if (oneReqeustStreamReaded) {
String requestContent = sb.toString().trim();
String prifix = requestContent.substring(0, 2);
// 單聊
if ("-c".equals(prifix)) {
requestContent = requestContent.substring(3);
String port = requestContent.substring(0, requestContent.indexOf(" "));
requestContent = requestContent.replaceFirst(port, "");
sendToOneSocket(connnectedSockets.get(port), requestContent);
// 群聊
} else {
// 向客戶端發(fā)送響應(yīng)
socket.getOutputStream().write(("您發(fā)送的消息-'" + sb + "' 已收到").getBytes());
sendToAllSocket(sb.toString(), socket);
}
sb.setLength(0);
}
}
return sb.toString();
}
/**
* 發(fā)送消息給某個socket
*
* @param socket
* @param msg
*/
private static void sendToOneSocket(Socket socket, String msg) {
// 對于同一個socket,同一時刻只有一個線程使用它發(fā)送消息
synchronized (socket) {
try {
socket.getOutputStream().write(msg.getBytes("UTF-8"));
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* 發(fā)送消息給所有的socket
*
* @param msg
*/
private static void sendToAllSocket(String msg, Socket selfSocket) {
for (String key : connnectedSockets.keySet()) {
Socket socket = connnectedSockets.get(key);
if (socket.equals(selfSocket)) {
continue;
}
sendToOneSocket(socket, msg);
}
}
}
public class ChatClient {
public static void main(String[] args) throws IOException {
new ChatClient().start();
}
public void start() throws IOException {
Socket socket = new Socket("localhost", 9000);
ExecutorService executorService = Executors.newFixedThreadPool(2);
Runnable readTask = new Runnable() {
public void run() {
try {
loopReadRequest(socket);
} catch (IOException e) {
e.printStackTrace();
}
}
};
executorService.submit(readTask);
Runnable sendMsgTask = new Runnable() {
public void run() {
try {
Scanner scanner = new Scanner(System.in);
while (true) {
System.out.print(">");
String line = scanner.nextLine();
if ("".equals(line)) {
continue;
}
if ("quit".equals(line)) {
scanner.close();
socket.close();
break;
}
socket.getOutputStream().write(line.getBytes());
}
} catch (IOException e) {
e.printStackTrace();
}
}
};
executorService.submit(sendMsgTask);
}
public void loopReadRequest(Socket socket) throws IOException {
InputStreamReader reader = new InputStreamReader(socket.getInputStream());
StringBuilder sb = new StringBuilder();
char[] cbuf = new char[256];
while (true) {
int readed = reader.read(cbuf);
// 讀出內(nèi)容寫入 char 數(shù)組,read 方法會一直阻塞
// 直到有輸入內(nèi)容 或 發(fā)生I/O錯誤 或 輸入流結(jié)束(對方關(guān)閉了socket)
// 正常讀取，方法會返回讀取的字符數(shù)，而當(dāng)輸入流結(jié)束(對方關(guān)閉了socket)則返回 -1
if (readed == -1) {
System.out.println(socket.getRemoteSocketAddress() + " 斷開了連接!");
reader.close();
socket.close();
break;
}
String readedStr = new String(cbuf, 0, readed);
sb.append(readedStr);
if (!reader.ready()) {
System.out.println(sb);
sb.setLength(0);
}
}
}
}
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
MyBatis 執(zhí)行動態(tài) SQL語句詳解
大家對mybatis執(zhí)行任意sql語句都了解，那么MyBatis執(zhí)行動態(tài)SQL語句呢？下面腳本之家小編給大家解答下mybatis執(zhí)行動態(tài)sql語句的方法，非常不錯，感興趣的朋友參考下吧2016-08-08
這篇文章主要為大家詳細(xì)介紹了Java的構(gòu)造方法及類的初始化，文中的示例代碼講解詳細(xì)，對我們學(xué)習(xí)Java有一定的幫助，感興趣的小伙伴可以了解一下2022-08-08
模仿J2EE的session機(jī)制的App后端會話信息管理實例
下面小編就為大家分享一篇模仿J2EE的session機(jī)制的App后端會話信息管理實例，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2017-11-11
下面小編就為大家?guī)硪黄猨ava修飾類的使用方法以及使用技巧(分享)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-01-01
java -jar命令是一種方便快捷地在命令行中運(yùn)行Java可執(zhí)行jar文件的方法,本文主要介紹了java -jar命令的具體使用,具有一定的參考價值,感興趣的可以了解一下2024-03-03
這篇文章主要介紹了mybatis中使用not?in與?in的寫法說明，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-01-01
Java語言是一個面向?qū)ο蟮恼Z言，但是Java中的基本數(shù)據(jù)類型卻是不面向?qū)ο蟮模@在實際使用時存在很多的不便，所以在設(shè)計類時為每個基本數(shù)據(jù)類型設(shè)計了一個對應(yīng)的類進(jìn)行代表，這樣八個和基本數(shù)據(jù)類型對應(yīng)的類統(tǒng)稱為包裝類，有些地方也翻譯為外覆類或數(shù)據(jù)類型類。2017-02-02
在java中main()方法是java應(yīng)用程序的入口方法，由此可見main方法是很重要的，那么下面這篇文章就給大家詳解介紹了Java中的main()方法,需要的朋友可以參考下。2016-09-09
下面小編就為大家?guī)硪黄昝澜鉀Q單例設(shè)計模式中懶漢式線程安全的問題。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2016-12-12
springboot post接口接受json時,轉(zhuǎn)換為對象時,屬性都為null的解決
這篇文章主要介紹了springboot post接口接受json時,轉(zhuǎn)換為對象時,屬性都為null的解決，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-10-10