java聊天室私聊（java实现聊天室私聊）
华为云服务器特价优惠火热进行中！ 2核2G2兆仅需 38 元；4核4G3兆仅需 79 元。购买时间越长越优惠！更多配置及优惠价格请咨询客服。
合作流程： |
本篇文章给大家谈谈java聊天室私聊，以及java实现聊天室私聊对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。
微信号：cloud7591如需了解更多，欢迎添加客服微信咨询。
复制微信号
本文目录一览：
- 1、java实现聊天室是怎么做到的？
- 2、用Java实现一个人和几个不同的人私聊，用Socket实现
- 3、我做java的简易聊天室，已经可以群聊和私聊，如何把创建房间加进去，且只能同一个房间里才能群聊和私聊？
- 4、怎么用java实现聊天室的私聊功能
- 5、如何用java做一个聊天小程序 要求使用图形用户界面,可以实现一个聊天室中多人聊天,也可以两人私聊,
java实现聊天室是怎么做到的？
Java实现聊天室可以采用网络编程中的Socket和ServerSocket技术来实现。具体实现步骤如下：
服务器端创建ServerSocket对象，并指定一个端口号来监听客户端的连接请求。
客户端创建Socket对象，并指定服务器端的IP地址和端口号来连接服务器。
服务器端通过ServerSocket.accept()方法等待客户端的连接请求，当有新的连接请求到达时，创建一个新的线程来处理该客户端的请求，并将该线程加入到线程池中。
客户端连接服务器后，通过Socket.getInputStream()方法获取输入流，并通过Socket.getOutputStream()方法获取输出流，向服务器发送消息或接收来自服务器的消息。
服务器端通过线程池中的线程来处理客户端的请求，服务器可以实现广播功能，将接收到的客户端消息转发给其他所有客户端，也可以实现点对点的私聊功能。
当客户端退出聊天室时，需要关闭相应的Socket连接，并通知其他客户端该客户端已经离开。
聊天室中的消息可以使用特定的格式进行编码和解码，以便服务器端和客户端可以正确地解析和处理消息。
需要注意的是，在实现聊天室时需要考虑线程安全、消息编解码、异常处理等问题，以确保聊天室的稳定和可靠性。同时，还需要进行充分的测试和优化，以提高聊天室的性能和用户体验。
用Java实现一个人和几个不同的人私聊，用Socket实现
package API_Day09;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
/**
* 控制台聊天程序
* 客户端应用程序
* @author Jacob
*
*/
public class chatClient
{
//客户端用于与服务端连接的Socket
private Socket clientSocket;
/**
* 构造方法，客户端初始化
*/
public chatClient()
{
try
{
/*
* socket(String host, int port)
* 地址： IP地址，用来定位网络上的计算机
* 端口： 用来找到远端计算机上用来连接的服务端应用程序
*/
clientSocket = new Socket("localhost",12580);
}
catch (Exception e)
{
e.printStackTrace();
}
}
/**
* 客户端昵称验证方法
* @param 为Scanner
*/
private void inputNickName(Scanner scan) throws Exception
{
String nickName = null;
//创建输出流
PrintWriter pw = new PrintWriter(
new OutputStreamWriter(clientSocket.getOutputStream(),
"UTF-8"),true);
//创建输入流
BufferedReader br = new BufferedReader(
new InputStreamReader(
clientSocket.getInputStream(),"UTF-8"));
while(true)
{
System.out.println("请创建您的昵称：");
nickName = scan.nextLine();
if (nickName.trim().equals(""))
{
System.out.println("昵称不得为空");
}
else
{
pw.println(nickName);
String pass = br.readLine();
if(pass!=null!pass.equals("OK"))
{
System.out.println("昵称已经被占用，请更换！");
}
else
{
System.out.println("你好！"+nickName+"可以开始聊天了");
break;
}
}
}
}
/*
* 客户端启动的方法
*/
public void start()
{
try
{
/*
* 创建Scanner，读取用户输入内容
* 目的是设置客户端的昵称
*/
Scanner scanner = new Scanner(System.in);
inputNickName(scanner);
/*
* 将用于接收服务器端发送过来的信息的线程启动
*/
Runnable run = new GetServerMsgHandler();
Thread t = new Thread(run);
t.start();
/*
* 建立输出流，给服务端发信息
*/
OutputStream os = clientSocket.getOutputStream();
OutputStreamWriter osw = new OutputStreamWriter(os,"UTF-8");
PrintWriter pw = new PrintWriter(osw,true);
while(true)
{
pw.println(scanner.nextLine());
}
}
catch(Exception e)
{
e.printStackTrace();
}
finally
{
if(clientSocket !=null)
{
try
{
clientSocket.close();
}
catch(IOException e)
{
e.printStackTrace();
}
}
}
}
/**
* 该线程体用来循环读取服务端发送过来的信息
* 并输出到客户端的控制台
* @param args
*/
class GetServerMsgHandler implements Runnable
{
@Override
public void run()
{
try
{
InputStream is = clientSocket.getInputStream();
InputStreamReader isr = new InputStreamReader(is,"UTF-8");
BufferedReader br = new BufferedReader(isr);
String msgString = null;
while((msgString = br.readLine())!= null)
{
System.out.println("服务端提示："+ msgString);
}
}
catch(Exception e)
{
e.printStackTrace();
}
}
}
public static void main(String[] args)
{
chatClient client = new chatClient();
client.start();
}
}
package API_Day09;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* 控制台聊天程序
* 服务端应用程序
* @author Jacob
*
*/
public class chatServer
{
/**
* ServerSocket 是运行在服务端的Socket
* 用来监听端口，等待客户端的连接，
* 一旦连接成功就会返回与该客户端通信的Socket
*/
private ServerSocket serverSocket;
/**
* 创建线程池来管理客户端的连接线程
* 避免系统资源过度浪费
*/
private ExecutorService threadPool;
/**
* 该属性用来存放客户端之间私聊的信息
*/
private MapString,PrintWriter allOut;
/**
* 构造方法，服务端初始化
*/
public chatServer()
{
try
{
/*
* 创建ServerSocket，并申请服务端口
* 将来客户端就是通过该端口连接服务端程序的
*/
serverSocket = new ServerSocket(12580);
/*
* 初始化Map集合，存放客户端信息
*/
allOut = new HashMapString, PrintWriter();
/*
* 初始化线程池，设置线程的数量
*/
threadPool = Executors.newFixedThreadPool(10);
/*
* 初始化用来存放客户端输出流的集合，
* 每当一个客户端连接，就会将该客户端的输出流存入该集合；
* 每当一个客户端断开连接，就会将集合中该客户端的输出流删除；
* 每当转发一条信息，就要遍历集合中的所有输出流(元素)
* 因此转发的频率高于客户端登入登出的频率，
* 还是应该使用ArrayList来存储元素，仅限群聊，私聊不行
* allOut = new ArrayListPrintWriter();
*/
}
catch (Exception e)
{
e.printStackTrace();
}
}
/*
* 将客户端的信息以Map形式存入集合中
*/
private void addOut(String key,PrintWriter value)
{
synchronized(this)
{
allOut.put(key, value);
}
}
/*
* 将给定的输出流从共享集合中删除
* 参数为客户端nickName,作为Map的key键
*/
private synchronized void removeOut(String key)
{
allOut.remove(key);
System.out.println("当前在线人数为："+ allOut.size());
}
/*
* 将给定的消息转发给所有客户端
*/
private synchronized void sendMsgToAll(String message)
{
for(PrintWriter out: allOut.values())
{
out.println(message);
System.out.println("当前在线人数为："+ allOut.size());
}
}
/*
* 将给定的消息转发给私聊的客户端
*/
private synchronized void sendMsgToPrivate(String nickname,String message)
{
PrintWriter pw = allOut.get(nickname); //将对应客户端的聊天信息取出作为私聊内容发送出去
if(pw!=null)
{
pw.println(message);
System.out.println("当前在线私聊人数为："+ allOut.size());
}
}
/**
* 服务端启动的方法
*/
public void start()
{
try
{
while(true)
{
/*
* 监听10086端口
*/
System.out.println("等待客户端连接... ... ");
/*
* Socket accept() 这是一个阻塞方法，会一直在10086端口进行监听
* 直到一个客户端连接上，此时该方法会将与这个客户端进行通信的Socket返回
*/
Socket socket = serverSocket.accept();
System.out.println("客户端连接成功！ ");
/*
* 启动一个线程，由线程来处理客户端的请求，这样可以再次监听
* 下一个客户端的连接了
*/
Runnable run = new GetClientMsgHandler(socket);
threadPool.execute(run); //通过线程池来分配线程
}
}
catch(Exception e)
{
e.printStackTrace();
}
}
/**
* 该线程体用来处理给定的某一个客户端的消息，循环接收客户端发送
* 的每一个字符串，并输出到控制台
* @author Jacob
*
*/
class GetClientMsgHandler implements Runnable
{
/*
* 该属性是当前线程处理的具体的客户端的Socket
* @see java.lang.Runnable#run()
*/
private Socket socket;
/*
* 获取客户端的地址信息
* private String hostIP;
*/
/*
* 获取客户端的昵称
*/
private String nickName;
/*
* 创建构造方法
*/
public GetClientMsgHandler(Socket socket)
{
this.socket = socket;
/*
* 获取远端客户的Ip地址信息
* 保存客户端的IP地址字符串
* InetAddress address = socket.getInetAddress();
* hostIP = address.getHostAddress();
*/
}
/*
* 创建内部类来获取昵称
*/
private String getNickName() throws Exception
{
try
{
//服务端的输入流读取客户端发送来的昵称输出流
InputStream iin = socket.getInputStream();
InputStreamReader isr =
new InputStreamReader(iin,"UTF-8");
BufferedReader bReader = new BufferedReader(isr);
//服务端将昵称验证结果通过自身的输出流发送给客户端
OutputStream out = socket.getOutputStream();
OutputStreamWriter iosw =
new OutputStreamWriter(out,"UTF-8");
PrintWriter ipw = new PrintWriter(iosw,true);
//读取客户端发来的昵称
String nameString = bReader.readLine();
while(true)
{
if(nameString.trim().length()==0)
{
ipw.println("FAIL");
}
if(allOut.containsKey(nameString))
{
ipw.println("FAIL");
}
else
{
ipw.println("OK");
return nameString;
}
nameString = bReader.readLine();
}
}
catch(Exception e)
{
throw e;
}
}
@Override
public void run()
{
PrintWriter pw = null;
try
{
/*
* 通过客户端的Socket获取客户端的输出流
* 用来将消息发送给客户端
*/
OutputStream os = socket.getOutputStream();
OutputStreamWriter osw = new OutputStreamWriter(os,"UTF-8");
pw = new PrintWriter(osw,true);
/*
* 将客户昵称和其所说的话作为元素存入共享集合HashMap中
*/
nickName = getNickName();
addOut(nickName, pw);
Thread.sleep(100);
/*
* 服务端通知所有客户端，某用户登录
*/
sendMsgToAll("[系统通知]：欢迎**"+nickName+"**登陆聊天室!");
/*
* 通过客户端的Socket获取输入流
* 读取客户端发送来的信息
*/
InputStream is = socket.getInputStream();
InputStreamReader isr = new InputStreamReader(is,"UTF-8");
BufferedReader br = new BufferedReader(isr);
String msgString = null;
while((msgString = br.readLine())!=null)
{
//验证是否是私聊
if(msgString.startsWith("@"))
{
/*
* 私聊格式：@昵称：内容
*/
int index = msgString.indexOf(":");
if(index =0)
{
//获取昵称
String name = msgString.substring(1,index);
String info = msgString.substring(index+1,msgString.length());
info = nickName + "对你说："+ info;
//将私聊信息发送出去
sendMsgToPrivate(name, info);
//服务端不在广播私聊的信息
continue;
}
}
/*
* 遍历所有输出流，将该客户端发送的信息转发给所有客户端
*/
System.out.println(nickName+"说："+ msgString);
sendMsgToAll(nickName+"说："+ msgString);
}
}
catch (Exception e)
{
/*
* 因为Win系统用户的客户端断开连接后，br.readLine()方法读取
* 不到信息就会抛出异常，而Linux系统会持续发送null；
* 因此这里就不在将捕获的异常抛出了。
*/
}
finally
{
/*
* 当执行到此处时，说明客户端已经与服务端断开连接
* 则将该客户端存在共享集合中的输出流删除
*/
removeOut(nickName);
/*
* 通知所有客户端，某某客户已经下线
*/
sendMsgToAll("[系统通知]："+nickName + "已经下线了。");
/*
* 关闭socket，则通过Socket获取的输入输出流也一同关闭了
*/
if(socket!=null)
{
try
{
socket.close();
}
catch(IOException e)
{
e.printStackTrace();
}
}
}
}
}
public static void main(String[] args)
{
chatServer server = new chatServer();
server.start();
}
}
我的作业，供你参考
我做java的简易聊天室，已经可以群聊和私聊，如何把创建房间加进去，且只能同一个房间里才能群聊和私聊？
我说下思路：
1、客户端创建房间时给每个房间分配惟一的一个房间ID，房间是公开的，每个连接的客户端都可以看到，房间属性，比如密码，比如黑名单，房间保存在Server内存当中，如果你使用了集群，建议存储到分布式缓存当中(Redis是最好的选择，其次是memcached)，当创建完成后，将房间信息发送给所有客户端。新客户端连接进来时，客户端要主动从服务端拉取房间信息。建议采用服务端主动通知（房间增减，服务端主动通知给所有客户端）和客户端定时轮询（客户端起个定时任务，每隔一定时间主动向服务端拉取房间列表）的方式来保证房间列表的动态更新。
2、当客户端选择加入房间时，如果设置有加入条件，比如密码，那就提示客户端输入，如果是其他条件就判断加入客户端是否符合这个条件。服务端保存房间同客户端的关联关系（可以设计成一对多，也就是一个客户端只能在一个房间聊天，也可以设计成多对多，一个客户端可以同时加入多个房间聊天，主要看设计），并将这个消息通知给这个房间所有的客户端列表“欢迎***进入房间”（消息的发送者为系统，房间ID这个房间的ID，接收人无，表示是这个房间的公开消息，消息内容即：欢迎***进入房间。）
3、把聊天内容当成消息的话，那消息应该有这样的属性，发送人，房间ID（如果没有房间ID就当成系统公告消息，在所有房间显示），接收人（如果没有指定接收人，则是公开消息，如果有接收人，就是私聊消息，只能在同一个房间私聊，那在发消息的时候要判断下接收客户端的是否在这个房间列表当中）。
4、再来说消息路由设置，当客户端发送消息时，根据房间ID，找到这个这个房间内所有的客户端列表，如果没有指定接收人，那消息就推送给这个房间关联的所有客户端，如果指定有接收人，接收人不在这个房间，直接提示“***已经离开”，如果还在就把消息推送给这个指定的客户端。
5、房间的管理：踢人，把这个客户端从房间同客户端关联关系解除，并在房间显示消息“***被踢出房间”等等
怎么用java实现聊天室的私聊功能
不知道你们群聊是不是这么实现的？
一个用户群聊/一个用户要看到所有人发的信息，都需要通过服务器来转发。而群聊就是服务器把每一个用户说的话都转发给你看。
那么私聊就是
客户端发送 ip/私聊的话，发给服务器 服务器按一定格式进行拆分。拆完成单独的 IP和 私聊的话。然后发送给那个指定Ip。
如何用java做一个聊天小程序 要求使用图形用户界面,可以实现一个聊天室中多人聊天,也可以两人私聊,
给你一个简单的实现吧，注意一定要先运行MyServer.java
//MyCilent.java
import java.io.*;
import java.net.*;
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
public class MyClient extends JFrame implements ActionListener{
JTextField tf;
JTextArea tx;
JButton bt;
PrintWriter out;
public MyClient(){
tf=new JTextField(20);
tx=new JTextArea();
tx.setLineWrap(true);
tx.setWrapStyleWord(true);
JPanel pan=new JPanel();
JScrollPane jsp=new JScrollPane(tx);
add(jsp,"Center");
bt=new JButton("SEND");
bt.addActionListener(this);
pan.add(tf);
pan.add(bt);
add(pan,"South");
this.addWindowListener(new WindowAdapter(){
public void windowClosing(WindowEvent e){
System.exit(0);
}
});
setTitle("THE CLIENT");
setSize(400,300);
setVisible(true);
try{
Socket socket=new Socket("127.0.0.1",1680);
out=new PrintWriter(socket.getOutputStream(),true);
InputStreamReader in = new InputStreamReader(socket.getInputStream());
BufferedReader sin=new BufferedReader(in);
String s;
while(true){
s=sin.readLine();
tx.append("#Server Said#: "+s+"\n");
}
}catch(Exception e){
e.printStackTrace();
}
}
public void actionPerformed(ActionEvent e){
if(e.getSource()==bt){
tx.append("@Client Said@: "+tf.getText()+"\n");
out.println(tf.getText());
tf.setText("");
}
}
public static void main(String[] args){
MyClient mct = new MyClient();
}
}
//MyServer.java
import java.io.*;
import java.net.*;
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
public class MyServer extends JFrame implements ActionListener{
JTextField tf;
JTextArea tx;
JButton bt;
JScrollPane jsp;
JPanel pan;
PrintWriter out;
public MyServer(){
tx=new JTextArea();
tx.setLineWrap(true);
tx.setWrapStyleWord(true);
jsp=new JScrollPane(tx);
tf=new JTextField(20);
bt=new JButton("SEND");
bt.addActionListener(this);
pan=new JPanel();
pan.add(tf);
pan.add(bt);
add(pan,"South");
add(jsp,"Center");
this.addWindowListener(new WindowAdapter(){
public void windowClosing(WindowEvent e){
System.exit(0);
}
});
setTitle("THE SERVER");
setSize(400,300);
setVisible(true);
try{
ServerSocket server = new ServerSocket(1680);
Socket socket = server.accept();
InputStreamReader in = new InputStreamReader(socket.getInputStream());
BufferedReader sin=new BufferedReader(in);
out=new PrintWriter(socket.getOutputStream(),true);
while(true){
String s=sin.readLine();
tx.append("@Client Said@: "+s+"\n");
}
}catch(Exception e){
e.printStackTrace();
}
}
public void actionPerformed(ActionEvent e){
if(e.getSource()==bt){
String st = tf.getText();
tx.append("#Server Said#: "+st+"\n");
out.println(st);
tf.setText("");
}
}
public static void main(String[] args){
MyServer msr = new MyServer();
}
}
java聊天室私聊的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于java实现聊天室私聊、java聊天室私聊的信息别忘了在本站进行查找喔。
