java基于C/S模式实现聊天程序(服务器)
上篇介绍了java基于c/s模式实现聊天程序的客户端写法,这一篇介绍服务器的写法。
服务器的功能是:接收来自客户端的消息,然后将消息转发给当前连接的所有用户。这里一个困扰我许久的地方是如何存储所有用户的地址(套接字),找了许久我找到了一种变长数组的数据结构vector,用size()来获取长度,用add()来添加元素,这样就容易多了,解决了服务器最大的问题。
服务器我定义了一个启动服务器的按钮,通过此按钮可以启动服务器的监听线程,我把服务器的创建放在了监听线程中。
服务器主要由两个线程组成:监听和消息处理。
监听线程:建立服务器的套接字,接收来自客户端的连接,每当有客户端连接到服务器时,服务器都要把该客户端的套接字添加到变长数组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加密解密和数字签名完整代码示例