在java實現(xiàn)屏幕共享的小程序中提到截取屏幕時是沒鼠標，為了看到教師端界面上的鼠標，可以在截取屏幕的時候，把鼠標繪制到每一張截圖上去，但是由于截圖的時候是一張張截取的，所以看到的鼠標難免會有點卡，之前寫了java鼠標操控小程序，可以通過這種方式來看到鼠標的演示。

實現(xiàn)的方式也挺簡單的，前面兩篇文章分別實現(xiàn)了鼠標控制和不帶鼠標的屏幕分享功能，把這兩個結合一下就ok了，下面簡單分析下。

服務端，將SendScreenImg和SendMouseMessage看作兩個工具類，分別監(jiān)聽不同的端口，他們兩個都實現(xiàn)了Thread類，我們用線程池ExecutorService類控制他們。

使用了兩個端口，因為暫時還不知道該如何吧鼠標信息和圖片的信息一起發(fā)送，或許可以把圖片轉換成字節(jié)數(shù)組的形式，把鼠標的坐標放在數(shù)組前面，不過這樣的話鼠標可能也會不連貫，因為傳送鼠標坐標的速度會比傳圖片的要快一些，嗯，有空再試試。

客戶端類比上面就是了。

下面是代碼：

服務端：

主程序：

/* * 屏幕廣播類，調用了兩個工具類：發(fā)送截屏信息的類和發(fā)送鼠標的信息類，利用了線程池。 */public class BroderCast {public  static void main(String[] args){new BroderCast();System.out.PRintln("開始");}public BroderCast(){ExecutorService exector = Executors.newFixedThreadPool(2);exector.execute(new SendScreenImg());exector.execute(new SendMouseMessage());}}

發(fā)送截圖：

import java.awt.Dimension;import java.awt.Rectangle;import java.awt.Robot;import java.awt.Toolkit;import java.awt.image.BufferedImage;import java.io.DataOutputStream;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import java.util.zip.ZipEntry;import java.util.zip.ZipOutputStream;import javax.imageio.ImageIO;/* * 工具類：發(fā)送教師端截屏信息給學生端，沒有鼠標信息，使用了8002號端口 * 可以在發(fā)送的圖片上面組件繪制鼠標的信息，從而實現(xiàn)在學生端界面上見到鼠標信息，暫未實現(xiàn)該功能 *  */publicclass SendScreenImg extends Thread{public int serverPort=8002;private ServerSocket serverSocket;private Robot robot;public  Dimension screen;public Rectangle rect ;private Socket socket; public static void main(String args[]){new SendScreenImg().start();}public void changeServerPort(int serverPort){if(this.serverPort == serverPort) return ;try{this.serverSocket.close();    //有必要先關閉當前端口this.serverPort = serverPort;serverSocket = new ServerSocket(this.serverPort);serverSocket.setSoTimeout(8000000);}catch(Exception e){}}//構造方法  開啟套接字連接      機器人robot   獲取屏幕大小public SendScreenImg(){try {serverSocket = new ServerSocket(getServerPort());serverSocket.setSoTimeout(864000000);robot = new Robot();} catch (Exception e) {e.printStackTrace();}screen = Toolkit.getDefaultToolkit().getScreenSize();  //獲取主屏幕的大小rect = new Rectangle(screen);                          //構造相應大小的矩形}@Overridepublic void run() {//實時等待接收截屏消息while(true){try {socket = serverSocket.accept();ZipOutputStream zip = new ZipOutputStream(new DataOutputStream(socket.getOutputStream()));zip.setLevel(9);     //設置壓縮級別try{BufferedImage img = robot.createScreenCapture(rect);zip.putNextEntry(new ZipEntry("test.jpg"));                    ImageIO.write(img, "jpg", zip);                    if(zip!=null)zip.close();                    System.out.println("學生端口已經(jīng)連接");                } catch (IOException ioe) {                    System.out.println("被控端：disconnect");                }            } catch (IOException ioe) {            System.out.println("連接出錯");            } finally {                if (socket != null) {                    try {                        socket.close();                    } catch (IOException e) {                    }                }            }        }}}

發(fā)送鼠標信息：

/* * 工具類：獲取鼠標的信息并且發(fā)送給學生端 */public class SendMouseMessage extends Thread{private int OperaTE_PORT = 8001;private ServerSocket server;private Socket socket;private String operateStr;public static void main(String[] args){new SendMouseMessage().start();}public SendMouseMessage(){try {server = new ServerSocket(OPERATE_PORT);//JOptionPane.showMessageDialog(null, "已經(jīng)開始監(jiān)聽");} catch (IOException e1) {e1.printStackTrace();}}//多線程  在無線的循環(huán)中監(jiān)聽客戶端的public void run(){while(true){Point point = MouseInfo.getPointerInfo().getLocation();  //operateStr ="Movemouse,"+point.x+","+point.y;try {socket = server.accept();socket.setSoTimeout(1000000);DataOutputStream output =new DataOutputStream(socket.getOutputStream());output.write(operateStr.getBytes());output.flush();   //刷行輸出流，并且使所有緩沖的輸出字節(jié)寫出output.close();   //關閉輸出流且釋放資源System.out.println("INFO：  "+operateStr);} catch (IOException e) {System.out.println("已經(jīng)停止連接");break;   //斷開連接的時候就停止無線循環(huán)}}}}

客戶端：

主程序：

import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import com.Tool.OperateMouse;import com.Tool.ReceiveImages;public class ReceiveBroderCast {public ExecutorService exector;public static String IP="202.216.60.9";public static void main(String[] args){new ReceiveBroderCast(IP);}public ReceiveBroderCast(String IP) {exector = Executors.newFixedThreadPool(2);exector.execute(new ReceiveImages(IP));exector.execute(new OperateMouse(IP));}}

接收截圖：

/* * ly  2014-11-20 * 該類用于接收教師端的屏幕信息，不包括鼠標 * 使用socket() */public  class ReceiveImages extends  Thread{public BorderInit frame ;public Socket socket;public String IP;public static void main(String[] args){new ReceiveImages("202.216.60.7").start();}public ReceiveImages(String IP){frame=new BorderInit();this.IP=IP;}public void run() {while(frame.getFlag()){System.out.println("已經(jīng)連接"+(System.currentTimeMillis()/1000)%24%60+"秒");try {socket = new Socket(IP,8002);DataInputStream ImgInput = new DataInputStream(socket.getInputStream());ZipInputStream imgZip = new ZipInputStream(ImgInput);Image img = null;try{imgZip.getNextEntry();   //到Zip文件流的開始處img = ImageIO.read(imgZip); //按照字節(jié)讀取Zip圖片流里面的圖片frame.jlbImg.setIcon(new ImageIcon(img));frame.validate();}catch (IOException e) {e.printStackTrace();}try{imgZip.close();} catch (IOException e) {System.out.println("連接斷開");}try {TimeUnit.MILLISECONDS.sleep(50);// 接收圖片間隔時間} catch (InterruptedException ie) {ie.printStackTrace();}} catch (IOException e) {e.printStackTrace();}finally{try {socket.close();} catch (IOException e) {}}}}}class BorderInit extends JFrame{private static final long serialVersionUID = 1L;public JLabel jlbImg;private boolean flag;public boolean getFlag(){return this.flag;}public BorderInit(){this.flag=true;this.jlbImg = new JLabel();this.setTitle("遠程監(jiān)控--IP:"  + "--主題:" );this.setSize(400, 400);//this.setUndecorated(true);//this.setAlwaysOnTop(true);  //始終在最前面this.add(jlbImg);this.setLocationRelativeTo(null);this.setExtendedState(Frame.MAXIMIZED_BOTH);this.setDefaultCloSEOperation(DISPOSE_ON_CLOSE);this.setVisible(true);this.validate();//窗口關閉事件this.addWindowListener(new WindowAdapter() {public void windowClosing(WindowEvent e) {flag=false;BorderInit.this.dispose();System.out.println("窗體關閉");System.gc();    //垃圾回收}});}}

接收鼠標信息并控制鼠標移動：

import java.awt.AWTException;import java.awt.Robot;import java.io.BufferedInputStream;import java.io.BufferedReader;import java.io.DataInputStream;import java.io.IOException;import java.io.InputStream;import java.net.Socket;import javax.swing.JOptionPane;/* * 學生端   控制鼠標和教師端一致 * 該類  負責接收鼠標的信息  并且用robot.mouseMove()函數(shù)控制鼠標移動   */public class OperateMouse extends Thread{public static void main(String[] args){new OperateMouse("202.116.60.7").start();}private Socket socket;public String IP;private int OPERATE_PORT = 8001;private Robot robot;public OperateMouse(String IP){this.IP = IP;}public void run() {while(true){try {socket = new Socket(IP,OPERATE_PORT);robot = new Robot();//獲取鼠標移動的信息DataInputStream dataIn = new DataInputStream(socket.getInputStream());        String info="";int r;while((r=dataIn.read()) != -1){info +=""+(char)r;   //把字節(jié)數(shù)組中所有元素都變?yōu)樽址蛚dataIn.close();System.out.println("數(shù)據(jù)流斷開"+info); if(info!=null){ String s[] = info.trim().split(","); if("Movemouse".equals(s[0].trim()));{if (s.length == 3) {int x = Integer.parseInt(s[1].trim());int y = Integer.parseInt(s[2].trim());System.out.println("輸出鼠標的信息"+x+"  "+ y);robot.mouseMove(x, y);}}}} catch (IOException e) {System.out.println("已斷開連接");break;} catch (AWTException e) {e.printStackTrace();}}}}

本博客出自博客園蘭幽