遠(yuǎn)程計(jì)算機(jī)監(jiān)控系統(tǒng)

1、題目 遠(yuǎn)程計(jì)算機(jī)監(jiān)控系統(tǒng)1、 實(shí)驗(yàn)?zāi)康氖炀氝\(yùn)用JAVA開發(fā)環(huán)境及工具、并用JAVA語言編寫程序；掌握面向?qū)ο蟮母拍?；掌握系統(tǒng)功能模塊的合理劃分，并實(shí)現(xiàn)各模塊接口的連接；掌握C/S結(jié)構(gòu)的編程方法；掌握Socket編程的基本原理與方法。2、 實(shí)驗(yàn)內(nèi)容1）遠(yuǎn)程控制模式架構(gòu)，基于C/S模式；2）遠(yuǎn)程控制功能實(shí)現(xiàn)，開關(guān)機(jī)，遠(yuǎn)程監(jiān)視；3）遠(yuǎn)程控制安全考慮；4）遠(yuǎn)程控制實(shí)現(xiàn)平臺(tái)與技巧；5）遠(yuǎn)程控制軟件實(shí)現(xiàn)，要求至少能在兩臺(tái)電腦上正常運(yùn)行；6）界面新穎友好3、 實(shí)驗(yàn)過程3.1 Socket通信流程圖設(shè)計(jì)(1) 客戶端請(qǐng)求Socket的步驟如下： 建立客戶端Socket連接； 得到Socket的讀和寫的流； 利

2、用流； 關(guān)閉流； 關(guān)閉Socket。(2) 服務(wù)器端Socket要完成以下的基本的步驟： 建立一個(gè)服務(wù)器Socket并開始監(jiān)聽； 使用accept()方法取得新的連接； 建立輸入和輸出流； 在已有的協(xié)議上產(chǎn)生會(huì)話； 關(guān)閉客戶端流和Socket； 回到或者轉(zhuǎn)到； 關(guān)閉服務(wù)器Socket。 圖 為面向連接的Socket協(xié)作流程圖3.2 Java事件處理機(jī)制設(shè)計(jì)事件源注冊(cè)的方法如下： public void addActionListener(ActionListener l) 添加特定的動(dòng)作，監(jiān)聽接收來自事件源的動(dòng)作事件，如果l為空，不會(huì)產(chǎn)生任何動(dòng)作。 監(jiān)聽者實(shí)現(xiàn)的接口為ActionListene

3、r接口，接口ActionListener來自包java.awt.event。在此接口中只有一個(gè)方法： public void actionPerformed(ActionEvent e) 當(dāng)事件對(duì)象e發(fā)生時(shí)，調(diào)用此方法。監(jiān)聽者就需要實(shí)現(xiàn)這個(gè)方法。3.3 多線程機(jī)制設(shè)計(jì)線程存在一個(gè)生命周期，由以下方法體現(xiàn)：(1) start()方法：啟動(dòng)一個(gè)線程。(2) run()方法：定義該線程的動(dòng)作。(3) sleep()方法：使線程睡眠一段時(shí)間，單位為ms。(4) stop()方法：結(jié)束線程生命周期并執(zhí)行清理工作。 3.3.1 線程類和Runnable接口1. 建立Thread類的子類 class myT

4、hread extends Thread .public void start()/啟動(dòng)線程 .public void run()/運(yùn)行線程. 2. 實(shí)現(xiàn)接口Runnable public interface Runnable Runnable接口可以由任意試圖實(shí)現(xiàn)線程機(jī)制的類來實(shí)現(xiàn)。接口包含一個(gè)run方法。 public void run() 對(duì)象實(shí)現(xiàn)Runnable接口時(shí)，創(chuàng)建一個(gè)線程，啟動(dòng)線程導(dǎo)致對(duì)象run方法的調(diào)用。4、 關(guān)鍵代碼及其分析4.1 -ConnectionDialog.java-/* * Title: 目標(biāo)機(jī)器ip輸入對(duì)話框 */public class Connectio

5、nDialog extends JDialog JPanel panel1 = new JPanel(); BorderLayout borderLayout1 = new BorderLayout(); JTextField address = new JTextField(); JButton ok = new JButton(); public ConnectionDialog(MainFrame owner, String title, boolean modal) super(owner, title, modal); try setDefaultCloseOperation(DIS

6、POSE_ON_CLOSE); jbInit(); catch (Exception exception) exception.printStackTrace(); private void jbInit() throws Exception panel1.setLayout(borderLayout1); ok.setText("確定"); ok.addActionListener(new ConnectionDialog_Ok_actionAdapter(this); setContentPane(panel1); panel1.add(address, java.aw

7、t.BorderLayout.CENTER); panel1.add(ok, java.awt.BorderLayout.EAST); setSize(200,50); setMainFrameCenter(this); setResizable(false); /* * 設(shè)置彈出窗口顯示位置在主窗口中間 */ public static void setMainFrameCenter(JDialog dialog) Point point = dialog.getOwner().getLocation(); Dimension dimension = dialog.getOwner().ge

8、tSize(); dialog.setLocation(point.x+dimension.width/2-dialog.getSize().width/2, point.y+dimension.height/2-dialog.getSize().height/2);/設(shè)置位置 public InetAddress getEnterInetAddress() throws UnknownHostException return InetAddress.getByName(address.getText(); class ConnectionDialog_Ok_actionAdapter imp

9、lements ActionListener ConnectionDialog adaptee ; public ConnectionDialog_Ok_actionAdapter(ConnectionDialog adaptee) this.adaptee = adaptee; /* * 按下"確定"按鈕,開始連接被控端 */ public void actionPerformed(ActionEvent e) InetAddress inet = null; adaptee.setVisible(false); MainFrame main = (MainFrame)a

10、daptee.getOwner(); try main.setEnabled(false); inet = adaptee.getEnterInetAddress(); ControlledStatus client = MainController.Connect(inet);/發(fā)送初試化命令 main.setConnection(client); main.setEnabled(true); MainController.startClientScreen(client,main);/開啟被控端屏幕監(jiān)聽線程 main.screen.setMainControl(MainController

11、.startControlSocket(client);/開啟控制連接 main.screen.setControlledStatus(client); main.jToolBar1.disconnect.setEnabled(true); main.jToolBar1.connect.setEnabled(false); catch(UnknownHostException e1) JOptionPane.showMessageDialog(main,"被控端地址錯(cuò)誤!","錯(cuò)誤信息",JOptionPane.WARNING_MESSAGE); cat

12、ch(Exception e2) e2.printStackTrace(); JOptionPane.showMessageDialog(main,e2.getMessage(),"錯(cuò)誤信息",JOptionPane.WARNING_MESSAGE); finally adaptee.dispose(); main.setEnabled(true); public class MainFrame extends JFrame ControlledScreenPanel screen ; JPanel panel ; int flag = 0 ; /0初始顯示panel面板

13、1顯示screen面板 MainToolBar jToolBar1 ; public MainFrame() try setDefaultCloseOperation(EXIT_ON_CLOSE); jbInit(); catch (Exception exception) exception.printStackTrace(); private void jbInit() throws Exception screen = new ControlledScreenPanel(); panel = new JPanel(); jToolBar1 = new MainToolBar(this);

14、 this.setSize(new Dimension(600, 400); this.setTitle("遠(yuǎn)程控制系統(tǒng)"); getContentPane().add(jToolBar1, java.awt.BorderLayout.PAGE_START); getContentPane().add(panel,java.awt.BorderLayout.CENTER); this.setFocusable(true); public void switchPanel(int f) switch(f) case 1 : this.remove(panel); screen

15、.bind(this); break ; case 2 : screen.remove(); getContentPane().add(panel,java.awt.BorderLayout.CENTER); break ; this.flag = f ; /* * 顯示被控端屏幕 */ public void showClientScreen(BufferedImage image) if (image = null)return; screen.setBufferedImage(image); private ControlledStatus status = null; /被監(jiān)視端狀態(tài)信

16、息 private boolean isConnection = false ; /是否連接被控端 public boolean isConnection() return isConnection ; public ControlledStatus getControlledStatus() return status; public void setConnection(ControlledStatus status) this.status = status ; switchPanel(1); setVisible(false);setVisible(true); public void

17、 setDisConnection() switchPanel(2) ; this.setSize(new Dimension(600, 400); setVisible(false);setVisible(true); status = null ; 4.3 -MainController.java-public class MainController public static ControlledStatus Connect(InetAddress inet) throws Exception ControlledStatus status = null; ServerSocket s

18、erver =openNewPort(); Socket socket = null ; try server.setSoTimeout(Environment.TCP_TIME_OUT); sendCommand(inet, CommandHandle.toCommand(CommandHandle.Command_Connection, server.getLocalPort(); socket = server.accept(); ObjectInputStream read = new ObjectInputStream(socket.getInputStream(); Object

19、obj = read.readObject(); if (obj != null) status = (ControlledStatus) obj; status.setControlled(inet); else throw new IOException("連接失敗:n 目標(biāo)機(jī)器不可達(dá)"); catch (IOException e) throw new Exception("連接失敗:n 目標(biāo)機(jī)器不可達(dá)"); public static void Disconnect(InetAddress inet) try sendCommand(inet,

20、CommandHandle.toCommand(CommandHandle.Command_Disconnection, ""); catch(IOException e) public static ServerSocket openNewPort()throws IOException ServerSocket socket = null; boolean sucess = true; int count=0; while(sucess) count+; if(count>=10)throw new IOException("連接失敗,無法開啟本機(jī)器端口

21、."); int c=(int)(Math.random()*10000); int port=(int)(c-65530*(c/65530); try socket = new ServerSocket(port); sucess = false; catch (IOException e) continue ; return socket ; public static void sendCommand(InetAddress inet,String command)throws IOException byte sp = command.getBytes(); Datagram

22、Packet packet = new DatagramPacket(sp, sp.length, inet, Environment.UDP_PORT); try DatagramSocket sd = new DatagramSocket(); sd.send(packet); catch (Exception e) throw new IOException("向被控端請(qǐng)求失敗!"); public static void startClientScreen(ControlledStatus clientstatus,MainFrame frame) throws E

23、xception ServerSocket server = openNewPort(); server.setSoTimeout(Environment.TCP_TIME_OUT); sendCommand(clientstatus.getControlled(), CommandHandle.toCommand(CommandHandle.Command_Screen,server.getLocalPort(); Socket socket=server.accept(); System.out.println(socket.getRemoteSocketAddress()+ "

24、 已經(jīng)連接端口："+socket.getLocalPort()+" 等待進(jìn)行圖形傳送"); Class argTypes = new ClassSocket.class,MainFrame.class; Object args = new Objectsocket,frame; ThreadManager.start(ImageReceiveThread.class,argTypes,args); public static MainControlSocket startControlSocket(ControlledStatus clientstatus)thr

25、ows IOException MainControlSocket control = null ; try ServerSocket server = openNewPort(); server.setSoTimeout(Environment.TCP_TIME_OUT); sendCommand(clientstatus.getControlled(), CommandHandle.toCommand(CommandHandle.Command_Control,server.getLocalPort(); Socket socket=server.accept(); System.out.

26、println(socket.getRemoteSocketAddress()+ " 已經(jīng)連接端口："+socket.getLocalPort()+ " 控制套接開啟"); control = new MainControlSocket(socket); catch (IOException e) throw new IOException("網(wǎng)絡(luò)故障"); return control ; class MainControlSocket private Socket socket = null; private ObjectOutp

27、utStream out = null; public MainControlSocket(Socket socket) throws IOException this.socket = socket; this.socket.setSendBufferSize(Environment.EVENT_CACHE); out = new ObjectOutputStream(socket.getOutputStream(); public class ControlledWindowResponseThread extends ThreadServer private Socket socket

28、; private ObjectInputStream in ; private Robot action ; private boolean isRun = true; public ControlledWindowResponseThread(Socket socket) throws IOException, AWTException action = new Robot(); this.socket = socket; this.socket.setReceiveBufferSize(Environment.EVENT_CACHE); in = new ObjectInputStrea

29、m(socket.getInputStream(); public void run() while (isRun) try Object obj = in.readObject(); if (obj != null) handleEvent( (InputEvent) obj); /處理 catch (ClassNotFoundException e) continue; catch (IOException ex) break; try if (in != null) in.close(); in = null; if (socket != null) socket.close(); so

30、cket = null; ThreadManager.remove(this.getClass(); catch (Exception e) /*-事件處理-*/ private void handleEvent(InputEvent event) MouseEvent mevent = null ; /鼠標(biāo)事件 MouseWheelEvent mwevent = null ;/鼠標(biāo)滾動(dòng)事件 KeyEvent kevent = null ; /鍵盤事件 int mousebuttonmask = -100; /鼠標(biāo)按鍵 switch (event.getID() case MouseEvent

31、.MOUSE_MOVED : /鼠標(biāo)移動(dòng) mevent = ( MouseEvent )event ; action.mouseMove( mevent.getX() , mevent.getY() ); break ; case MouseEvent.MOUSE_PRESSED : /鼠標(biāo)鍵按下 mevent = ( MouseEvent ) event; action.mouseMove( mevent.getX() , mevent.getY() ); mousebuttonmask = getMouseClick( mevent.getButton() ); if(mousebutto

32、nmask != -100) action.mousePress(mousebuttonmask); break; case MouseEvent.MOUSE_RELEASED : /鼠標(biāo)鍵松開 mevent = ( MouseEvent ) event; action.mouseMove( mevent.getX() , mevent.getY() ); mousebuttonmask = getMouseClick( mevent.getButton() ); if(mousebuttonmask != -100) action.mouseRelease( mousebuttonmask

33、); break ; case MouseEvent.MOUSE_WHEEL : /鼠標(biāo)滾動(dòng) mwevent = ( MouseWheelEvent ) event ; action.mouseWheel(mwevent.getWheelRotation(); break ; case MouseEvent.MOUSE_DRAGGED : /鼠標(biāo)拖拽 mevent = ( MouseEvent ) event ; action.mouseMove( mevent.getX(), mevent.getY() ); break ; case KeyEvent.KEY_PRESSED : /按鍵 k

34、event = ( KeyEvent ) event; action.keyPress( kevent.getKeyCode() ); break ; case KeyEvent.KEY_RELEASED : /松鍵 kevent= ( KeyEvent ) event ; action.keyRelease( kevent.getKeyCode() ); break ; default: break ; /* * 鼠標(biāo)按鍵翻譯 */ private int getMouseClick(int button) if (button = MouseEvent.BUTTON1) /左鍵 ,中間鍵為

35、BUTTON2 return InputEvent.BUTTON1_MASK; if (button = MouseEvent.BUTTON3) /右鍵 return InputEvent.BUTTON3_MASK; return -100; /* * 鼠標(biāo)單擊 */ public void mouseClick(int mousebuttonmask) action.mousePress(mousebuttonmask); action.mouseRelease(mousebuttonmask); public void quit() isRun = false; /* * Title: 圖

36、像接收線程 * */public class ImageReceiveThread extends ThreadServer private Socket socket ; private MainFrame frame ; JPEGImageDecoder de = null; BufferedImage image = null; private boolean isRun = true; public ImageReceiveThread(Socket socket,MainFrame frame) throws Exception this.socket = socket ; this

37、.frame = frame ; socket.setReceiveBufferSize(Environment.IMAGE_CACHE * 3); /接收緩沖 de = JPEGCodec.createJPEGDecoder(socket.getInputStream(); public void run() try while (isRun) image = de.decodeAsBufferedImage(); if (image != null) frame.showClientScreen(image); catch (Exception e) finally try socket.

38、close(); de = null ; image = null ; ThreadManager.remove(this.getClass(); catch (Exception e) public void quit() isRun = false; /* * Title: 線程管理 * */public class ThreadManager private static HashMap threadMap = new HashMap(); public static void start(Class cls,Class argTypes,Object args)throws Excep

39、tion ThreadServer t = (ThreadServer)threadMap.get(cls.getName(); if(t=null) t = (ThreadServer)(cls.getConstructor(argTypes).newInstance(args); t.start(); System.out.println(cls.getName() + "is start "); threadMap.put(cls.getName(),t); public static void quit(Class cls) ThreadServer t = (Th

40、readServer)threadMap.get(cls.getName(); if(t!=null) t.quit(); remove(cls); System.out.println(cls.getName() + "is quit "); public static void remove(Class cls) if(threadMap.containsKey(cls.getName() threadMap.remove(cls.getName(); System.out.println(cls.getName() + "is remove ");

41、 abstract class ThreadServer extends Thread public abstract void quit();/* *Title: 啟動(dòng)被控端 * */public class JPcAnyWhereControlled private static JPcAnyWhereControlled client = null ; ControlledReceiver receiver ; private JPcAnyWhereControlled() try receiver = new ControlledReceiver(); /開啟客戶端服務(wù) catch (

42、Exception e) public static void start() if(client=null) client = new JPcAnyWhereControlled(); public static JPcAnyWhereControlled getClient() if (client = null) start(); return client; public ControlledReceiver getReceiver() return receiver ; public static void main(String args) JPcAnyWhereControlle

43、d.start(); /* *Title: 被控端接收線程 */public class ControlledReceiver private DatagramSocket stockUDP ; public ControlledReceiver() try stockUDP = new DatagramSocket(Environment.UDP_PORT); System.out.println("成功開啟UDP端口 "+Environment.UDP_PORT); startReceiver();/啟動(dòng)命令接收線程 catch(SocketException e) JOptionPane.showMessageDialog(null, "開啟UDP端口 "+Environment.UDP_P