嵌入式课程设计（论文）-android聊天室设计.doc

嵌入式课程设计（论文）androidl聊天室设计学 生： 学 号：指导教师：李季 老师专 业：计算机科学与技术重庆大学计算机学院二o一一年十二月嵌入式课程设计（论文） 中文摘要摘 要此系统设计了一个基于android系统与pc之间的通信，采用socket流式套接字进行网络通信。其中android系统的模拟器作为客户端，客户端采用获取手机号码作为该客户端的唯一标识，pc作为服务器端。其中客户端的设计过程中主要用chatclientactivity 文件实现客户端的各个widget的功能以及利用socket向服务器端发送和接受服务器端的消息。服务器端主要用serverthread 服务器线程初始化serversocket并将对客户端监听到得socket封装到clientthread线程中并将该线程存放到vector数组用于服务器与指定客户端交互，以及启动broadcast线程和clientthread线程，以及将，其中clientthread线程主要用于将监听到客户端发送的消息存放到消息队列并将其保存在sql2000数据库中以及根据分类显示在控制台上，broadcast线程主要获取消息队列中的消息并根据消息的性质确定是否将此消息广播到所有在线客户端或是发送到某些指定的客户端。startserver主要用于启动serverthread线程，即启动整个服务器。dodatabase主要用于连接数据库和实现对数据库的添加操作。最后此系统实现了群聊与私聊的功能，并能够将聊天记录分类保存到数据库中。关键词：android，socket通信，线程同步，tcp/ip协议i嵌入式课程设计（论文） 目录嵌入式课程设计（论文） 目录目 录中文摘要1 tcp/ip及socket简介1 1.1 tcp/ip协议简介1 1.2 socket套接字简介12 系统总体架构23 系统功能实现33.1 数据交互格式33.2 服务器功能实现4 3.2.1 startserver类4 3.2.2 serverthread类5 3.2.3 clientthread类6 3.2.4 broadcast类8 3.2.1dodatabase类103.3 客户端功能实现113.4 系统功能展示153.4.1客户端功能展示153.4.2服务器端及数据库展示16 4 系统存在的问题及改进方法17 4.1 系统存在的问题174.2 系统改进方法174 自我评价18ii参考文献19嵌入式课程设计（论文） 1 tcp/ip及socket简介1 tcp/ip及socket简介 1.1 tcp/ip协议简介tcp/ip是transm control protocol/internet protocol 的简写，又称网络通信协议，是internet最基本的协议。tcp/ip协议是“可靠的”、“面相连接”的网络传输协议。tcp/ip协议遵循的是一个抽象的分层模型，这个模型中所有的tcp/ip系列网络协议都被归纳到四个抽象的“层”中。每一抽象层建立在低一层提供的服务上，并为高一层服务。tcp/ip参考模型从上到下分别包括网络接口层、网络互连层、传输层和应用层四层。1.2 socket套接字简介在网络上的两个程序通过一个双向的通信链路实现数据交换，这个双向链路的一段就被称为一个socket，socket通常用来实现客户端和服务器端的链接。socket是tcp/ip协议的一个十分流行的编程界面，一个socket有一个ip地址和一个端口号确定。在java环境中实现基于tcp/ip协议的网络编程都需要采用socket机制。并且与基于url的网络编程socket编程提供更高的传输效率。socket通常采用c/s结构，使用socket进行c/s程序设计的一般链接过程如下图：图1.1 socket编程连接一般过程- 19 -嵌入式课程设计（论文） 2 系统总体架构2 系统总体架构整个系统由客户端和服务器端组成，其中客户端位于android模拟器上，服务器端位于pc上。客户端创建的socket与服务端的serversocket进行交互来实现网络数据交互。其中socket与serversocket交互过程如下：(1) 服务器端程序创建一个serversocket，然后调用accept()方法等待客户连接(2) 客户端创建一个socket并请求与服务器端程序建立连接。(3) 服务器端程序接受客户端的连接请求，并创建一个新的socket与该客户端建立专线连接。(4) 建立了连接的客户端及服务器端的两个socket在一个有服务器端程序创建的单独线程上对话，对话方式采用getinputstream()、getoutputstream()得到的输入与输出流进行数据的读取与输出。客户端的socket与服务器端的serversocket的通信如下图：图2.1 socket与serversocket通信图(5) 服务器端开始等待新的连接请求，重复(2)(5)的过程。在客户端程序实现了界面的显示以及与服务器端的数据交互。在服务器端程序一共包含五个类，其名称及功能如下表所示：startserver启动服务器主线程serverthread，即启动服务器serverthread服务器监听端口线程，负责创建serversocket以及监听是否有新客户端连接，并记录客户端连接以及需要发送的消息clientthread维持服务器与单个客户端的连接线程，负责接受客户端发送来的消息broadcast服务器向客户端发送广播线程，负责向客户端发送消息dodatabase连接数据库，将消息拆解后按类型存放到数据库chatdemo的messages表中表2.1 服务器端程序的四个类功能实现通信功能的流程图如下：图2.2 系统通信功能流程图嵌入式课程设计（论文） 3 系统功能实现3 系统功能实现3.1数据交互格式对于此聊天系统，主要存在如下三类数据：1、登陆2、传递消息3、退出这三类数据都是需要向服务器端发送的数据，因为了在服务器端处理的数据不被混淆，必须对他们的数据格式进行规格化，此系统的数据规格如下图：表3.1 消息格式图消息种类： “l”登陆；“s”传递消息；“c”退出，目的地址： 要发往特定客户端的手机号标 识： 用来标识不同种类的信息符号其中“$”发送的消息标识；“#”客户上下线标识。源 地 址： 消息来源的客户端手机号码时 间： 获取到的发送消息时的时间内 容： 如果登陆则为“上线了”，如果退出则为“下线了”，如果是传递消息则为想发送的内容；其中对于登陆和退出消息，送往服务器端进行拆分后将其目标地址置空，对于传递消息，如果目标地址和源地址相同则表示将该消息发送给所有的客户端，反之，则只是发送到这两个地址的客户端中。3.2服务器端功能实现3.2.1 startserver类startserver线程是整个服务器的主线程，当执行这个工程文件时执行这个类中的main函数，在main函数中创建了一个实例化了一个serverthread线程命名为serverthread,并启动该线程，代码如下：public class startserver private static serverthread serverthread;public static void main(string args) / todo auto-generated method stubserverthread = new serverthread();serverthread.start();3.2.2 serverthread类该类在构造函数中实例化了两个vector数组，分别用于存放clientthread线程和存放从客户端发送来的消息，并命名为clients 和messages。此外还对serversocket进行了初始化，然后启动broadcast方法。代码如下：public vector clients;public vector messages;public serverthread()clients = new vector();messages= new vector();try serversocket = new serversocket(port); catch (ioexception e) / todo auto-generated catch blocke.printstacktrace();try myipaddress = inetaddress.getlocalhost(); catch (unknownhostexception e) / todo auto-generated catch blocke.printstacktrace();broadcast = new broadcast(this);broadcast.start();构造方法执行后，接着执行该线程的run()方法。在run()函数中用了一个死循环实现不停的对客户端的连接进行监听，一旦监听到客户端的连接请求，就获得该客户端的socket并将其封装在clientthread线程中，然后启动clientthread线程并将该线程压入clients数组中以实现服务器与指定客户端或所有客服端发送数据。此外由于clients属于临界资源，同一时刻只能允许被一个线程操作，因此使用了线程同步方法synchronized(clients)。代码如下：public void run()while(true)try socket socket = serversocket.accept();system.out.println(socket.getinetaddress().gethostaddress();clientthread clientthread = new clientthread(socket,this);clientthread.start();if(socket!=null)synchronized(clients)clients.addelement(clientthread); catch (ioexception e) / todo auto-generated catch blocke.printstacktrace();3.2.3 clientthread类当serverthread线程开启了clientthread线程后，通过构造函数获得了客户端的socket套接字，然后通过socket的getinputstream()方法和getoutputstream()方法获取输入输出流。public clientthread(socket socket,serverthread serverthread)this.clientsocket = socket;this.serverthread = serverthread;try in = new datainputstream(clientsocket.getinputstream();out = new dataoutputstream(clientsocket.getoutputstream(); catch (ioexception e) / todo auto-generated catch blocke.printstacktrace();然后执行run()方法监听socket是否有新的消息，然后根据消息的类别相应处理后在控制台上显示出来，并把message的第14到25的子串(username)作为clientthread的唯一标识id，此标识可以用来实现从一个客户端向另一指定客户端发送数据。并利用domsg()方法将message拆分后存放到数据库中，同时将message压入到messages消息队列中。代码如下：public void run()while(true)try string message = in.readutf();synchronized(serverthread.messages)if(message !=null)domsg(message);id = message.substring(14, 25);serverthread.messages.addelement(message);if(message.subsequence(0, 1).equals(s)if(message.substring(1,12).equals(message.substring(14,25)system.out.println(message.substring(1,12) + message.substring(24);elsesystem.out.println($+message.substring(14,25)+ 对 +message.substring(1,12)+message.substring(25);elsesystem.out.println(message.substring(12); catch (ioexception e) / todo auto-generated catch blocke.printstacktrace();break;private void domsg(string message) / todo auto-generated method stubcatgory = message.substring(0,1);orgid = message.substring(14,25);time = message.substring(26,34);if(catgory.equals(s)goalid = message.substring(1,12);content =message.substring(36);elsegoalid = ;content =message.substring(34);try dodb.addmsg(time, catgory, orgid, goalid, content); catch (exception e) / todo auto-generated catch blocke.printstacktrace();3.2.4 broadcast类通过serverthread线程调用该类后，serverthread类通过broadcast构造函数传给serverthread实例，然后执行该线程的run()方法，没循环一次线程休眠200ms，然后取出messages中尚未发送出的消息，将消息按其格式拆分后根据其意图送往各个客户端或是指定客户端，是实现群聊个私聊的功能。同样，消息数组是临界资源，所以，用到了synchronized(serverthread.messages)方法，判断该消息为下线功能，则将根据id删除vector中的clientthread线程。源代码如下：public void run()while(true)try thread.sleep(200); catch (interruptedexception e) / todo auto-generated catch blocke.printstacktrace();synchronized(serverthread.messages)if(serverthread.messages.isempty()continue;/获取消息队列队首消息str = (string)this.serverthread.messages.firstelement();synchronized(serverthread.clients)system.out.println(serverthread.clients.size();for(int i=0;iserverthread.clients.size();i+)/获取该客户端线程clientthread =(clientthread)serverthread.clients.elementat(i);try clientthread.out.writeutf(str); catch (ioexception e) / todo auto-generated catch blocke.printstacktrace();/从消息队列中删除该消息this.serverthread.messages.remove(str);3.2.5 dodatabase类该类有两个方法addmsg()和getconnection()方法，其中getconnection()方法用于获取数据库chatdemo的连接句柄。addmsg()方法用于对chatdemo中的表messages进行写操作。实现代码如下：public class dodatabase public void addmsg(string time, string catgory, string orgid, string goalid, string content)throws exception /打开连接connection conn = getconnection();/ 执行操作preparedstatement pst = conn.preparestatement(insert into messages values(?,?,?,?,?);pst.setstring(1, time); /时间pst.setstring(2, catgory);/消息种类pst.setstring(3, orgid);/源地址pst.setstring(4, goalid);/目的地址pst.setstring(5, content);/内容pst.execute();/ 关闭数据库conn.close();private connection getconnection() throws classnotfoundexception,sqlexception class.forname(net.sourceforge.jtds.jdbc.driver);connection conn = drivermanager.getconnection(jdbc:jtds:sqlserver:/localhost:1433/chatdemo, sa, );return conn;3.3客户端功能实现图3.1 客户端界面其源代码如下：public class chatclientactivity extends activity implements runnableprivate edittext usernameedit,ipedit,historyedit,messageedit;private button loginbutton,leavebutton,sendbutton;private string username ,ip,chat_txt,chat_in;public static final int port = 8521;/端口号public datainputstream in=null;public dataoutputstream out=null;public socket socket;public thread thread;public boolean flag = false; /标识是否登陆，true为已登录，false为未登录 override public void oncreate(bundle savedinstancestate) super.oncreate(savedinstancestate); setcontentview(r.layout.main); usernameedit = (edittext)findviewbyid(r.id.username); ipedit = (edittext)findviewbyid(r.id.ip); historyedit = (edittext)findviewbyid(r.id.history); messageedit = (edittext)findviewbyid(r.id.message); loginbutton = (button)findviewbyid(r.id.loginbutton); leavebutton = (button)findviewbyid(r.id.leave); sendbutton = (button)findviewbyid(r.id.sendbutton); loginbutton.setonclicklistener(listener); leavebutton.setonclicklistener(listener); sendbutton.setonclicklistener(listener); view.onclicklistener listener = new view.onclicklistener() overridepublic void onclick(view v) / todo auto-generated method stubswitch(v.getid()case r.id.loginbutton:/登陆if(flag=true)toast.maketext(chatclientactivity.this, 已经登陆过了, 3000).show();return;username = usernameedit.gettext().tostring();ip = ipedit.gettext().tostring();if(username!= & username!=null & ip != null)/目的地址和源地址不能为空；try socket = new socket(ip,port); /实例化socket/获取输入输出流in = new datainputstream(socket.getinputstream();out = new dataoutputstream(socket.getoutputstream();date now = new date(system.currenttimemillis(); /获取系统时间simpledateformat format = new simpledateformat(hh:mm:ss);string nowstr = format.format(now);out.writeutf($+username+ +nowstr+上线了); catch (unknownhostexception e) / todo auto-generated catch blocke.printstacktrace(); catch (ioexception e) / todo auto-generated catch blocke.printstacktrace();thread = new thread(chatclientactivity.this);thread.start();flag = true;break;case r.id.sendbutton: /发送消息if(flag = false)toast.maketext(chatclientactivity.this, 没有登陆,请登陆, 3000).show();return;chat_txt = messageedit.gettext().tostring();if(chat_txt !=null)date now = new date(system.currenttimemillis(); /获取当前时间simpledateformat format = new simpledateformat(hh:mm:ss);string nowstr = format.format(now);try out.writeutf(_+username+ +nowstr+说n+chat_txt); catch (ioexception e) / todo auto-generated catch blocke.printstacktrace();elsetry out.writeutf(请说话); catch (ioexception e) / todo auto-generated catch blocke.printstacktrace();break;case r.id.leave: /退出if(flag = false)toast.maketext(chatclientactivity.this, 没有登陆,请登陆, 3000).show();return;try out.writeutf(#+username+下线了！);out.close();in.close();socket.close(); catch (ioexception e) / todo auto-generated catch blocke.printstacktrace();flag = false;toast.maketext(chatclientactivity.this, 已经退出！, 3000).show();break;overridepublic void run() /服务端反馈的消息/ todo auto-generated method stubwhile(true)try chat_in = in.readutf();chat_in +=n;mhandler.sendmessage(mhandler.obtainmessage(); /发到主线程的消息队列中 catch (ioexception e) / todo auto-generated catch blocke.printstacktrace();handler mhandler = new handler()public void handlemessage(message msg)historyedit.append(chat_in); /在historyedit文本框中追加消息super.handlemessage(msg);3.4系统功能展示3.2.1 客户端功能展示图3.2 客户端5554发送接收消息界面 图3.3 客户端5556发送接收消息界面图3.4 客户端5558发送接收消息界面3.2.1 服务器端及数据库展示图3.5 服务器控制台显示 图3.6 数据库存储显式嵌入式课程设计（论文） 4 系统存在的问题及改进方法4 系统存在问题及改进方法4.1系统存在的问题此系统实现了android系统聊天室的群聊和私聊功能以及实现了在服务器端将接收到的消息存储到，但是由于时间限制此系统基本实现了android系统的聊天室的实现群发功能，但是由于时间较紧，还有一些没有实现的功能。首先在安全性上考虑不周，登陆时只需要输入用户名就能够进入系统，而且没有检测多个模拟器上是否有同名的情况。其次，对很多可能出现异常的情况没有处理。再次，设计上还不够严谨，在客户端与服务器端进行数据通信时有很多数据交互，此系统只实现了在客户端对发送的消息进行了记录，但只实现了数据库的写操作。在客户端本地没有实现数据存储机制以便日后需要，比如：用户名，密码等。最后，android客户端界面设计不足，比如：当历史记录edittext中存放了太多内容时需要设置清除功能。4.2系统改进方法对于上述存在的问题提出的改进方法如下：首先，对系统增加严谨的注册和登陆功能，只有在系统中注册的用户以及正确输入了用户名和密码的用户