189 8069 5689
怎么在java中利用C/S模式实现聊天程序？相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。
创新互联是专业的香坊网站建设公司，香坊接单;提供成都网站建设、网站设计,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行香坊网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!
监听线程：建立服务器的套接字，接收来自客户端的连接，每当有客户端连接到服务器时，服务器都要把该客户端的套接字添加到变长数组socketsss中，并且要给每个用户都创建单独的线程。
消息处理线程：在输入流中读取来自客户端的UTF字符串，然后遍历Vector数组socketsss，将UTF字符串写入到对每一个用户的输出流中。
服务器的功能就是这些了，这样就能实现基本的聊天室功能了，感觉最难的地方就是消息转发了，不过最后找到了合适的方法也解决了。只有当自己动手去写了才会发现自己有什么地方的不足，比如，设置关闭按钮的响应时，在弹出的对话框中点什么都关闭，后来发现是前面窗体设置关闭没有改成无操作；还有就是刚开始服务器只能接收处理一组消息，第二组就出问题了，是因为我以为把监听写到线程中就可以无限调用了，还是要把他放到循环中去。总之，纸上得来终觉浅绝知此事要躬行，凡事动手去做比看书理解要深刻，学编程还是要多动动手。
界面展示：
package server;
import java.awt.*;
import java.io.*;
import java.net.*;
import java.util.*;
import java.awt.event.*;
import javax.swing.*;
public class Server extends JFrame {
JTextArea textShow;
JButton start;
Vector socketsss = new Vector();//这里用到了变长对象数组，用来存储来自客户端的socket对象
ServerSocket server = null;
Socket clients;
Server() { // 服务器的构造函数，并且初始化
init();
setVisible(true);
setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
setBounds(450, 150, 340, 455);
setTitle("好好学习天天向上聊天室服务器");
setResizable(false);
}
void init() { // 设置布局和事件监视器
setLayout(new FlowLayout());
getContentPane().setBackground(new Color(20, 85, 237));
textShow = new JTextArea(21, 29);
textShow.setBackground(new Color(45, 210, 209));
start = new JButton(" 启动服务器 ");
start.setBackground(new Color(236, 134, 21));
add(start);
add(new JScrollPane(textShow));
textShow.setEditable(false);
start.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) { //在这里启动监听的线程
Listen listen = new Listen();
Thread go = new Thread(listen);
go.start();
}
});
addWindowListener(new WindowAdapter() { // 响应关闭按钮功能
public void windowClosing(WindowEvent e) {
int option = JOptionPane
.showConfirmDialog(null, "亲爱的你真的要离开聊天室么？",
" 好好学习天天向上聊天室", JOptionPane.YES_NO_OPTION,
JOptionPane.QUESTION_MESSAGE);
if (option == JOptionPane.YES_OPTION)
System.exit(0);
}
});
} // init()结束
class ServerThread extends Thread { // 服务器消息处理的线程
Socket socket;
DataOutputStream out = null;
DataInputStream in = null;
String s = null;
Vector sockets = new Vector();
int j = 0;
ServerThread(Socket t, Vector socketss) {
socket = t;
sockets = socketss;
try {
in = new DataInputStream(socket.getInputStream());
} catch (IOException e) {
}
}
public void run() {
while (true) {
try {
String r = in.readUTF();// 堵塞状态，除非读取到信息
for (int j = 0; j < sockets.size(); j++) {
out = new DataOutputStream(
((Socket) sockets.get(j)).getOutputStream()); // 对于每个数组内的socket对象都建立输出流
out.writeUTF(r);
}
} catch (IOException e) {
textShow.append("有一个逗比离开了\n");
return;
}
}
}
}
class Listen implements Runnable { // 服务器监听线程
ServerSocket server;
Socket clients;
public void run() {
while (true) {
try {
server = new ServerSocket(8888);
textShow.append(new java.text.SimpleDateFormat(
"yy-MM-dd HH:mm:ss").format(new Date())
+ "服务器已开启\n");
} catch (IOException e1) {
textShow.append("正在监听\n"); // ServerSocket对象不能重复创建
}
try {
textShow.append(new java.text.SimpleDateFormat(
"yy-MM-dd HH:mm:ss").format(new Date())
+ " 等待用户连接......\n");
clients = server.accept();
socketsss.add(clients);
ServerThread handlers = new ServerThread(clients, socketsss);
handlers.start(); // 为每个用户创建单独的消息处理线程
textShow.append(new java.text.SimpleDateFormat(
"yy-MM-dd HH:mm:ss").format(new Date())
+ "有用户连接,用户的地址:" + clients.getInetAddress() + "\n");
} catch (IOException e1) {
textShow.append(new java.text.SimpleDateFormat(
"yy-MM-dd HH:mm:ss").format(new Date())
+ "正在等待逗比来临......\n");
}
}
}
}
public static void main(String args[]) {
Server server = new Server();
}
}看完上述内容，你们掌握怎么在java中利用C/S模式实现聊天程序的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注创新互联行业资讯频道，感谢各位的阅读！