Android下实现一个手机监控摄像头

一直想在自己的Android手机上实现一个手机监控摄像头功能。今天逛论坛，看到一个例子，于是做了出来，留着以后完善。

功能点：

1。Android和PC通过socket通信。

2。Android下Camera的使用。

看代码：

package com.wenix.androidcameramonitor;import android.app.Activity;import android.app.AlertDialog;import android.app.AlertDialog.Builder;import android.content.DialogInterface;import android.content.DialogInterface.OnClickListener;import android.content.Intent;import android.os.Bundle;import android.view.Window;import android.view.WindowManager;import android.widget.EditText;import android.widget.TableLayout;public class GetIP extends Activity {    String ipname = null;    @Override    public void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);// 设置全屏requestWindowFeature(Window.FEATURE_NO_TITLE);getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN,WindowManager.LayoutParams.FLAG_FULLSCREEN);setContentView(R.layout.activity_main);final Builder builder = new AlertDialog.Builder(this); // 定义一个AlertDialog.Builder对象builder.setTitle("登录服务器对话框"); // 设置对话框的标题// 装载/res/layout/login.xml界面布局TableLayout loginForm = (TableLayout) getLayoutInflater().inflate(R.layout.login, null);final EditText iptext = (EditText) loginForm.findViewById(R.id.ipedittext);builder.setView(loginForm); // 设置对话框显示的View对象// 为对话框设置一个“登录”按钮builder.setPositiveButton("登录"// 为按钮设置监听器, new OnClickListener() {    @Override    public void onClick(DialogInterface dialog, int which) {// 此处可执行登录处理ipname = iptext.getText().toString().trim();Bundle data = new Bundle();data.putString("ipname", ipname);Intent intent = new Intent(GetIP.this, MainActivity.class);intent.putExtras(data);startActivity(intent);    }});// 为对话框设置一个“取消”按钮builder.setNegativeButton("取消", new OnClickListener() {    @Override    public void onClick(DialogInterface dialog, int which) {// 取消登录，不做任何事情。System.exit(1);    }});// 创建、并显示对话框builder.create().show();    }}

获取ip后就跳转到MainActivity。

package com.wenix.androidcameramonitor;import java.io.ByteArrayInputStream;import java.io.ByteArrayOutputStream;import java.io.IOException;import java.io.OutputStream;import java.net.Socket;import android.app.Activity;import android.content.Intent;import android.graphics.ImageFormat;import android.graphics.Rect;import android.graphics.YuvImage;import android.hardware.Camera;import android.hardware.Camera.Size;import android.os.Bundle;import android.util.Log;import android.view.SurfaceHolder;import android.view.SurfaceHolder.Callback;import android.view.SurfaceView;import android.view.Window;import android.view.WindowManager;public class MainActivity extends Activity {SurfaceView sView;SurfaceHolder surfaceHolder;int screenWidth, screenHeight;Camera camera; // 定义系统所用的照相机boolean isPreview = false; // 是否在浏览中private String ipname;@Overridepublic void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);// 设置全屏requestWindowFeature(Window.FEATURE_NO_TITLE);getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN, WindowManager.LayoutParams.FLAG_FULLSCREEN);setContentView(R.layout.activity_main);// 获取IP地址Intent intent = getIntent();Bundle data = intent.getExtras();ipname = data.getString("ipname");screenWidth = 640;screenHeight = 480;sView = (SurfaceView) findViewById(R.id.sView); // 获取界面中SurfaceView组件surfaceHolder = sView.getHolder(); // 获得SurfaceView的SurfaceHolder// 为surfaceHolder添加一个回调监听器surfaceHolder.addCallback(new Callback() {@Overridepublic void surfaceChanged(SurfaceHolder holder, int format, int width, int height) {}@Overridepublic void surfaceCreated(SurfaceHolder holder) {initCamera(); // 打开摄像头}@Overridepublic void surfaceDestroyed(SurfaceHolder holder) {// 如果camera不为null ,释放摄像头if (camera != null) {if (isPreview)camera.stopPreview();camera.release();camera = null;}System.exit(0);}});// 设置该SurfaceView自己不维护缓冲surfaceHolder.setType(SurfaceHolder.SURFACE_TYPE_PUSH_BUFFERS);}private void initCamera() {if (!isPreview) {camera = Camera.open();}if (camera != null && !isPreview) {try {Camera.Parameters parameters = camera.getParameters();parameters.setPreviewSize(screenWidth, screenHeight); // 设置预览照片的大小parameters.setPreviewFpsRange(20, 30); // 每秒显示20~30帧parameters.setPictureFormat(ImageFormat.NV21); // 设置图片格式parameters.setPictureSize(screenWidth, screenHeight); // 设置照片的大小// camera.setParameters(parameters); // android2.3.3以后不需要此行代码camera.setPreviewDisplay(surfaceHolder); // 通过SurfaceView显示取景画面camera.setPreviewCallback(new StreamIt(ipname)); // 设置回调的类camera.startPreview(); // 开始预览camera.autoFocus(null); // 自动对焦} catch (Exception e) {e.printStackTrace();}isPreview = true;}}}class StreamIt implements Camera.PreviewCallback {private String ipname;public StreamIt(String ipname) {this.ipname = ipname;}@Overridepublic void onPreviewFrame(byte[] data, Camera camera) {Size size = camera.getParameters().getPreviewSize();try {// 调用image.compressToJpeg（）将YUV格式图像数据data转为jpg格式YuvImage image = new YuvImage(data, ImageFormat.NV21, size.width, size.height, null);if (image != null) {ByteArrayOutputStream outstream = new ByteArrayOutputStream();image.compressToJpeg(new Rect(0, 0, size.width, size.height), 80, outstream);outstream.flush();// 启用线程将图像数据发送出去Thread th = new MyThread(outstream, ipname);th.start();}} catch (Exception ex) {Log.e("Sys", "Error:" + ex.getMessage());}}}class MyThread extends Thread {private byte byteBuffer[] = new byte[1024];private OutputStream outsocket;private ByteArrayOutputStream myoutputstream;private String ipname;public MyThread(ByteArrayOutputStream myoutputstream, String ipname) {this.myoutputstream = myoutputstream;this.ipname = ipname;try {myoutputstream.close();} catch (IOException e) {e.printStackTrace();}}public void run() {try {// 将图像数据通过Socket发送出去Socket tempSocket = new Socket(ipname, 6000);outsocket = tempSocket.getOutputStream();ByteArrayInputStream inputstream = new ByteArrayInputStream(myoutputstream.toByteArray());int amount;while ((amount = inputstream.read(byteBuffer)) != -1) {outsocket.write(byteBuffer, 0, amount);}myoutputstream.flush();myoutputstream.close();tempSocket.close();} catch (IOException e) {e.printStackTrace();}}}

这样就打开了socket，然后把camera获取的数据发送到PC端。

PC端代码：

package com.wenix;import java.awt.Dimension;import java.awt.Graphics;import java.awt.Image;import java.awt.Toolkit;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.io.File;import java.io.FileNotFoundException;import java.io.IOException;import java.io.InputStream;import java.io.RandomAccessFile;import java.net.ServerSocket;import java.net.Socket;import javax.imageio.ImageIO;import javax.swing.JButton;import javax.swing.JFileChooser;import javax.swing.JFrame;import javax.swing.JPanel;public class ImageServer {            public static ServerSocket ss = null;        public static void main(String args[]) throws IOException{                ss = new ServerSocket(6000);                final ImageFrame frame = new ImageFrame(ss);        frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);        frame.setVisible(true);               while(true){                frame.panel.getimage();            frame.repaint();        }            }       }/**     A frame with an image panel*/@SuppressWarnings("serial")class ImageFrame extends JFrame{        public ImagePanel panel;        public JButton jb;       public ImageFrame(ServerSocket ss){               // get screen dimensions                             Toolkit kit = Toolkit.getDefaultToolkit();        Dimension screenSize = kit.getScreenSize();        int screenHeight = screenSize.height;        int screenWidth = screenSize.width;        // center frame in screen        setTitle("ImageTest");        setLocation((screenWidth - DEFAULT_WIDTH) / 2, (screenHeight - DEFAULT_HEIGHT) / 2);        setSize(DEFAULT_WIDTH, DEFAULT_HEIGHT);        // add panel to frame        this.getContentPane().setLayout(null);        panel = new ImagePanel(ss);        panel.setSize(640,480);        panel.setLocation(0, 0);        add(panel);        jb = new JButton("拍照");        jb.setBounds(0,480,640,50);        add(jb);        saveimage saveaction = new saveimage(ss);        jb.addActionListener(saveaction);    }    public static final int DEFAULT_WIDTH = 640;    public static final int DEFAULT_HEIGHT = 560;  }/**   A panel that displays a tiled image*/@SuppressWarnings("serial")class ImagePanel extends JPanel {         private ServerSocket ss;    private Image image;    private InputStream ins;             public ImagePanel(ServerSocket ss) {              this.ss = ss;    }        public void getimage() throws IOException{            Socket s = this.ss.accept();        System.out.println("连接成功!");        this.ins = s.getInputStream();                this.image = ImageIO.read(ins);                this.ins.close();    }       public void paintComponent(Graphics g){          super.paintComponent(g);            if (image == null) return;        g.drawImage(image, 0, 0, null);    }}class saveimage implements ActionListener {        RandomAccessFile inFile = null;        byte byteBuffer[] = new byte[1024];        InputStream ins;        private ServerSocket ss;                public saveimage(ServerSocket ss){                this.ss = ss;        }                public void actionPerformed(ActionEvent event){        try {                        Socket s = ss.accept();                        ins = s.getInputStream();                                                // 文件选择器以当前的目录打开                JFileChooser jfc = new JFileChooser(".");                jfc.showSaveDialog(new javax.swing.JFrame());                // 获取当前的选择文件引用                File savedFile = jfc.getSelectedFile();                                // 已经选择了文件                if (savedFile != null) {                    // 读取文件的数据，可以每次以快的方式读取数据                    try {                                        inFile = new RandomAccessFile(savedFile, "rw");                                } catch (FileNotFoundException e) {                                        e.printStackTrace();                                }                }            int amount;            while ((amount = ins.read(byteBuffer)) != -1) {                inFile.write(byteBuffer, 0, amount);            }            inFile.close();            ins.close();            s.close();            javax.swing.JOptionPane.showMessageDialog(new javax.swing.JFrame(),                    "已接保存成功", "提示!", javax.swing.JOptionPane.PLAIN_MESSAGE);                } catch (IOException e) {                        e.printStackTrace();                }        }}

运行结果如下：

手机视频：

pc端视频：

可以看到视频数据已经上传到了PC端。

接下来要完善的地方：

1。Android端可以提供一个Url，然后PC端使用浏览器来浏览。

2。PC端添加视频录制功能。

3。添加图像检测功能，比如运动物体检测等，这样就可以扩展为监控摄像头了。

更多相关文章

随机推荐