【正文】 數(shù)據(jù)庫的結構本系統(tǒng)數(shù)據(jù)庫主要有6張表，各表及表結構如下所示：第一張表：用戶安全登錄表（如圖33）作用：允許相關人員登陸此系統(tǒng)圖33 用戶安全登錄表第二張表：家庭火災表作用：對監(jiān)控取得視頻結果用數(shù)字數(shù)據(jù)形式進行整理，此表對家庭發(fā)生火災情況進行整理。圖34 家庭火災表第三張表：家庭被盜表作用：對監(jiān)控取得視頻結果用數(shù)字數(shù)據(jù)形式進行整理，此表對家庭被盜情況進行整理。圖35 家庭被盜表第四張表：小區(qū)園區(qū)監(jiān)控表作用：對監(jiān)控取得視頻結果用數(shù)字數(shù)據(jù)形式進行整理，此表對小區(qū)園區(qū)監(jiān)控結果進行整理。圖36 小區(qū)元園區(qū)監(jiān)控表第五張表：小區(qū)樓內(nèi)監(jiān)控表作用：對監(jiān)控取得視頻結果用數(shù)字數(shù)據(jù)形式進行整理，此表對小區(qū)樓內(nèi)監(jiān)控結果進行整理。圖37 小區(qū)樓內(nèi)監(jiān)控表第六張表：視頻存放表作用：將各個地點的攝像頭所拍下的視頻地址存放該表中，以供相關人員調(diào)用，因為如果存大量視頻會使機器越來越慢，把視頻存入本地磁盤。圖38 視頻存放表 網(wǎng)站目錄結構本系統(tǒng)在開發(fā)軟件Eclipse中的目錄顯示如下：圖39 網(wǎng)站目錄結構Form:網(wǎng)頁表單Action:Action類是用戶請求和業(yè)務邏輯之間的橋梁Dao:數(shù)據(jù)庫代碼集中地Util:主要是一些特殊類,用來監(jiān)聽和JDBC語句Jsp中的image:用來存放網(wǎng)站所需的圖片Js:用來存放公共的js腳本代碼Css:美化頁面的Page:存放頁面的位置:主要是一些配置信息，如Formbean:用來接收網(wǎng)頁傳過來的數(shù)據(jù)第四章 系統(tǒng)各模塊的詳細設計與實現(xiàn)第4章 系統(tǒng)各模塊的詳細設計與實現(xiàn) 總體設計要點聊天系統(tǒng)的設計跟普通網(wǎng)站設計有著許多不同的地方，普通網(wǎng)站設計所考慮的因素，例如，普通網(wǎng)站需要對布局進入大量美化以及動畫設計等等，而聊天室只要提供滿足訪客雙方直接實時聊天即可。因此，在設計聊天系統(tǒng)的過程中，必須要考慮好以下幾個設計要點：實現(xiàn)思想局域網(wǎng)基于P2P上的聊天程序一般都是以服務器模塊提供連接響應，使用者通過客戶端模塊連接，與用戶交談，這是一個面向連接的通信過程。因此，程序要在TCP/IP環(huán)境下，實現(xiàn)服務器和客戶端兩個模塊的程序。服務器模塊工作流程服務器模塊通過socket()系統(tǒng)調(diào)用創(chuàng)建一個Socket數(shù)組后，與指定的本地端口綁定，就可以在端口進行偵聽listen()。如果有用戶連接請求，則建立一個Socket，將客戶端地址賦給這個Socket。然后就可以相互傳遞信息了?？蛻舳四K工作流程客戶端程序相對簡單，只需要建立一個Socket與服務器模塊連接，成功后通過這個Socket來發(fā)送和接收數(shù)據(jù)就可以了。系統(tǒng)通過ActionListener接口來監(jiān)聽用戶的對按鈕的點擊，來啟動各聊天窗口進行相關工作，如私聊，群聊等。 設計步驟以及功能模塊其表如下圖所示：1．頁面功能：聊天系統(tǒng)工作原理圖圖42原理圖 功能模塊1．LoadingFrame(源代碼見附錄，下同) public void init(){//登陸界面的初始化方法 setTitle(登錄)。 setIconImage((new ImageIcon(\\image\\)).getImage())。 …… setLocation(387, 234)。 setSize(350,300)。 setVisible(true)。 setDefaultCloseOperation(3)。 (this)。//將“登陸”按鈕加入到事件偵聽器中 (this)。//講“取消”按鈕加入到事件偵聽器中 (this)。//講輸入用戶名的文本框加入到事件偵聽器中 (false)。 }public void actionPerformed(ActionEvent e) { if(()==loadBtn||()==nameText){//創(chuàng)建客戶端主界面 text=()。 new StateFrame(text)。 dispose()。 }else if(()==cancelBtn){//取消登錄，推出程序 dispose()。 (0)。 } } 程序的登錄窗口,從此窗口中，輸入用戶名，點擊“登陸”來初始化一個StateFrame對象，并在顯示器上顯示出客戶端的主界面。在后期的完善中，會完成記住用戶名及自動登錄功能。主要通過將用戶名寫入一個記事本保存起來。2．StateFrame public final static int DEFAULT_PORT=8322。//默認端口 public final static int CATCH_PORT=7322。 public final static int TCP_PORT=6322。//默認TCP連接端口 public void init(){//初始化應用程序窗口…… (new ActionListener(){//用ActionListener接口來對圖形界面中的各個組件進行監(jiān)聽 public void actionPerformed(ActionEvent e) { //雙擊登錄到列表框內(nèi)容時觸發(fā)的事件為連通列表框中的IP,建立TCP通信 Socket socket。 int s=()。 String address=userinfo[s].getIP()。//獲取對方IP try { socket=new Socket(address,TCP_PORT)。//建立連接 MainChatFrame mf=new MainChatFrame(socket,userinfo[s].getName())。//啟動私聊主界面 } catch (Exception e1) {()。} }})。 ……//初始化UDP協(xié)議端口信息 //首先向已在線的程序發(fā)送本機的IP以及請求響應并對相應的組播端進行監(jiān)聽 public void JoinGroup(){ try { group=()。 //初始化廣播聊天信息組 groupC=()。//初始化登錄信息組 socket=new DatagramSocket()。 byte notify[]=new byte[100]。 byte nametag[]=new byte[20]。 nametag=()。 //發(fā)送一個登錄信息給已登錄的用戶，通知他們本程序上線。 //包的數(shù)據(jù)結構為：判斷位+用戶名+IP地扯+用戶名長度 notify=new String(C+name +().getHostAddress()+()).getBytes()。 packet=new DatagramPacket(notify,groupC,CATCH_PORT)。 (packet)。 socketC=new MulticastSocket(CATCH_PORT)。 (groupC)。 Catcher catcher=new Catcher(socketC,this,name,userinfo)。 CheckIn login=new CheckIn(this,userinfo)。 } catch (Exception e) { ()。 }} 用來顯示用用戶名及在線人的窗口，并對窗口中各組件實施監(jiān)聽。讓其可順利生成各個聊天主界面。3．Catcher//實現(xiàn)對組播端口的監(jiān)聽，并作出反映 public void run(){ try {socket=new DatagramSocket()。 while(true){ byte[] Rdata=new byte[256]。 packet=new DatagramPacket(Rdata,)。 (packet)。//等待接受數(shù)據(jù)包 String count=new String(()).substring(()1,())。 int num=(count)。 //count記錄了數(shù)據(jù)包的最后一位數(shù)，也就是記錄了用戶名的長度。 String check=new String(()).substring(1+num,()1)。 //check為數(shù)據(jù)包的IP地址 String judge=new String(()).substring(0,1)。 String usertag=new String (()).substring(1,num+1)。 if((C)){//judge為“C”時反送一個含有對方用戶名以及本機的IP的數(shù)據(jù)包到組播組 …… } public void Connect(String check){ //Connect()方法實現(xiàn)了對對方回應本機信息的過程， //其中第一以及最后一個為無用信息，在接受方被吸收掉 …… CheckSocket=new Socket(check,CHECK_PORT)。 in=new BufferedReader(new InputStreamReader(()))。 out=new PrintWriter(())?！脕韺Φ卿浶畔⒌谋O(jiān)聽，并解析傳送過來的數(shù)據(jù)包。4．Listenerpublic void run(){ try {while(true){ byte[] Rdata=new byte[256]。 packet=new DatagramPacket(Rdata,)。//用Rdata數(shù)組來接收數(shù)據(jù)， (packet)。 //并傳給MulticastSocket對象 (new String(()))。 (true)。ring()。 } } catch (IOException e) { ()。}} 用來對群消息的監(jiān)聽及處理，將接收到的消息打包，傳給MulticastSocket對象，再利用CheckIn和Logon對象進行處理。5．CheckIn//對回應信息的端口的監(jiān)聽，一旦收到回應信息則開啟一個新線程對其進行信息的接收 public void run(){ try { Check=new ServerSocket(CHECK_PORT)。 } catch (IOException e) {()。} try { while(true){ client=()。 Logon ll=new Logon(sf,client,userinfo)。 ()。} } catch (IOException e) {()。 }}6．Logon public void run(){//run()方法實現(xiàn)對回應的TCP連接的信息的接收，并且完成對UserInfo信息的保存 String msg=null。 Try{ msg=receiveMsg()。 name=msg。//獲取對方的名字 msg=receiveMsg()。 ip=msg。//獲取對方的IP { k=()。 userinfo[k]=new UserInfo(name,ip)。 } (userinfo[k].getName())。 msg=receiveMsg()?！? } } public String receiveMsg()throws IOException{//接收數(shù)據(jù) String msg=new String()。 try { msg=()。 } catch (IOException e) {……} return msg。 }5和6主要完成對群消息的處理，5主要完成對信息的解包，顯示等等；而6主要是對TCP連接的信息的接收，以及對用戶信息的保存。7．TCPConnectpublic void run(){ try { listen=new ServerSocket(port)。 processMsg(正在監(jiān)聽TCP端口………)。//建立TCP連接 } catch (Exception e) { processMsg(群聊功能仍可使用)。//建立失敗，不過還可以群聊 } …… while(true){ Socket client = ()。 MainChatFrame mf=new MainChatFrame(client,name)。//啟動一個私聊主界面 } …… } 根據(jù)所得到對方的IP信息建立一個TCP連接，并啟動一個私聊主界面，進行TCP通信。8．UserInfopublic class UserInfo {//初始化用戶信息，姓名以及IP地址，姓名是通過登錄界面由用戶鍵入的，IP//地址是程序直接由機器獲取的 private String name。 private String IP。 public UserInfo(String name, String ip) { = name。IP = ip。} public String getIP() {return IP。} public void setIP(String ip) {IP = ip。} publ