java通過控制鼠標(biāo)實(shí)現(xiàn)屏幕廣播的方法
更新時(shí)間：2014年12月15日 11:25:39 投稿：shichen2014
這篇文章主要介紹了java通過控制鼠標(biāo)實(shí)現(xiàn)屏幕廣播的方法,針對(duì)前面一篇Java屏幕共享功能進(jìn)行了改進(jìn),實(shí)現(xiàn)了鼠標(biāo)控制功能,具有一定的實(shí)用價(jià)值,需要的朋友可以參考下
本文實(shí)例講述了java通過控制鼠標(biāo)實(shí)現(xiàn)屏幕廣播的方法。分享給大家供大家參考。具體分析如下：
在前面一篇《java實(shí)現(xiàn)屏幕共享功能實(shí)例分析》中提到截取屏幕時(shí)是沒鼠標(biāo)，為了看到教師端界面上的鼠標(biāo)，可以在截取屏幕的時(shí)候，把鼠標(biāo)繪制到每一張截圖上去，但是由于截圖的時(shí)候是一張張截取的，所以看到的鼠標(biāo)難免會(huì)有點(diǎn)卡，之前寫了java鼠標(biāo)操控小程序，可以通過這種方式來看到鼠標(biāo)的演示。
實(shí)現(xiàn)的方式也挺簡(jiǎn)單的，前面兩篇文章分別實(shí)現(xiàn)了鼠標(biāo)控制和不帶鼠標(biāo)的屏幕分享功能，把這兩個(gè)結(jié)合一下就ok了，下面簡(jiǎn)單分析下。
服務(wù)端，將SendScreenImg和SendMouseMessage看作兩個(gè)工具類，分別監(jiān)聽不同的端口，他們兩個(gè)都實(shí)現(xiàn)了Thread類，我們用線程池ExecutorService類控制他們。
使用了兩個(gè)端口，因?yàn)闀簳r(shí)還不知道該如何吧鼠標(biāo)信息和圖片的信息一起發(fā)送，或許可以把圖片轉(zhuǎn)換成字節(jié)數(shù)組的形式，把鼠標(biāo)的坐標(biāo)放在數(shù)組前面，不過這樣的話鼠標(biāo)可能也會(huì)不連貫，因?yàn)閭魉褪髽?biāo)坐標(biāo)的速度會(huì)比傳圖片的要快一些，嗯，有空再試試。
客戶端類比上面就是了。
下面是代碼：
服務(wù)端：
主程序：
復(fù)制代碼 代碼如下:
/*
* 屏幕廣播類，調(diào)用了兩個(gè)工具類：發(fā)送截屏信息的類和發(fā)送鼠標(biāo)的信息類，利用了線程池。
*/
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());
}
}
* 屏幕廣播類，調(diào)用了兩個(gè)工具類：發(fā)送截屏信息的類和發(fā)送鼠標(biāo)的信息類，利用了線程池。
*/
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ā)送截圖代碼：
復(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ā)送教師端截屏信息給學(xué)生端，沒有鼠標(biāo)信息，使用了8002號(hào)端口
* 可以在發(fā)送的圖片上面組件繪制鼠標(biāo)的信息，從而實(shí)現(xiàn)在學(xué)生端界面上見到鼠標(biāo)信息，暫未實(shí)現(xiàn)該功能
*
*/
public class 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(); //有必要先關(guān)閉當(dāng)前端口
this.serverPort = serverPort;
serverSocket = new ServerSocket(this.serverPort);
serverSocket.setSoTimeout(8000000);
}catch(Exception e){}
}
//構(gòu)造方法 開啟套接字連接 機(jī)器人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); //構(gòu)造相應(yīng)大小的矩形
}
@Override
public void run()
{
//實(shí)時(shí)等待接收截屏消息
while(true){
try {
socket = serverSocket.accept();
ZipOutputStream zip = new ZipOutputStream(new DataOutputStream(socket.getOutputStream()));
zip.setLevel(9); //設(shè)置壓縮級(jí)別
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("學(xué)生端口已經(jīng)連接");
} catch (IOException ioe) {
System.out.println("被控端：disconnect");
}
} catch (IOException ioe) {
System.out.println("連接出錯(cuò)");
} finally {
if (socket != null) {
try {
socket.close();
} catch (IOException e) {
}
}
}
}
}
}
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ā)送教師端截屏信息給學(xué)生端，沒有鼠標(biāo)信息，使用了8002號(hào)端口
* 可以在發(fā)送的圖片上面組件繪制鼠標(biāo)的信息，從而實(shí)現(xiàn)在學(xué)生端界面上見到鼠標(biāo)信息，暫未實(shí)現(xiàn)該功能
*
*/
public class 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(); //有必要先關(guān)閉當(dāng)前端口
this.serverPort = serverPort;
serverSocket = new ServerSocket(this.serverPort);
serverSocket.setSoTimeout(8000000);
}catch(Exception e){}
}
//構(gòu)造方法 開啟套接字連接 機(jī)器人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); //構(gòu)造相應(yīng)大小的矩形
}
@Override
public void run()
{
//實(shí)時(shí)等待接收截屏消息
while(true){
try {
socket = serverSocket.accept();
ZipOutputStream zip = new ZipOutputStream(new DataOutputStream(socket.getOutputStream()));
zip.setLevel(9); //設(shè)置壓縮級(jí)別
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("學(xué)生端口已經(jīng)連接");
} catch (IOException ioe) {
System.out.println("被控端：disconnect");
}
} catch (IOException ioe) {
System.out.println("連接出錯(cuò)");
} finally {
if (socket != null) {
try {
socket.close();
} catch (IOException e) {
}
}
}
}
}
}
發(fā)送鼠標(biāo)信息：
復(fù)制代碼 代碼如下:
/*
* 工具類：獲取鼠標(biāo)的信息并且發(fā)送給學(xué)生端
*/
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(); //關(guān)閉輸出流且釋放資源
System.out.println("INFO： "+operateStr);
} catch (IOException e) {
System.out.println("已經(jīng)停止連接");
break; //斷開連接的時(shí)候就停止無線循環(huán)
}
}
}
}
* 工具類：獲取鼠標(biāo)的信息并且發(fā)送給學(xué)生端
*/
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(); //關(guān)閉輸出流且釋放資源
System.out.println("INFO： "+operateStr);
} catch (IOException e) {
System.out.println("已經(jīng)停止連接");
break; //斷開連接的時(shí)候就停止無線循環(huán)
}
}
}
}
客戶端：
主程序：
復(fù)制代碼 代碼如下:
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));
}
}
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));
}
}
接收截圖代碼：
復(fù)制代碼 代碼如下:
/*
* ly 2014-11-20
* 該類用于接收教師端的屏幕信息，不包括鼠標(biāo)
* 使用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);// 接收?qǐng)D片間隔時(shí)間
} 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("遠(yuǎn)程監(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();
//窗口關(guān)閉事件
this.addWindowListener(new WindowAdapter() {
public void windowClosing(WindowEvent e) {
flag=false;
BorderInit.this.dispose();
System.out.println("窗體關(guān)閉");
System.gc(); //垃圾回收
}
});
}
}
* ly 2014-11-20
* 該類用于接收教師端的屏幕信息，不包括鼠標(biāo)
* 使用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);// 接收?qǐng)D片間隔時(shí)間
} 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("遠(yuǎn)程監(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();
//窗口關(guān)閉事件
this.addWindowListener(new WindowAdapter() {
public void windowClosing(WindowEvent e) {
flag=false;
BorderInit.this.dispose();
System.out.println("窗體關(guān)閉");
System.gc(); //垃圾回收
}
});
}
}
接收鼠標(biāo)信息并控制鼠標(biāo)移動(dòng)：
復(fù)制代碼 代碼如下:
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;
/*
* 學(xué)生端 控制鼠標(biāo)和教師端一致
* 該類 負(fù)責(zé)接收鼠標(biāo)的信息 并且用robot.mouseMove()函數(shù)控制鼠標(biāo)移動(dòng)
*/
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();
//獲取鼠標(biāo)移動(dòng)的信息
DataInputStream dataIn = new DataInputStream(socket.getInputStream());
String info="";
int r;
while((r=dataIn.read()) != -1){
info +=""+(char)r; //把字節(jié)數(shù)組中所有元素都變?yōu)樽址?br /> }
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("輸出鼠標(biāo)的信息"+x+" "+ y);
robot.mouseMove(x, y);
}
}
}
} catch (IOException e) {
System.out.println("已斷開連接");
break;
} catch (AWTException e) {
e.printStackTrace();
}
}
}
}
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;
/*
* 學(xué)生端 控制鼠標(biāo)和教師端一致
* 該類 負(fù)責(zé)接收鼠標(biāo)的信息 并且用robot.mouseMove()函數(shù)控制鼠標(biāo)移動(dòng)
*/
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();
//獲取鼠標(biāo)移動(dòng)的信息
DataInputStream dataIn = new DataInputStream(socket.getInputStream());
String info="";
int r;
while((r=dataIn.read()) != -1){
info +=""+(char)r; //把字節(jié)數(shù)組中所有元素都變?yōu)樽址?br /> }
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("輸出鼠標(biāo)的信息"+x+" "+ y);
robot.mouseMove(x, y);
}
}
}
} catch (IOException e) {
System.out.println("已斷開連接");
break;
} catch (AWTException e) {
e.printStackTrace();
}
}
}
}
希望本文所述對(duì)大家的Java程序設(shè)計(jì)有所幫助。
相關(guān)文章
Spring Boot統(tǒng)一異常處理最佳實(shí)踐(拓展篇)
這篇文章主要給大家介紹了關(guān)于Spring Boot統(tǒng)一異常處理最佳實(shí)踐(拓展篇)的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-02-02
Spring Boot項(xiàng)目打包指定包名實(shí)現(xiàn)示例
這篇文章主要為大家介紹了Spring Boot項(xiàng)目打包指定包名實(shí)現(xiàn)示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-11-11
Tomcat 實(shí)現(xiàn)WebSocket詳細(xì)介紹
這篇文章主要介紹了Tomcat 如何實(shí)現(xiàn)WebSocket的相關(guān)資料,對(duì)WebSocket協(xié)議通信的過程進(jìn)行了詳細(xì)介紹，需要的朋友可以參考下2016-12-12
很多同學(xué)會(huì)重載和重寫分不清楚，這篇文章主要介紹了詳解java重載與覆寫的區(qū)別，有需要的朋友可以了解一下。2016-11-11
這篇文章主要介紹了Mybatis使用@param注解四種情況解析,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-08-08
springboot整合企微webhook機(jī)器人發(fā)送消息提醒
這篇文章主要為大家介紹了springboot整合企微webhook機(jī)器人發(fā)送消息提醒，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-12-12
MyBatis-Plus主鍵生成策略的實(shí)現(xiàn)方法
MyBatis-Plus提供了多種主鍵生成策略,包括自增、UUID、Redis和雪花算法,本文就來介紹一下,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-12-12
這篇文章主要介紹了springboot jpa 延遲加載問題的2種解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-07-07
json-lib將json格式的字符串,轉(zhuǎn)化為java對(duì)象的實(shí)例
下面小編就為大家?guī)硪黄猨son-lib將json格式的字符串,轉(zhuǎn)化為java對(duì)象的實(shí)例。小編覺得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-03-03
springmvc處理響應(yīng)數(shù)據(jù)的解析
今天小編就為大家分享一篇關(guān)于springmvc處理響應(yīng)數(shù)據(jù)的解析，小編覺得內(nèi)容挺不錯(cuò)的，現(xiàn)在分享給大家，具有很好的參考價(jià)值，需要的朋友一起跟隨小編來看看吧2019-01-01