基本过程是android作为socket客户端将采集到的每一帧图像数据发送出去,PC作为服务器接收并显示每一帧图像实现远程监控。图片如下(后来PC端加了个拍照功能)。。。
(PS。刚学android和java不久很多东西还不懂,高手若是知道哪些地方可以继续优化的话还请多多指点下啊)
系统代码如下:
一、android手机客户端
(1)AndroidManifest.xml文件。添加camera和socket权限,并设置了程序开始执行的activity、
<?xml
version= "1.0" encoding= "utf-8" ?> <manifest
xmlns:android= "http://schemas.android.com/apk/res/android" package = "org.wanghai.CameraTest" android:versionCode= "1" android:versionName= "1.0" > <uses-sdk
android:minSdkVersion= "15" /> <!--
授予程序使用摄像头的权限 --> <uses-permission
android:name= "android.permission.CAMERA" />
<uses-feature
android:name= "android.hardware.camera" />
<uses-feature
android:name= "android.hardware.camera.autofocus" /> <uses-permission
android:name= "android.permission.INTERNET" /> <uses-permission
android:name= "android.permission.KILL_BACKGROUND_PROCESSES" /> <uses-permission
android:name= "android.permission.RESTART_PACKAGES" /> <application android:icon= "@drawable/ic_launcher" android:label= "@string/app_name" > <activity android:name= ".GetIP" android:screenOrientation= "landscape" android:label= "@string/app_name" > <intent-filter> <action
android:name= "android.intent.action.MAIN" /> <category
android:name= "android.intent.category.LAUNCHER" /> </intent-filter> </activity> <activity android:name= ".CameraTest" android:screenOrientation= "landscape" android:label= "@string/app_name" > </activity> </application> </manifest> |
(2)main.xml 设置surfaceview用于摄像头采集图像的预览
<?xml
version= "1.0" encoding= "utf-8" ?> <LinearLayout
xmlns:android= "http://schemas.android.com/apk/res/android" android:layout_width= "fill_parent" android:layout_height= "fill_parent" android:orientation= "vertical" > <SurfaceView android:id= "@+id/sView" android:layout_width= "fill_parent" android:layout_height= "fill_parent" android:scaleType= "fitCenter" /> </LinearLayout> |
(3)login.xml 登录界面,用于输入服务器IP
<?xml
version= "1.0" encoding= "utf-8" ?> <TableLayout
xmlns:android= "http://schemas.android.com/apk/res/android" android:id= "@+id/loginForm" android:orientation= "vertical" android:layout_width= "fill_parent" android:layout_height= "fill_parent" > <TableRow>
<TextView android:layout_width= "fill_parent" android:layout_height= "wrap_content" android:text= "IP:" android:textSize= "10pt" /> <!--
输入用户名的文本框 --> <EditText android:id= "@+id/ipedittext" android:layout_width= "fill_parent" android:layout_height= "wrap_content" android:digits= "0123456789." android:hint= "请填写服务器IP" android:selectAllOnFocus= "true" /> </TableRow> </TableLayout> |
(4)GetIP.java 获得服务器IP后,通过Intent启动CameraTest的activity,ip信息通过Bundle传递
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.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 ,CameraTest. class ); intent.putExtras(data); startActivity(intent); } }); //
为对话框设置一个“取消”按钮 builder.setNegativeButton( "取消" ,
new OnClickListener() { @Override public void onClick(DialogInterface
dialog, int which) { //取消登录,不做任何事情。 System.exit( 1 ); } }); //创建、并显示对话框 builder.create().show(); } } |
(5)CameraTest.java 程序主体。设置PreviewCallback后,每当一帧图像数据采集完成后将调用PreviewCallback的onPreviewFrame函数。在这里我们将YUV格式数据转为jpg,再启用线程将数据通过socket发送出去。
public class CameraTest
extends Activity
{ SurfaceView
sView; SurfaceHolder
surfaceHolder; int screenWidth,
screenHeight; Camera
camera; //
定义系统所用的照相机 boolean isPreview
= false ;
//是否在浏览中 private String
ipname; @SuppressWarnings ( "deprecation" ) @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.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()
{ @Override public void surfaceChanged(SurfaceHolder
holder, int format,
int width, int height)
{ } @Override public void surfaceCreated(SurfaceHolder
holder) { initCamera();
//
打开摄像头 } @Override public 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; } @Override public 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(); } } } |
二、PC服务器端
ImageServer.java 用于显示图像,并且可以拍照
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(); } } } |
开放源码如下(android我使用的是4.03的SDK,其它版本请自行更改。2.3.3版本以下的请注意initCamera()里被注释掉的哪一行)
只能在android4.04系统的手机上运行成功哦。
下面是测试成功时的启动画面:
源码链接:
原文地址:http://blog.csdn.net/u014723529/article/details/41721279