基于JAVA的ICQ系统的设计于实现.doc

1、基于 JAVA 的 ICQ 系统的设计于实现内容：一序言二设计三程序界面四程序的使用参考资料关于作者何刚 (he_)2001 年 10 月分析 ICQ 系统，并尝试用 Java 编写。一序言ICQ 是英文“I seek you “的简称，中文意思是我找你。ICQ 最大的功能就是即时信息交流，只要记得对方的号码，上网时可以呼他，无论他在哪里，只要他上网打开 ICQ，人们就可以随时交流。ICQ源于以色列特拉维夫的 Mirabils 公司。该公司成立于年月，也就是在这个时候，互联网上最出名，下载使用人数最多的免费软件 ICQ 诞生了。可能是其不断增加的用户和广阔的前景以及广泛的应用前景和巨大的市场潜

2、力，Mirabils 的 ICQ 最终被美国在线 AOL 收购。由于 ICQ 的成功，推动了 ICQ 的本土化，就中文的 ICQ 而言，现在已经越来越多，比如著名的深圳腾迅公司推出的OICQ(现在由于版权问题，已改名为 QQ2001)，还有由 TOM.COM 推出的 Tomq 等，这些软件技术都很好，而且简单易用，成为中国网民最喜欢的通信软件。但是这些公司都只提供软件的客户端程序免费下载，而不提供其服务器程序，因此对于未与互联网连接的私有网络，这些软件就用不上了。当然网上也有免费的类似 ICQ 的服务器提供下载，但是好多都不提供源程序，即使有，其说明也很简单，我很想知道它是怎么回事，所以我就试

3、着做了。二设计为什么选择 JAVA？Java 是 Sun Microsystem 公司的 James Gosling 开发的编程语言。它以 C+为基础，但是却是一个全新的软件开发语言。Java 是一个简单，面象对象，分布式，解释性，强壮，安全，与系统无关，可移植，高性能，多线程和动态的语言-这是 Sun 给 Java 的定义。Sun 公司的口号就是“网络就是计算机“,Java 能使所有东西从桌面计算平稳的转变为基于网络的计算，它是专门为此而建立的，并显然是为了完成这个任务而来的。使用 Java，我们可以相对轻松的一天编写一个有条理的网络程序。今天，Java 的网络功能正在飞跃发展，不断有新的特

4、性增加到这个有价值的基础上，JavaSoft 实验室正在不断努力使 Java 更加完善。2数据库设计系统可以采用任何一种流行的，Java 支持的数据库，本系统采用了 Microsoft 公司的 SQL Server2000 作为后台数据库。通过对现在流行的一些 Icq 的参考，建立数据库，名为 javaicq,数据库共建立两个表，一个是用户的基本信息,包括呢称，Jicq 号码等。一个是用户的好友表，包括用户自己的号码和好友的号码。(1)用户的基本信息表(表名 icq)序号 字段名 含义 数据类型NULL1 Icqno 用户的号码 Int No2 Nickname 用户的呢称 Char No3

5、Password 用户的密码 Char No4 Status 用户在线否 Bit No5 Ip 用户的 IP 地址 Char Yes6 Info 用户的资料 Varchar Yes7 Pic 用户的头像号 Int Yes8 Sex 用户性别 Char Yes9 Email 用户的 email Char Yes10 Place 用户的籍贯 Char yes其中 Icqno 字段为自动增加。 （其他还可以添加诸如电话号码等字段作为更多选择）（2）用户的好友表（表名 friend）序号 字段名 含义 数据类型 NULL1 Icqno 用户的号码 Int No2 Friend 好友的号码 Int No

6、3系统模式及程序 (具体程序参看源程序)系统采用客户/服务器摸式(如图 )1. 服务器程序: 服务器与客户间通过套接口 Socket(TCP)连接。在 java 中使用套接口相当简单，Java API为处理套接口的通信提供了一个类 .Socket.,使得编写网络应用程序相对容易服务器采用多线程以满足多用户的请求，通过 JDBC 与后台数据库连接，并通过创建一个ServerSocket 对象来监听来自客户的连接请求，默认端口为 8080，然后无限循环调用accept()方法接受客户程序的连接服务器程序代码如下：(部分)import java.io.*;import .*;import java.

7、sql.*;import java.util.Vector;class ServerThread extends Thread/继承线程private Socket socket;/定义套接口private BufferedReader in;/定义输入流private PrintWriter out;/定义输出流int no;/定义申请的 jicq 号码public ServerThread(Socket s) throws IOException /线程构造函数socket=s;/取得传递参数in=new BufferedReader(new InputStreamReader(socke

8、t.getInputStream();/创建输入流out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),true);/创建输出流start();/启动线程public void run()/线程监听函数try while(true)String str=in.readLine();/取得输入字符串if(str.equals(“end“)break;/如果是结束就关闭连接else if(str.equals(“login“) /如果是登录try Class.forName(“s

9、un.jdbc.odbc.JdbcOdbcDriver“);/连接数据库Connection c=DriverManager.getConnection(“jdbc:odbc:javaicq“,“ “,“ “);String sql=“select nickname,password from icq where icqno=?“;/准备从数据库选择呢称和密码PreparedStatement prepare=c.prepareCall(sql);/设定数据库查寻条件String icqno=in.readLine();int g=Integer.parseInt(icqno);/取得输入的

10、jicq 号码System.out.println(icqno);String passwd=in.readLine().trim();/取得输入的密码System.out.println(passwd);prepare.clearParameters();prepare.setInt(1,g);/设定参数ResultSet r=prepare.executeQuery();/执行数据库查寻if(r.next()/以下比较输入的号码于密码是否相同String pass=r.getString(“password“).trim();System.out.println(pass);if(pass

11、wd.regionMatches(0,pass,0,pass.length() out.println(“ok“);/如果相同就告诉客户 ok/并且更新数据库用户为在线/以及注册用户的 ip 地址/*register ipaddressString setip=“update icq set ip=? where icqno=?“;PreparedStatement prest=c.prepareCall(setip);prest.clearParameters();prest.setString(1,socket.getInetAddress().getHostAddress();prest

12、.setInt(2,g);int set=prest.executeUpdate();System.out.println(set);/*ipaddress/set status onlineString status=“update icq set status=1 where icqno=?“;PreparedStatement prest2=c.prepareCall(status);prest2.clearParameters();prest2.setInt(1,g);int set2=prest2.executeUpdate();System.out.println(set2);/s

13、et online/否者告诉客户失败else out.println(“false“);r.close();c.close();else out.println(“false“);System.out.println(“false“);r.close();c.close();catch (Exception e)e.printStackTrace();socket.close();/end login/登录结束/以下为处理客户的新建请求else if(str.equals(“new“)try Class.forName(“sun.jdbc.odbc.JdbcOdbcDriver“);/连接数据

14、库Connection c2=DriverManager.getConnection(“jdbc:odbc:javaicq“,“ “,“ “);String newsql=“insert into icq(nickname,password,email,info,place,pic) values(?,?,?,?,?,?)“;/准备接受用户的呢称，密码，email，个人资料，籍贯，头像等信息PreparedStatement prepare2=c2.prepareCall(newsql);String nickname=in.readLine().trim();String password=

15、in.readLine().trim();String email=in.readLine().trim();String info=in.readLine().trim();String place=in.readLine().trim();int picindex=Integer.parseInt(in.readLine();prepare2.clearParameters();prepare2.setString(1,nickname);prepare2.setString(2,password);prepare2.setString(3,email);prepare2.setStrin

16、g(4,info);prepare2.setString(5,place);prepare2.setInt(6,picindex);int r3=prepare2.executeUpdate();/执行数据库添加String sql2=“select icqno from icq where nickname=?“;/以下告诉客户其注册的号码PreparedStatement prepare3=c2.prepareCall(sql2);prepare3.clearParameters();prepare3.setString(1,nickname);ResultSet r2=prepare3.

17、executeQuery();while(r2.next()/out.println(r2.getInt(1);no=r2.getInt(1);System.out.println(no);out.println(no);out.println(“ok“);c2.close();/完毕catch (Exception e)e.printStackTrace();out.println(“false“);socket.close();/end new/新建用户结束/以下处理用户查找好友else if(str.equals(“find“)try Class.forName(“sun.jdbc.od

18、bc.JdbcOdbcDriver“);Connection c3=DriverManager.getConnection(“jdbc:odbc:javaicq“,“ “,“ “);/以下连接数据库，并且返回其他用户的呢称，性别，籍贯，个人资料等信息String find=“select nickname,sex,place,ip,email,info from icq“;Statement st=c3.createStatement();ResultSet result=st.executeQuery(find);while(result.next()out.println(result.g

19、etString(“nickname“);out.println(result.getString(“sex“);out.println(result.getString(“place“);out.println(result.getString(“ip“);out.println(result.getString(“email“);out.println(result.getString(“info“);/while endout.println(“over“);/GET ICQNOint d,x;boolean y;/以下返回用户的 jicq 号码，头像号，及是否在线ResultSet i

20、set=st.executeQuery(“select icqno,pic,status from icq“);while(iset.next()d=iset.getInt(“icqno“);out.println(d);x=iset.getInt(“pic“);/pic infoout.println(x);y=iset.getBoolean(“status“);if (y)out.println(“1“);else out.println(“0“);/System.out.println(d);/ end send jicqnoiset.close();/icqno endc3.close

21、();result.close();catch (Exception e)e.printStackTrace();System.out.println(“false“);/socket.close();/end find/查找好友结束/以下处理用户登录时读取其好友资料else if(str.equals(“friend“)try Class.forName(“sun.jdbc.odbc.JdbcOdbcDriver“);Connection c4=DriverManager.getConnection(“jdbc:odbc:javaicq“,“ “,“ “);/以下连接好友表，返回用户的好友名

22、单String friend=“select friend from friend where icqno=?“;PreparedStatement prepare4=c4.prepareCall(friend);prepare4.clearParameters();int icqno=Integer.parseInt(in.readLine();System.out.println(icqno);prepare4.setInt(1,icqno);ResultSet r4=prepare4.executeQuery();Vector friendno=new Vector();/该矢量保存好友

23、号码while(r4.next()friendno.add(new Integer(r4.getInt(1);/read friend info/以下告诉客户其好友的呢称，号码，ip 地址，状态，头像，个人资料等信息out.println(friendno.size();for(int i=0;ifriendno.size();i+)String friendinfo=“select nickname,icqno,ip,status,pic,email,info from icq where icqno=?“;PreparedStatement prepare5=c4.prepareCall(

24、friendinfo);prepare5.clearParameters();prepare5.setObject(1,friendno.get(i);ResultSet r5=prepare5.executeQuery();boolean status;while(r5.next()out.println(r5.getString(“nickname“);out.println(r5.getInt(“icqno“);out.println(r5.getString(“ip“);status=r5.getBoolean(“status“);if (status)out.println(“1“)

25、;else out.println(“0“);out.println(r5.getInt(“pic“);out.println(r5.getString(“email“);out.println(r5.getString(“info“); /whiler5.close();/for/发送完毕out.println(“over“);System.out.println(“over“);c4.close();r4.close();catch (Exception e)e.printStackTrace();System.out.println(“false“);/socket.close();/e

26、nd friend/读取好友信息完毕/以下处理用户添加好友else if(str.equals(“addfriend“)System.out.println(“add“);try Class.forName(“sun.jdbc.odbc.JdbcOdbcDriver“);Connection c6=DriverManager.getConnection(“jdbc:odbc:javaicq“,“ “,“ “);/连接数据库，根据接受的用户号码及好友号码向好友表添加记录int friendicqno=Integer.parseInt(in.readLine();System.out.printl

27、n(friendicqno);int myicqno=Integer.parseInt(in.readLine();System.out.println(myicqno);String addfriend=“insert into friend values(?,?)“;PreparedStatement prepare6=c6.prepareCall(addfriend);prepare6.clearParameters();prepare6.setInt(1,myicqno);prepare6.setInt(2,friendicqno);int r6=0;r6=prepare6.execu

28、teUpdate();if(r6=1) System.out.println(“ok addfrien“);else System.out.println(“false addfriend“);catch (Exception e)e.printStackTrace();System.out.println(“false“);/socket.close();System.out.println(“over addfriend“);/end addfriend/用户添加好友结束/add new friend who add me/以下处理其他用户如果加我，我就加他else if(str.equa

29、ls(“addnewfriend“)System.out.println(“add“);try Class.forName(“sun.jdbc.odbc.JdbcOdbcDriver“);Connection c6=DriverManager.getConnection(“jdbc:odbc:javaicq“,“ “,“ “);/连接数据库，根据接受的用户号码及好友号码向好友表添加记录int friendicqno=Integer.parseInt(in.readLine();System.out.println(friendicqno);int myicqno=Integer.parseIn

30、t(in.readLine();System.out.println(myicqno);String addfriend=“insert into friend values(?,?)“;PreparedStatement prepare6=c6.prepareCall(addfriend);prepare6.clearParameters();prepare6.setInt(1,myicqno);prepare6.setInt(2,friendicqno);int r6=0;r6=prepare6.executeUpdate();if(r6=1) System.out.println(“ok

31、 addfrien“);else System.out.println(“false addfriend“);String friendinfo=“select nickname,icqno,ip,status,pic,email,info from icq where icqno=?“;/如果成功，就向用户传递好友的基本信息，比如呢称等PreparedStatement prepare5=c6.prepareCall(friendinfo);prepare5.clearParameters();prepare5.setInt(1,friendicqno);ResultSet r5=prepa

32、re5.executeQuery();boolean status;while(r5.next()System.out.println(“dsf“);out.println(r5.getString(“nickname“);out.println(r5.getInt(“icqno“);out.println(r5.getString(“ip“);status=r5.getBoolean(“status“);if (status)out.println(“1“);else out.println(“0“);out.println(r5.getInt(“pic“);out.println(r5.g

33、etString(“email“);out.println(r5.getString(“info“); /whileout.println(“over“);r5.close();c6.close();catch (Exception e)e.printStackTrace();System.out.println(“false“);System.out.println(“over addnewfriend“);/end addfriend/结束处理其他用户如果加我，我就加他/delete friend/以下执行用户删除好友else if(str.equals(“delfriend“)Syste

34、m.out.println(“del“);try Class.forName(“sun.jdbc.odbc.JdbcOdbcDriver“);Connection c7=DriverManager.getConnection(“jdbc:odbc:javaicq“,“ “,“ “);/连接数据库，根据接受的用户号码及好友号码向好友表删除记录int friendicqno=Integer.parseInt(in.readLine();System.out.println(friendicqno);int myicqno=Integer.parseInt(in.readLine();System.

35、out.println(myicqno);String addfriend=“delete from friend where icqno=? and friend=?“;PreparedStatement prepare7=c7.prepareCall(addfriend);prepare7.clearParameters();prepare7.setInt(1,myicqno);prepare7.setInt(2,friendicqno);int r7=0;r7=prepare7.executeUpdate();if(r7=1) System.out.println(“ok delfrie

36、n“);/成功else System.out.println(“false delfriend“);/失败catch (Exception e)e.printStackTrace();System.out.println(“del false“);/end delete friend/执行用户删除好友结束/以下处理用户退出程序else if(str.equals(“logout“)try Class.forName(“sun.jdbc.odbc.JdbcOdbcDriver“);Connection c8=DriverManager.getConnection(“jdbc:odbc:javai

37、cq“,“ “,“ “);/连接数据库，根据接受的用户号码，将其状态字段设为 0，及 ip 地址设为空int myicqno=Integer.parseInt(in.readLine();System.out.println(myicqno);String status=“update icq set status=0 , ip= where icqno=?“;PreparedStatement prest8=c8.prepareCall(status);prest8.clearParameters();prest8.setInt(1,myicqno);int r8=prest8.executeUpdate();if(r8=1) System.out.println(“ok logout“);