客戶(hù)端package project.java;

//客戶(hù)端

//輸入、輸出流分別為處于一個(gè)線程

import java.io.IOException;

import java.io.PrintStream;

import java.net.Socket;

import java.util.Scanner;

class OutToServer2 implements Runnable{

private Socket client;

public OutToServer2(Socket client) {

super();

this.client = client;

}

@Override

public void run() {

PrintStream printStream;

try {

printStream = new PrintStream(client.getOutputStream(),true);

Scanner scanner = new Scanner(System.in);

scanner.useDelimiter("\n");

while(true) {

System.out.println("請(qǐng)輸入：");

while(scanner.hasNext()) {

String string = scanner.nextLine();

printStream.println(string);

if(string.equals("拜拜")) {

System.out.println("客戶(hù)端退出");

printStream.close();

scanner.close();

//client.close();

break;

}

}

}

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

class ReadFromServer2 implements Runnable{

private Socket client;

public ReadFromServer2(Socket client) {

super();

this.client = client;

}

public void run() {

try {

Scanner scanner = new Scanner(client.getInputStream());

scanner.useDelimiter("\n");

while(scanner.hasNext()) {

System.out.println("服務(wù)器端輸入："+scanner.nextLine());

}

} catch (IOException e) {

e.printStackTrace();

}

}

}

public class SingelClient2 {

public static void main(String[] args) {

String serverName = "127.0.0.1";

int port = 6666;

Socket client;

try {

client = new Socket(serverName,port);

Thread ouThread = new Thread(new OutToServer2(client));

Thread inThread = new Thread(new ReadFromServer2(client));

ouThread.start();

inThread.start();

} catch (Exception e) {

e.printStackTrace();

}

}

}

服務(wù)器端package project.java;

import java.io.IOException;

import java.io.PrintStream;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.HashMap;

import java.util.Iterator;

import java.util.Map;

import java.util.Map.Entry;

import java.util.Scanner;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.regex.Matcher;

import java.util.regex.Pattern;

//服務(wù)器端

/**

* Map

* 用戶(hù)注冊(cè)：username:yyy

* 群聊：G:hello

* 私聊：P:yyy-hhh

*/

class ExcuteClientServer1 implements Runnable{

private Socket client;

private Map clientMap;

public ExcuteClientServer1(Socket client, Map clientMap) {

super();

this.client = client;

this.clientMap = clientMap;

}

public void run() {

try {

//拿到客戶(hù)端輸入流，讀取用戶(hù)信息

Scanner scanner = new Scanner(client.getInputStream());

String string = null;

while(true){

if(scanner.hasNext()) {

string = scanner.nextLine();

Pattern pattern = Pattern.compile("\r\n|\r|\n");

Matcher matcher = pattern.matcher(string);

string = matcher.replaceAll("");

//用戶(hù)注冊(cè)

if(string.startsWith("user")) {

//獲取用戶(hù)名

String useName = string.split("\\:")[1];

userRegist(useName, client);

continue;

}

//群聊

else if(string.startsWith("G")) {

String message = string.split("\\:")[1];

gropChat(message);

continue;

}

//私聊

else if(string.startsWith("P")) {

String temp = string.split("\\:")[1];

//取得用戶(hù)名

String useName = temp.split("\\-")[0];

//取得消息內(nèi)容

String message = temp.split("\\-")[1];

privateChat(useName, message);

continue;

}

//用戶(hù)退出

else if(string.contains("拜拜")) {

//先根據(jù)Socket知道用戶(hù)名

String useName = getUseName(client);

System.out.println("用戶(hù)名為"+useName +"的用戶(hù)下線了！！！");

clientMap.remove(useName);

continue;

}

}

}

}catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

//獲取key值(即由端口號(hào)找到用戶(hù)名)

public String getUseName(Socket socket) {

String useName = null;

for(String getKey : clientMap.keySet()) {

if(clientMap.get(getKey).equals(socket)) {

useName = getKey;

}

}

return useName;

}

//注冊(cè)實(shí)現(xiàn)

public void userRegist(String useName,Socket client) {

System.out.println("用戶(hù)姓名為：" + useName);

System.out.println("用戶(hù)socket為：" + client);

System.out.println("用戶(hù)名為"+ useName +"的用戶(hù)上線了！");

System.out.println("當(dāng)前用戶(hù)數(shù)為："+ (clientMap.size()+1) +"人");

clientMap.put(useName, client);

}

//群聊實(shí)現(xiàn)

public void gropChat(String message) {

Iterator> iterable = clientMap.entrySet().iterator();

for(Map.Entry stringSocketEntry:clientMap.entrySet()) {

try {

Socket socket = stringSocketEntry.getValue();

PrintStream printStream = new PrintStream(socket.getOutputStream(),true);

System.out.println("用戶(hù)說(shuō)"+message);

printStream.println(message);

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

//私聊實(shí)現(xiàn)

public void privateChat(String useName,String message) {

//根據(jù)對(duì)應(yīng)的useName找到對(duì)應(yīng)的Socket

Socket privateSocket = clientMap.get(useName);

try {

PrintStream printStream = new PrintStream(privateSocket.getOutputStream());

printStream.println("用戶(hù)名為"+getUseName(client)+"的用戶(hù)對(duì)你說(shuō)："+message);

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

public class SingleServer2 {

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

ServerSocket serverSocket = new ServerSocket(6666);

//存取用戶(hù)信息(用戶(hù)名和Socket)

Map map = new HashMap();

//線程池，線程大小為20

ExecutorService executorService =Executors.newFixedThreadPool(20);

System.out.println("等待客戶(hù)連接中...");

try {

for(int i = 0;i < 20;i ++) {

Socket socket = serverSocket.accept();

System.out.println("有新的用戶(hù)連接："+socket.getInetAddress()+socket.getPort());

executorService.execute(new ExcuteClientServer1(socket,map));

}

executorService.shutdown();

serverSocket.close();

} catch (Exception e) {

}

}

}

總結(jié)

以上是生活随笔為你收集整理的java 聊天室 私聊_Java聊天室——实现多人聊天、私聊、群聊的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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