main.xml

<?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" ><TextView android:id="@+id/Tips"android:layout_width="fill_parent"android:layout_height="wrap_content"android:text="@string/init_tips"android:textSize="40px"android:textColor="#00ff00"/><Button android:id="@+id/btn_network" android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="@string/login"android:textSize="40px"android:textColor="#00ff00"/><TextViewandroid:id="@+id/statc001" android:layout_width="wrap_content"android:layout_height="wrap_content" android:textSize="40px"android:textColor="#00ff00"/><Button android:id="@+id/btn_video"android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="@string/move"android:textSize="40px"/></LinearLayout>

?

?

flash.xml

<?xml version="1.0" encoding="utf-8"?> <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"android:layout_width="match_parent"android:layout_height="match_parent" android:gravity="center"android:orientation="vertical" ><TextViewandroid:id="@+id/hintTv"android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="@string/login_hint" /><EditTextandroid:id="@+id/ip"android:hint="@string/ip_hint"android:layout_width="fill_parent"android:layout_height="wrap_content"android:gravity="center"android:text="192.168.0.10"/><EditTextandroid:id="@+id/port"android:layout_width="fill_parent"android:layout_height="wrap_content"android:text="8080"android:gravity="center"/><Buttonandroid:id="@+id/connect"android:layout_width="fill_parent"android:layout_height="40.0dip"android:layout_marginLeft="10.0dip"android:layout_marginRight="10.0dip"android:layout_marginTop="20.0dip"android:text="@string/connect"android:textColor="#ffffffff"android:textSize="18.0sp" /></LinearLayout>

mainactivity.xml

<?xml version="1.0" encoding="utf-8"?> <RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"android:layout_width="fill_parent"android:layout_height="fill_parent" ><TextView android:layout_width="fill_parent"android:layout_height="wrap_content"android:text="視頻顯示"/><com.mjpeg.view.MjpegViewandroid:id="@+id/mjpegview"android:layout_width="fill_parent"android:layout_height="fill_parent"/> </RelativeLayout>

strings.xml

<?xml version="1.0" encoding="utf-8"?> <resources><string name="login">連接服務(wù)器</string><string name="app_name">梧州學(xué)院圖書館刷卡入座系統(tǒng)</string><string name="move">視頻</string><string name="init_tips">提示:請先打開WiFi或GPRS再連接網(wǎng)絡(luò)</string><string name="people1">空座</string><string name="people2">有人</string><string name="login_hint">connecting......;</string><string name="ip">IP:</string><string name="ip_hint">請輸入IP地址</string><string name="port">Port:</string><string name="port_hint">端口1000到65535</string><string name="connect">鏈接</string><string name="connect_failed">鏈接失敗</string></resources>

?

AndroidManifest.xml

<?xml version="1.0" encoding="utf-8"?> <manifest xmlns:android="http://schemas.android.com/apk/res/android"package="my.work.Library"android:versionCode="1"android:versionName="1.0" ><uses-sdk android:minSdkVersion="15" /><applicationandroid:icon="@drawable/ic_launcher"android:label="@string/app_name" ><activityandroid:name=".WsnActivty"android:label="@string/app_name" ><intent-filter><action android:name="android.intent.action.MAIN" /><category android:name="android.intent.category.LAUNCHER" /></intent-filter></activity><activityandroid:name=".FlashActivity"android:theme="@android:style/Theme.NoTitleBar.Fullscreen"android:screenOrientation="portrait" ><intent-filter><category android:name="android.intent.category.LAUNCHER" /></intent-filter></activity><activityandroid:name=".LinearLayout_activity"android:theme="@android:style/Theme.NoTitleBar.Fullscreen"android:screenOrientation="portrait" ><intent-filter><category android:name="android.intent.category.LAUNCHER" /></intent-filter></activity></application><uses-permission android:name="android.permission.INTERNET"/><uses-permission android:name="android.permission.ACCESS_WIFI_STATE"/><uses-permission android:name="android.permission.CHANGE_WIFI_STATE"/><uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"/> </manifest>

?

Generic.java

package tools;import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.FileReader; import java.io.IOException; import java.io.OutputStreamWriter; import java.net.InetAddress; import java.net.NetworkInterface; import java.net.SocketException; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.Comparator; import java.util.Date; import java.util.Enumeration; import java.util.List;import android.content.Context; import android.graphics.Bitmap; import android.graphics.BitmapFactory; import android.media.ThumbnailUtils; import android.os.Environment; import android.text.format.Time; import android.util.Log; import android.widget.Toast;public class Generic {public static void showMsg(Context c, String msg, boolean flag){if(flag)/*** Toast是已經(jīng)用于顯示給用戶的控件，顯示一段時間后消失，可以多久消失* LENGTH_SHORT：斷的顯示時間* LENGTH_LONG :長的顯示時間*/Toast.makeText(c, msg, Toast.LENGTH_SHORT).show(); elseToast.makeText(c, msg, Toast.LENGTH_LONG).show();}// get sysTimepublic static String getSysNowTime() {Time localTime = new Time();localTime.setToNow();String strTime = localTime.format("%Y-%m-%d-%H-%M-%S");return strTime;}/*** 得到sdcard的路徑* @return 失敗返回null*/public static File getSdCardFile(){if(Environment.getExternalStorageState().equals(Environment.MEDIA_MOUNTED)){return Environment.getExternalStorageDirectory();}return null;}/*** 獲取所有連接到本wifi熱點(diǎn)的手機(jī)IP地址*/ public static ArrayList<String> getConnectedIP() { ArrayList<String> connectedIP = new ArrayList<String>(); try { BufferedReader br = new BufferedReader(new FileReader("/proc/net/arp")); String line; br.readLine();while ((line = br.readLine()) != null) { String[] splitted = line.split(" "); if (splitted != null && splitted.length >= 4) { String ip = splitted[0]; connectedIP.add(ip); } } } catch (Exception e) { e.printStackTrace(); } return connectedIP; } /*** 得到照片的縮略圖* @param f 照片文件* @param w 圖片縮小的目標(biāo)寬度* @param h 圖片縮小的目標(biāo)高度* @return* 1.根據(jù)android提供的BitmapFactory.Options類創(chuàng)建并設(shè)置好options* 2.根據(jù)File獲得流對象* 3.根據(jù)BitmapFactory.decodeStream獲得位圖* 4.改變圖片為居中縮放，返回位圖*/public static Bitmap getShrinkedPic(File f){Bitmap smallBitmap = null;// 直接通過圖片路徑將圖片轉(zhuǎn)化為bitmap,并將bitmap壓縮，避免內(nèi)存溢出BitmapFactory.Options options = new BitmapFactory.Options();options.inSampleSize = 10;// 圖片寬高都為原來的十分之一options.inPreferredConfig = Bitmap.Config.ARGB_4444;// 每個像素占用2byte內(nèi)存options.inPurgeable = true;// 如果 inPurgeable// 設(shè)為True的話表示使用BitmapFactory創(chuàng)建的Bitmap// 用于存儲Pixel的內(nèi)存空間在系統(tǒng)內(nèi)存不足時可以被回收options.inInputShareable = true;FileInputStream fInputStream;try {fInputStream = new FileInputStream(f);// 建議使用BitmapFactory.decodeStreamBitmap bitmap = BitmapFactory.decodeStream(fInputStream, null, options);// 直接根據(jù)圖片路徑轉(zhuǎn)化為bitmapsmallBitmap = ThumbnailUtils.extractThumbnail(bitmap, 64, 48);// 創(chuàng)建所需尺寸居中縮放的位圖} catch (FileNotFoundException e) {e.printStackTrace();return null;}return smallBitmap;}/*** Integer值越大，則排在前面* @author Administrator**/public static class DescendSortByIndex implements Comparator<Integer>{/*** @return 負(fù)數(shù)：object2<object1，正數(shù)：object2>object1，0：相等*/@Overridepublic int compare(Integer object1, Integer object2) {return object2.compareTo(object1);}}/*** File的最后修改時間值越大，則排在前面* @author Administrator**/public static class DescendSortByTime implements Comparator<File>{/*** @return 負(fù)數(shù)：object2<object1，正數(shù)：object2>object1，0：相等*/@Overridepublic int compare(File object1, File object2) {return (int) (object2.lastModified() - object1.lastModified());}} }

Mjpeg.java

package com.mjpeg.view;import java.io.IOException;import tools.Generic;import my.work.Library.R; import com.mjpeg.io.MjpegInputStream;import android.content.Context; import android.graphics.Bitmap; import android.graphics.Canvas; import android.graphics.Color; import android.graphics.Paint; import android.graphics.PorterDuff; import android.graphics.PorterDuffXfermode; import android.graphics.Rect; import android.graphics.Typeface; import android.util.AttributeSet; import android.util.Log; import android.view.SurfaceHolder; import android.view.SurfaceView; /*** 此類繼承了SurfaceView實(shí)現(xiàn)了SurfaceHolder.Callback接口* SurfaceView是視圖類(view)的繼承類，這個視圖里內(nèi)嵌入了一個專門用于繪制的Surface ，可以控制這個Surface的格式和尺寸* SurfaceView控制這個Surface的繪制位置* surface是縱深排序(Z-ordered)的，這表明它總在自己所在窗口的后面。surfaceview提供了一個可見區(qū)域* 只有在這個可見區(qū)域內(nèi) 的surface部分內(nèi)容才可見，可見區(qū)域外的部分不可見。surface的排版顯示受到視圖層級關(guān)系的影響* 它的兄弟視圖結(jié)點(diǎn)會在頂端顯示，這意味者 surface的內(nèi)容會被它的兄弟視圖遮擋，這一特性可以用來放置遮蓋物(overlays)(例如，文本和按鈕等控件)* 可以通過SurfaceHolder接口訪問這個surface，getHolder()方法可以得到這個接口* surfaceview變得可見時 ，surface被創(chuàng)建；surfaceview隱藏前，surface被銷毀；這樣能節(jié)省資源。如果你要查看 surface被創(chuàng)建和銷毀的時機(jī)* 可以重載surfaceCreated(SurfaceHolder)和 surfaceDestroyed(SurfaceHolder)* surfaceview的核心在于提供了兩個線程:UI線程和渲染線程，這里應(yīng)注意:* 1> 所有SurfaceView和SurfaceHolder.Callback的方法都應(yīng)該在UI線程里調(diào)用，一般來說就是應(yīng)用程序主線程，渲染線程所要訪問的各種變量應(yīng)該作同步處理。* 2> 由于surface可能被銷毀，它只在SurfaceHolder.Callback.surfaceCreated()和 SurfaceHolder.Callback.surfaceDestroyed()之間有效，* 所以要確保渲染線程訪問的是合法有效的surface* 整個過程:繼承SurfaceView并實(shí)現(xiàn)SurfaceHolder.Callback接口 ----> SurfaceView.getHolder()獲得SurfaceHolder對象(Surface控制器) * ---->SurfaceHolder.addCallback(callback)添加回調(diào)函數(shù)---->SurfaceHolder.lockCanvas()獲得Canvas對象并鎖定畫布* ----> Canvas繪畫 ---->SurfaceHolder.unlockCanvasAndPost(Canvas canvas)結(jié)束鎖定畫圖，并提交改變，將圖形顯示。*/ public class MjpegView extends SurfaceView implements SurfaceHolder.Callback {/*fps顯示位置*/public final static int POSITION_UPPER_LEFT = 9;public final static int POSITION_UPPER_RIGHT = 3;public final static int POSITION_LOWER_LEFT = 12;public final static int POSITION_LOWER_RIGHT = 6;/*圖像顯示模式*/public final static int STANDARD_MODE = 1;//標(biāo)準(zhǔn)尺寸public final static int KEEP_SCALE_MODE = 4;//保持寬高比例public final static int FULLSCREEN_MODE = 8;//全屏private Context mContext = null;private MjpegViewThread mvThread = null;private MjpegInputStream mIs = null;private Paint overlayPaint = null;//用于fps涂層繪畫筆private boolean bIsShowFps = true;private boolean bRun = false;private boolean bsurfaceIsCreate = false;private int overlayTextColor;private int overlayBackgroundColor;private int ovlPos;private int dispWidth;//MjpegView的寬度private int dispHeight;//MjpegView的高度private int displayMode;//覆蓋模式public MjpegView(Context context) {super(context);init(context);}/*** 因?yàn)樵趓es/layout目錄下的main.xml中作為自定義的控件使用了這個類，所以需要給此類提供帶有屬性形參的構(gòu)造函數(shù)* 當(dāng)在MainActivity通過ID找到這自定義的控件時，該構(gòu)造函數(shù)將被調(diào)用，所以將該構(gòu)造函數(shù)設(shè)為public * @param context* @param attrs*/public MjpegView(Context context, AttributeSet attrs) {super(context, attrs);init(context);}/*** 類的私有方法* 1.獲得Surface控制器，為Surface控制器添加回調(diào)接口* 2.新建渲染線程MjpegViewThread* 3.新建覆蓋畫筆，設(shè)置文本的對齊方式、文本長度、字體、畫筆文本顏色、畫筆背景* 4.設(shè)置覆蓋動態(tài)文本的覆蓋位置 //如果你只需要實(shí)現(xiàn)監(jiān)控畫面的功能，3和4步可以省略* 5.設(shè)置MjpegView顯示模式* @param context*/private void init(Context context) {mContext = context;SurfaceHolder holder = getHolder();holder.addCallback(this);mvThread = new MjpegViewThread(holder, context);setFocusable(true);overlayPaint = new Paint();overlayPaint.setTextAlign(Paint.Align.LEFT);overlayPaint.setTextSize(12);overlayPaint.setTypeface(Typeface.DEFAULT);overlayTextColor = Color.RED;overlayBackgroundColor = Color.TRANSPARENT;ovlPos = MjpegView.POSITION_UPPER_RIGHT;displayMode = MjpegView.KEEP_SCALE_MODE;}/*** Surface的任何結(jié)構(gòu)性結(jié)構(gòu)性的改變(如格式，大小)將激發(fā)此方法* 主要調(diào)用渲染線程的setSurfaceSize來設(shè)置Surface的寬和高*/public void surfaceChanged(SurfaceHolder holder, int f, int w, int h) {mvThread.setSurfaceSize(w, h);}/*** Surface被銷毀之前將激發(fā)此方法，這里只設(shè)置標(biāo)記位，表示Surface“被銷毀了”*/public void surfaceDestroyed(SurfaceHolder holder) {bsurfaceIsCreate = false;}/*** Surface被第一次創(chuàng)建后將激發(fā)此方法，這里只設(shè)置標(biāo)記位，表示Surface“被創(chuàng)建了”*/public void surfaceCreated(SurfaceHolder holder) {bsurfaceIsCreate = true;}/*** setFps，getFps，set source都在MaiActivity使用* @param b*/public void setFps(boolean b) {bIsShowFps = b;}public boolean getFps(){return bIsShowFps;}public void setSource(MjpegInputStream source) {mIs = source;}/*** 開始播放線程* 設(shè)置標(biāo)記，表示“Surface被創(chuàng)建了”，然后調(diào)用渲染線程的的run方法啟動渲染*/public void startPlay() {if (mIs != null) {bRun = true;mvThread.start();}}/*** 停止播放線程* 1.先設(shè)置標(biāo)記，表示"停止播放"* 2.等待播放線程的退出* 3.關(guān)閉輸入流*/public void stopPlay() {bRun = false;boolean retry = true;while (retry) {try {mvThread.join();retry = false;} catch (InterruptedException e) {}}//線程停止后關(guān)閉Mjpeg流(很重要) mIs.closeInstance();}/*** mjpegview的獲取位圖方法，調(diào)用渲染線程的獲取位圖方法* @return*/public Bitmap getBitmap(){return mvThread.getBitmap();}/*** 設(shè)置顯示模式，在MainActivity的initview調(diào)用* @param s*/public void setDisplayMode(int s) {displayMode = s;}/*** 既然有設(shè)置顯示模式，就應(yīng)該也有獲得顯示模式，這是java在設(shè)置方法方面的風(fēng)格* @return*/public int getDisplayMode() {return displayMode;}/*** 此渲染線程類在主類上是重點(diǎn)，應(yīng)該重點(diǎn)掌握* @author Administrator**/public class MjpegViewThread extends Thread {private SurfaceHolder mSurfaceHolder = null;private int frameCounter = 0;private long start = 0;private Canvas c = null;private Bitmap overlayBitmap = null;private Bitmap mjpegBitmap = null;private PorterDuffXfermode mode = null;/*** 用一個變量來保存?zhèn)鬟M(jìn)來的surfaceHolder* 新建一個目的圖層和覆蓋圖層的相交模式，mjpegview為目的圖層，覆蓋圖層為右上角的動態(tài)"文本"* mode在calculateFps方法里使用* @param surfaceHolder:Surfaceview控制器* @param context : 上下文環(huán)境*/public MjpegViewThread(SurfaceHolder surfaceHolder, Context context) {mSurfaceHolder = surfaceHolder;mode = new PorterDuffXfermode(PorterDuff.Mode.DST_OVER);/*相交時動態(tài)文本覆蓋mjpegview*/}public Bitmap getBitmap(){return mjpegBitmap;}/*** 計(jì)算圖像尺寸* @param bmw bitmap寬* @param bmh bitmap高* @return 圖像矩陣*/private Rect destRect(int bmw, int bmh) {int tempx;int tempy;/*** 顯示模式只會在全屏和半屏模式之間切換，根本不會進(jìn)入STANDARD_MODE模式，故下面的if分支可以去掉*/if (displayMode == MjpegView.STANDARD_MODE) {tempx = (dispWidth / 2) - (bmw / 2);tempy = (dispHeight / 2) - (bmh / 2);return new Rect(tempx, tempy, bmw + tempx, bmh + tempy);}/*** 一開始，程序處于KEEP_SCALE_MODE模式，表示半屏顯示畫面*/if (displayMode == MjpegView.KEEP_SCALE_MODE) {float bmasp = (float) bmw / (float) bmh;bmw = dispWidth;bmh = (int) (dispWidth / bmasp);/*寬是手機(jī)屏幕的一半*/if (bmh > dispHeight) {bmh = dispHeight;bmw = (int) (dispHeight * bmasp);}tempx = (dispWidth / 2) - (bmw / 2);tempy = (dispHeight / 2) - (bmh / 2);/*** Rect(左邊，頂邊，右邊，下邊)，功能是繪制一個特定坐標(biāo)的矩形* 簡單說就是左上角坐標(biāo)為(0，0),右下角坐標(biāo)為(bmw，bmh)*/return new Rect(0, 0, bmw + 0, bmh + 0);}/*** 如果顯示模式為全屏，則全屏顯示畫面* dispWidth和dispHeight在下面的setSurfaceSize方法使用，它們表示mjpegview的寬和高*/if (displayMode == MjpegView.FULLSCREEN_MODE)return new Rect(0, 0, dispWidth, dispHeight);return null;}/*** 當(dāng)mjpegview發(fā)生任何結(jié)構(gòu)性的改變時，將激發(fā)此方法，前面也提到，渲染線程使用的各種變量需做同步處理* synchronized內(nèi)的就是同步代碼塊，為了防止線程之間對臨界資源的競爭* @param width* @param height*/public void setSurfaceSize(int width, int height) {synchronized (mSurfaceHolder) {dispWidth = width;dispHeight = height;}}/*** 此方法被calculateFps使用，calculateFps又被渲染線程的run方法使用* 功能是返回一個位圖* @param p:覆蓋"文本"用的畫筆* @param text:要繪制的字符 如:幀* @return bm*/private Bitmap makeFpsOverlay(Paint p, String text) {int nWidth, nHeight;Rect b = new Rect();//int a = b.left ;/*** 功能是獲得從原點(diǎn)開始，字符圍繞的最小的矩形* text：字符* 0：表示第一個字符* text.length:測量的最后一個字符* b:用于存放獲得的字符矩形* 獲得了text的邊界后就可以得到矩形的寬和高*/p.getTextBounds(text, 0, text.length(), b);nWidth = b.width() + 2;nHeight = b.height() + 2;/*** 每一個像素4字節(jié)，根據(jù)上面獲得的寬和高返回一個位圖*/Bitmap bm = Bitmap.createBitmap(nWidth, nHeight,Bitmap.Config.ARGB_8888);/*** Canvas :畫布，這是圖像處理的基本單元* 畫圖時，需要4個重要的元素：* 1.操作像素的位圖* 2.繪圖到位圖的畫布 * 3.矩形 * 4. 描述顏色和繪制風(fēng)格的畫筆 * Canvas(bm):構(gòu)造出一個要繪制到位圖的畫布*/Canvas c = new Canvas(bm);/*** Paint類介紹 * Paint即畫筆，在繪圖過程中起到了極其重要的作用，畫筆主要保存了顏色， * 樣式等繪制信息，指定了如何繪制文本和圖形，畫筆對象有很多設(shè)置方法， * 大體上可以分為兩類，一類與圖形繪制相關(guān)，一類與文本繪制相關(guān)。 * * 1.圖形繪制 * setColor(int color); * 設(shè)置繪制的顏色，使用顏色值來表示，該顏色值包括透明度和RGB顏色。 * setDither(boolean dither); * setXfermode(Xfermode xfermode); * 設(shè)置圖形重疊時的處理方式，如合并，取交集或并集，經(jīng)常用來制作橡皮的擦除效果 * * 2.文本繪制 * setFakeBoldText(boolean fakeBoldText); * 模擬實(shí)現(xiàn)粗體文字，設(shè)置在小字體上效果會非常差 * setSubpixelText(boolean subpixelText); * 設(shè)置該項(xiàng)為true，將有助于文本在LCD屏幕上的顯示效果 * * setTextAlign(Paint.Align align); * 設(shè)置繪制文字的對齊方向 * setTextSize(float textSize); * 設(shè)置繪制文字的字號大小 * setTypeface(Typeface typeface); * 設(shè)置Typeface對象，即字體風(fēng)格，包括粗體，斜體以及襯線體，非襯線體等 */ p.setColor(overlayBackgroundColor);// 背景顏色c.drawRect(0, 0, nWidth, nHeight, p);/*繪制矩形*/p.setColor(overlayTextColor);// 文字顏色/*** 畫布的繪制文字方法* test:要繪制的字符* -b.left:字符起始位置的x坐標(biāo)，這里是矩形的左邊* (nHeight / 2) - ((p.ascent() + p.descent()) / 2) + 1:字符起始位置的y坐標(biāo)* p:用到的畫筆* 關(guān)于涉及的矩形屬性可看博客 http://mikewang.blog.51cto.com/3826268/871765*/c.drawText(text, -b.left + 1,(nHeight / 2) - ((p.ascent() + p.descent()) / 2) + 1, p);return bm;}/*** 重頭戲* 如果線程是運(yùn)行的，SurfaceView也創(chuàng)建了的* 則鎖定畫布com/mjpeg/io/MjpegInputStream.java中的readMjpegFrame方法獲得mjpeg視頻流的內(nèi)容* mjpeg視頻的內(nèi)容就是類位圖，然后根據(jù)類位圖繪制矩形，再繪制相應(yīng)的位圖，這個位圖才是我們需要的* 如果設(shè)置了幀率文本，就在mjpegview上覆蓋，最后解鎖畫布*/public void run() {start = System.currentTimeMillis();Rect destRect;Paint p = new Paint();// String fps = "";while (bRun) {if (bsurfaceIsCreate) {c = mSurfaceHolder.lockCanvas();try {mjpegBitmap = mIs.readMjpegFrame();/*調(diào)用Inputstrean的方法*//*同步圖像的寬高設(shè)置*/synchronized (mSurfaceHolder) {destRect = destRect(mjpegBitmap.getWidth(),mjpegBitmap.getHeight());}/*** 當(dāng)主activity點(diǎn)擊相冊和設(shè)置跳轉(zhuǎn)時，Surfaceview被銷毀，此時c將為空*/if(c != null){c.drawPaint(new Paint());c.drawBitmap(mjpegBitmap, null, destRect, p);if (bIsShowFps)calculateFps(destRect, c, p);mSurfaceHolder.unlockCanvasAndPost(c);}} catch (IOException e) {}}else {try {Thread.sleep(500);//線程休眠，讓出調(diào)度} catch (InterruptedException e) {e.printStackTrace();}}}}/*** 使用前面的方法，繪制出“顯示幀率”文本，效果為"i幀"，i自增* @param destRect* @param c* @param p*/public void calculateFps(Rect destRect, Canvas c, Paint p) {int width;int height;String fps;p.setXfermode(mode);/* 設(shè)置兩個畫面相交時的模式*/if (overlayBitmap != null) {/*** 計(jì)算好文本的寬和高* 然后調(diào)用畫布的繪制位圖方法繪圖*/height = ((ovlPos & 1) == 1) ? destRect.top: destRect.bottom - overlayBitmap.getHeight();width = ((ovlPos & 8) == 8) ? destRect.left : destRect.right - overlayBitmap.getWidth();c.drawBitmap(overlayBitmap, width, height, null);}p.setXfermode(null);frameCounter++;/*** currentTimeMillis表示系統(tǒng)從January 1, 1970 00:00:00.0 UTC開始的毫秒數(shù)* start在前面已經(jīng)設(shè)置好，表示渲染線程開始的系統(tǒng)時間*/if ((System.currentTimeMillis() - start) >= 1000) {fps = frameCounter+ "fps";start = System.currentTimeMillis();overlayBitmap = makeFpsOverlay(overlayPaint, fps);/*真正的繪制這個"文本"*/frameCounter = 0; }}}}

?

MjpegInputStream.java

package com.mjpeg.io;import java.io.BufferedInputStream; import java.io.ByteArrayInputStream; import java.io.DataInputStream; import java.io.IOException; import java.io.InputStream; import java.io.Serializable; import java.util.Properties;import org.apache.http.HttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.impl.client.DefaultHttpClient; import org.apache.http.params.CoreConnectionPNames;import android.graphics.Bitmap; import android.graphics.BitmapFactory; import android.os.Parcelable; import android.util.Log; /*** 該類繼承了DataInputStream實(shí)現(xiàn)了Serializable接口* 1. 實(shí)例化流,獲取初始化流和關(guān)閉實(shí)例流的方法* 2. 一個構(gòu)造函數(shù)* 3. 一個根據(jù)幀數(shù)據(jù)大小獲得位圖方法*/ public class MjpegInputStream extends DataInputStream implements Serializable{/*** */private static final long serialVersionUID = 1L;/*** 用UE打開發(fā)現(xiàn) 每一個jpg格式的圖片 開始兩字節(jié)都是 0xFF,0xD8*/private final byte[] SOI_MARKER = { (byte) 0xFF, (byte) 0xD8 }; // private final byte[] EOF_MARKER = { (byte) 0xFF, (byte) 0xD9 };/*** 表示服務(wù)器發(fā)給客戶端的一幀數(shù)據(jù)的長度*/private final String CONTENT_LENGTH = "Content-Length";private final static int HEADER_MAX_LENGTH = 100;private final static int FRAME_MAX_LENGTH = 40000 + HEADER_MAX_LENGTH;private int mContentLength = -1;private static MjpegInputStream mis = null;/*** 調(diào)用該類的構(gòu)造方法 創(chuàng)建MjpegInputStream流* @param is*/public static void initInstance(InputStream is){if(mis == null)mis = new MjpegInputStream(is);}/*** 獲得創(chuàng)建的mjpegInputsteam流* @return*/public static MjpegInputStream getInstance(){if(mis != null)return mis;return null;}/*** 因?yàn)閙pjeginputstream繼承了datainputstream* 所以可以調(diào)用mpjeginputstream的關(guān)閉流方法*/public static void closeInstance(){try {mis.close();} catch (IOException e) {e.printStackTrace();}mis = null;}private MjpegInputStream(InputStream in) {super(new BufferedInputStream(in, FRAME_MAX_LENGTH));}/*** 在數(shù)據(jù)流里面找SOI_MARKER={(byte)0xFF,(byte) 0xD8}* 所有對IO流的操作都會拋出異常* @param in* @param sequence* @return* @throws IOException*/private int getEndOfSeqeunce(DataInputStream in, byte[] sequence)throws IOException {int seqIndex = 0;byte c;for (int i = 0; i < FRAME_MAX_LENGTH; i++) {// 0 1 2 3c = (byte) in.readUnsignedByte();if (c == sequence[seqIndex]) {seqIndex++;if (seqIndex == sequence.length)//2return i + 1;//3} elseseqIndex = 0;}return -1;}/*** 此方法功能是找到索引0xFF,0XD8在字符流的位置* 整個數(shù)據(jù)流形式：http頭信息 幀頭(0xFF 0xD8) 幀數(shù)據(jù) 幀尾(0xFF 0xD9)* 1、首先通過0xFF 0xD8找到幀頭位置* 2、幀頭位置前的數(shù)據(jù)就是http頭，里面包含Content-Length，這個字段指示了整個幀數(shù)據(jù)的長度* 3、幀頭位置后面的數(shù)據(jù)就是幀圖像的開始位置* @param in* @param sequence* @return* @throws IOException*/private int getStartOfSequence(DataInputStream in, byte[] sequence)throws IOException {int end = getEndOfSeqeunce(in, sequence);return (end < 0) ? (-1) : (end - sequence.length);}/*** 從http的頭信息中獲取Content-Length，知道一幀數(shù)據(jù)的長度* @param headerBytes* @return* @throws IOException* @throws NumberFormatException*/private int parseContentLength(byte[] headerBytes) throws IOException,NumberFormatException {/*** 根據(jù)字節(jié)流創(chuàng)建ByteArrayInputStream流* Properties是java.util包里的一個類，它有帶參數(shù)和不帶參數(shù)的構(gòu)造方法，表示創(chuàng)建無默認(rèn)值和有默認(rèn)值的屬性列表* 根據(jù)流中的http頭信息生成屬性文件，然后找到屬性文件CONTENT_LENGTH的value，這就找到了要獲得的幀數(shù)據(jù)大小* 創(chuàng)建一個 ByteArrayInputStream，使用 headerBytes作為其緩沖區(qū)數(shù)組*/ByteArrayInputStream headerIn = new ByteArrayInputStream(headerBytes);Properties props = new Properties();/*創(chuàng)建一個無默認(rèn)值的空屬性列表*/props.load(headerIn);/*從輸入流中生成屬性列表（鍵和元素對）。*/return Integer.parseInt(props.getProperty(CONTENT_LENGTH));/*用指定的鍵在此屬性列表中搜索屬性。*/}/*** * @return* @throws IOException*/public Bitmap readMjpegFrame() throws IOException {mark(FRAME_MAX_LENGTH);/*流中當(dāng)前的標(biāo)記位置*/int headerLen = getStartOfSequence(this, SOI_MARKER);reset();/*將緩沖區(qū)的位置重置為標(biāo)記位置*/byte[] header = new byte[headerLen];readFully(header);/*會一直阻塞等待，直到數(shù)據(jù)全部到達(dá)(數(shù)據(jù)緩沖區(qū)裝滿)*/ // String s = new String(header);try {mContentLength = parseContentLength(header);// ?} catch (NumberFormatException e) {return null;}/*** 根據(jù)幀數(shù)據(jù)的大小創(chuàng)建字節(jié)數(shù)組*/byte[] frameData = new byte[mContentLength];readFully(frameData);/*** 根據(jù)不同的源(file，stream，byte-arrays)創(chuàng)建位圖* 把輸入字節(jié)流流轉(zhuǎn)為位圖*/return BitmapFactory.decodeStream(new ByteArrayInputStream(frameData));} }

?

WsnActivty.java

package my.work.Library;import java.util.Timer; import java.util.TimerTask; import java.util.regex.Matcher; import java.util.regex.Pattern;import android.app.Activity; import android.app.AlertDialog; import android.content.Context; import android.content.DialogInterface; import android.content.Intent; import android.os.Bundle; import android.os.Handler; import android.os.Message; import android.view.Menu; import android.view.View; import android.view.View.OnClickListener; import android.widget.Button; import android.widget.EditText; import android.widget.ImageButton; import android.widget.ImageView; import android.widget.TextView;public class WsnActivty extends Activity {/** Called when the activity is first created. */private Button btnNetwork,btnVideo;private String strIpAddr = null;static TextView textTips,seat;private ClientThread clientThread = null;private Message MainMsg;public static Handler mainHandler;static final int TIPS_UPDATE_UI = 3; //tips_update_uistatic final int SEAT_UPDATE_UI = 6; //seat_update_uistatic final int MAX_NODE = 4;static byte NodeData[][] = new byte[MAX_NODE][5];; // [5] 0=溫度 1=濕度 2=氣體 3=燈static final int RX_DATA_UPDATE_UI = 1;@Overridepublic void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.main);initControl();initMainHandler();}private void initControl() {// TODO Auto-generated method stubbtnNetwork = (Button) findViewById(R.id.btn_network);btnNetwork.setOnClickListener(new ButtonClick());textTips = (TextView) findViewById(R.id.Tips);textTips.setText(R.string.init_tips);seat = (TextView) findViewById(R.id.statc001);seat.setText(R.string.people1);btnVideo = (Button) findViewById(R.id.btn_video);btnVideo.setOnClickListener(new ButtonClick());}class ButtonClick implements OnClickListener {@Overridepublic void onClick(View v) {switch (v.getId()) {case R.id.btn_network: // 連接網(wǎng)絡(luò)showDialog(WsnActivty.this);break;case R.id.btn_video: // 暫時用作停止自動刷新功能 ,跳轉(zhuǎn)到FlashActivity去// mainTimer.cancel(); //看視頻關(guān)閉定時查詢數(shù)據(jù) 要判斷if (clientThread != null) {MainMsg = ClientThread.childHandler.obtainMessage(ClientThread.RX_EXIT); //關(guān)閉線程 ClientThread.childHandler.sendMessage(MainMsg);}/*new一個Intent對象，并指定class*/ Intent intent = new Intent(); intent.setClass(WsnActivty.this,FlashActivity.class); /*new一個Bundle對象，并將要傳遞的數(shù)據(jù)傳入*/ Bundle bundle = new Bundle(); bundle.putString("IP",strIpAddr); /*將Bundle對象assign給Intent*/ intent.putExtras(bundle); /*調(diào)用Activity FlashActivity*/ startActivity(intent); //startActivity(new Intent(WsnActivity.this, FlashActivity.class));//簡單跳轉(zhuǎn)break;}}}// 顯示連接對話框private void showDialog(Context context) {final EditText editIP = new EditText(context);editIP.setText("192.168.0.10");AlertDialog.Builder builder = new AlertDialog.Builder(context);// builder.setIcon(R.drawable.ic_launcher);builder.setTitle("請輸入服務(wù)器IP地址");builder.setView(editIP);builder.setPositiveButton("連接", new DialogInterface.OnClickListener() {public void onClick(DialogInterface dialog, int whichButton) {strIpAddr = editIP.getText().toString();boolean ret = isIPAddress(strIpAddr);if (ret) {textTips.setText("服務(wù)器IP地址:" + strIpAddr);} else {strIpAddr = null;textTips.setText("IP地址不合法，請重新設(shè)置");return;}clientThread = new ClientThread(strIpAddr);// 建立客戶端線程 clientThread.start();//mainTimer = new Timer();// 定時查詢所有終端信息//setTimerTask(); }});builder.setNeutralButton("取消", new DialogInterface.OnClickListener() {public void onClick(DialogInterface dialog, int whichButton) {if (clientThread != null) {MainMsg = ClientThread.childHandler.obtainMessage(ClientThread.RX_EXIT);ClientThread.childHandler.sendMessage(MainMsg);textTips.setText("與服務(wù)器斷開連接");}}});builder.show();}// 判斷輸入IP是否合法private boolean isIPAddress(String ipaddr) {boolean flag = false;Pattern pattern = Pattern.compile("\\b((?!\\d\\d\\d)\\d+|1\\d\\d|2[0-4]\\d|25[0-5])\\.((?!\\d\\d\\d)\\d+|1\\d\\d|2[0-4]\\d|25[0-5])\\.((?!\\d\\d\\d)\\d+|1\\d\\d|2[0-4]\\d|25[0-5])\\.((?!\\d\\d\\d)\\d+|1\\d\\d|2[0-4]\\d|25[0-5])\\b");Matcher m = pattern.matcher(ipaddr);flag = m.matches();return flag;}void initMainHandler() {mainHandler = new Handler() {// 主線程消息處理中心public void handleMessage(Message msg) {switch (msg.what) {case TIPS_UPDATE_UI:String str = (String) msg.obj; //連接成功 textTips.setText(str);break;case SEAT_UPDATE_UI:String strseat = (String) msg.obj; //rfid seat.setText(strseat);break;}super.handleMessage(msg);}};}}

?

ClientThread.java

package my.work.Library;import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.InetSocketAddress; import java.net.Socket; import java.net.SocketAddress;import android.content.Context; import android.os.Handler; import android.os.Looper; import android.os.Message; import android.widget.Toast;public class ClientThread extends Thread {private OutputStream outputStream = null;private InputStream inputStream = null;private Socket socket;private SocketAddress socketAddress;public static Handler childHandler;private boolean RxFlag = true;final int TEXT_INFO = 12;static final int RX_EXIT = 11;static final int TX_DATA = 10;Context mainContext;Message msg;private String strIP;final int SERVER_PORT = 33333;byte cNodeData[][] = new byte[4][5]; // [5] 0=溫度 1=濕度 2=氣體 3=燈int RxCount = 0, nRecvLen, index = 0;byte CheckSum;// byte strRxBuf[] = new byte[256];int ucRecvLen = 7;private RxThread rxThread;//獲取WsnActivty.java 開辟子線程clientThread對象線程傳遞過來的ip地址public ClientThread(String ip) {strIP = ip;}// 連接網(wǎng)絡(luò)void connect() {RxFlag = true;socketAddress = new InetSocketAddress(strIP, SERVER_PORT);socket = new Socket();try {socket.connect(socketAddress, SERVER_PORT);inputStream = socket.getInputStream();outputStream = socket.getOutputStream();msg = WsnActivty.mainHandler.obtainMessage(WsnActivty.TIPS_UPDATE_UI, "連接成功");WsnActivty.mainHandler.sendMessage(msg);rxThread = new RxThread();rxThread.start();} catch (IOException e) {try {sleep(10);} catch (InterruptedException e1) {e1.printStackTrace();}msg = WsnActivty.mainHandler.obtainMessage(WsnActivty.TIPS_UPDATE_UI, "無法連接到服務(wù)器");WsnActivty.mainHandler.sendMessage(msg);e.printStackTrace();} catch (NumberFormatException e) {}}void initChildHandler() {Looper.prepare(); // 在子線程中創(chuàng)建Handler必須初始化Looper childHandler = new Handler() {// 子線程消息處理中心public void handleMessage(Message msg) {// 接收主線程及其他線程的消息并處理.../*** MainMsg = ClientThread.childHandler.obtainMessage(ClientThread.TX_DATA,* len, 0, (Object) buffer);* SendData(SendBuf, 7);*/switch (msg.what) {case RX_EXIT:RxFlag = false;try {if (socket.isConnected()) {inputStream.close();outputStream.close();socket.close();}} catch (IOException e1) {e1.printStackTrace();}childHandler.getLooper().quit();// 結(jié)束消息隊(duì)列break;default:break;}}};// 啟動該線程的消息隊(duì)列 Looper.loop();}public void run() {connect();initChildHandler();msg = WsnActivty.mainHandler.obtainMessage(WsnActivty.TIPS_UPDATE_UI,"與服務(wù)器斷開連接");WsnActivty.mainHandler.sendMessage(msg);}// socket 接收線程public class RxThread extends Thread {public void run() {try {while (socket.isConnected() && RxFlag) {byte strRxBuf[] = new byte[30];byte i;int RxIndex, len, readBytes = 0; while (readBytes < ucRecvLen) { //接收到數(shù)據(jù),存放到strRxBuflen = inputStream.read(strRxBuf,readBytes, 8);readBytes += len;if (len == -1)break;}String strRead =new String(strRxBuf);String str=new String("822350C2");String str1="822350C2";if(str.equals(str1)){msg = WsnActivty.mainHandler.obtainMessage(WsnActivty.SEAT_UPDATE_UI, "有人");WsnActivty.mainHandler.sendMessage(msg);}msg = WsnActivty.mainHandler.obtainMessage(WsnActivty.SEAT_UPDATE_UI, strRead);WsnActivty.mainHandler.sendMessage(msg);}if (socket.isConnected())socket.close();} catch (IOException e) {e.printStackTrace();}}}byte GetDataLen(byte fc) {byte len = 0;switch (fc) {case 0x01:len = 22;break;case 0x07:case 0x08:case 0x0A:case 0x0B:case 0x0C:case 0x0D:len = 7;break;}return len;}}

?

FlashActivity.java

package my.work.Library;import java.io.IOException; import java.io.InputStream; import java.util.ArrayList;import my.work.Library.WsnActivty.ButtonClick;import org.apache.http.HttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.impl.client.DefaultHttpClient; import org.apache.http.params.CoreConnectionPNames;import tools.Generic; import android.app.Activity; import android.content.Context; import android.content.Intent; import android.content.SharedPreferences; import android.content.SharedPreferences.Editor; import android.net.DhcpInfo; import android.net.wifi.WifiManager; import android.os.AsyncTask; import android.os.Bundle; import android.view.View; import android.view.View.OnClickListener; import android.widget.ArrayAdapter; import android.widget.AutoCompleteTextView; import android.widget.Button; import android.widget.EditText; import android.widget.TextView; import android.widget.Toast;import com.mjpeg.io.MjpegInputStream;/*** 應(yīng)用程序執(zhí)行時，該類首先被調(diào)用*/ public class FlashActivity extends Activity {private Context mContext = this;private EditText ipEdt = null;private EditText portEdt = null;private TextView hintTv = null;private DhcpInfo dpInfo = null;private WifiManager wifi = null;private InputStream is = null;private SharedPreferences sp = null;private Editor editor = null;private String port = "8080";/* 用來保存獲得用戶輸入的端口 */private Bundle bundle;private Button connectin;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.flash);/* 設(shè)置布局為res/layout/flash.xml*/init();int state = wifi.getWifiState();/* 獲得wifi當(dāng)前狀態(tài) */if (state != WifiManager.WIFI_STATE_ENABLED) {/*** 為了程序的擴(kuò)展性和可讀性，單獨(dú)在tools目錄定義一個Generic類，它有很多方法* 1.有showMsg方法，用于控制顯示時間來顯示一個Toast* 2.有g(shù)etSysNowTime方法，用于獲取當(dāng)前的系統(tǒng)時間* 3.有g(shù)etSdCardFile方法，用于獲取SD卡的絕對路徑，成功返回File值，失敗返回NULL* 4.有g(shù)etConnectedIP方法，用于獲取連接到wifi熱點(diǎn)的所有的手機(jī)ip，成功返回ArrayList<String>型的容器* 5.有g(shù)etShrinkedPic方法，用于獲取照片的縮略圖* 6.定義了一個DescendSortByIndex類：實(shí)現(xiàn)了整型比較器* 7.定義個DescendSortByTime類：實(shí)現(xiàn)了File比較器*/Generic.showMsg(this, "請打開wifi", false);finish();} else/* 取得Intent中的Bundle對象 */ bundle = this.getIntent().getExtras(); /* 取得Bundle對象中的數(shù)據(jù) */ String strIP = bundle.getString("IP"); //autoConnect(strIP); }@Override/*** 調(diào)用finish方法時，這方法將被激發(fā)* 設(shè)置輸入流為空，調(diào)用父類的onDestroy銷毀資源*/protected void onDestroy() {is = null;super.onDestroy();}private void init() {/*** 獲取在本Activity要使用的控件和WiFi*/hintTv = (TextView) findViewById(R.id.hintTv);ipEdt = (EditText) findViewById(R.id.ip);portEdt = (EditText) findViewById(R.id.port);connectin = (Button) findViewById(R.id.connect);connectin.setOnClickListener(new ButtonClick());/*** 因?yàn)橐玫絎IFI和Internet所以在AndroidMenufest.xml 中添加如下權(quán)限 <uses-permission* android:name="android.permission.INTERNET"/> <uses-permission* android:name="android.permission.ACCESS_WIFI_STATE"/>* <uses-permission* android:name="android.permission.CHANGE_WIFI_STATE"/>*/wifi = (WifiManager) getSystemService(Context.WIFI_SERVICE);//initSp();/* 主要是方便查找以前登錄成功了的IP */ }class ButtonClick implements OnClickListener {@Overridepublic void onClick(View v) {String ip = ipEdt.getText().toString();/* 獲得輸入的IP */port = portEdt.getText().toString();/* 獲得輸入的端口 */// port不能為空,ip地址格式正確if (!port.equals("") && checkAddr(ip, Integer.valueOf(port))) {new ConnectTask().execute(ip);} else {Generic.showMsg(mContext, "請檢查ip或port", true);}}} // /** // * 生成配置文件config，它在 /data/data/<package name>/shared_prefs/config.xml // * 取出配置文件的ip用冒號隔開，并為自動完成列表設(shè)置適配器 // */ // private void initSp() { // sp = getSharedPreferences("config", MODE_PRIVATE); // /* 創(chuàng)建好配置文件后，以后就可以用它的edit來操作配置文件了 */ // editor = sp.edit(); // String names[] = sp.getString("ip", "").split(":"); // ArrayAdapter<String> adapter = new ArrayAdapter<String>(mContext, // android.R.layout.simple_dropdown_item_1line, names); // //ipEdt.setAdapter(adapter); // } // // /** // * 自動連接 先將獲取到的wifi熱點(diǎn)服務(wù)器地址和連接到wifi熱點(diǎn)的設(shè)備的ip放入容器，啟動連接線程掃描容器中的ip // * // * @return // */ // private void autoConnect(String strIP) { // ArrayList<String> addr = new ArrayList<String>();/* 創(chuàng)建容器 用于存放ip */ // // dpInfo = wifi.getDhcpInfo(); // addr.add(int32ToIp(dpInfo.serverAddress));/* 把服務(wù)IP放入容器的尾部 */ // addr.addAll(Generic.getConnectedIP());// Adds the objects in the specified collection to this ArrayList // // // 為了在執(zhí)行連接時 不會卡住UI，故采用異步任務(wù)方式，若讀者想減縮程序，也可不使用異步任務(wù) // if (strIP != null) { // new ConnectTask().execute(strIP); // } else { // //因?yàn)檫B接線程的執(zhí)行方法必須String類型,所以要toArray // new ConnectTask().execute(addr.toArray(new String[addr.size()])); // } // }/*** 按照一定的格式返回輸入的Ip* * @param ip* @return*/private String int32ToIp(int ip) {return (ip & 0xff) + "." + (ip >> 8 & 0xff) + "." + (ip >> 16 & 0xff)+ "." + (ip >> 24 & 0xff);}// /** // * 手動連接 為控件綁定監(jiān)聽器有2種方法 1.給出布局文件并設(shè)置，findViewById()找到控件，調(diào)用API為其綁定相應(yīng)監(jiān)聽器 // * 2.給出布局文件并設(shè)置，在布局文件里設(shè)置相應(yīng)控件的OnClick，然后在源文件里具體實(shí)現(xiàn)相應(yīng)控件的OnClick//本類用的就是這方法 // * 在layout目錄下的flash.xml里聲明了connectBtn的Button控件 點(diǎn)擊"連接"按鈕將調(diào)用此方法 // * // * @param v // */ // public void connectBtn() { // String ip = ipEdt.getText().toString();/* 獲得輸入的IP */ // port = portEdt.getText().toString();/* 獲得輸入的端口 */ // // // port不能為空,ip地址格式正確 // if (!port.equals("") && checkAddr(ip, Integer.valueOf(port))) { // new ConnectTask().execute(ip); // } else { // Generic.showMsg(mContext, "連接失敗", true); // } // }/*** 分割的ip是4段，ip端口范圍在1000-65535* * @param ip* @param port* @return*/private boolean checkAddr(String ip, int port) {if (ip.split("\\.").length != 4)return false;if (port < 1000 || port > 65535)return false;return true;}/*** 連接線程 此類的作用是在后臺線程里執(zhí)行http連接，連接卡住不會影響UI運(yùn)行，適合于運(yùn)行時間較長但又不能影響前臺線程的情況* 異步任務(wù)，有3參數(shù)和4步* :onPreExecute()，doInBackground()，onProgressUpdate()，onPostExecute()* onPreExecute()：運(yùn)行于UI線程，一般為后臺線程做準(zhǔn)備，如在用戶接口顯示進(jìn)度條* doInBackground():當(dāng)onPreExecute執(zhí)行后，馬上被觸發(fā)，執(zhí)行花費(fèi)較長時間的后臺運(yùn)算，將返回值傳給onPostExecute* onProgressUpdate():當(dāng)用戶調(diào)用 publishProgress()將被激發(fā)，執(zhí)行的時間未定義，這個方法可以用任意形式顯示進(jìn)度* 一般用于激活一個進(jìn)度條或者在UI文本領(lǐng)域顯示logo onPostExecute():當(dāng)后臺進(jìn)程執(zhí)行后在UI線程被激發(fā)，把后臺執(zhí)行的結(jié)果通知給UI* 參數(shù)一:運(yùn)行于后臺的doInBackground的參數(shù)類型* 參數(shù)二:doInBackground計(jì)算的通知給UI線程的單元類型，即運(yùn)行于UI線程onProgressUpdate的參數(shù)類型，這里沒用到* 參數(shù)三:doInBackground的返回值，將傳給onPostExecute作參數(shù)* * @author Administrator* */private class ConnectTask extends AsyncTask<String, Integer, String> {@Overrideprotected String doInBackground(String... params) {for (int i = 0; i < params.length; i++) {String ip = params[i];/* 取出每一個ip */if (ip.split("\\.").length == 4) {/*** 在瀏覽器觀察畫面時,也是輸入下面的字符串網(wǎng)址*/String action = "http://" + ip + ":" + port+ "/?action=stream";is = http(action);if (is != null) { /* 第一次必須輸入IP，下次登錄時才可找到之前登錄成功后的IP *///writeSp(ip);MjpegInputStream.initInstance(is); //消息實(shí)體內(nèi)容isbreak;}}}return null;}@Overrideprotected void onPostExecute(String result) {if (is != null) {/*** Intent是Android特有的東西，可以在Intent指定程序要執(zhí)行的動作(比如:view,edit,dial)* 都準(zhǔn)備好程序執(zhí)行該工作所需要的材料后* ，只要調(diào)用startActivity，Android系統(tǒng)會自動尋找最符合你指定要求的應(yīng)用程序 并執(zhí)行該程序*/startActivity(new Intent(FlashActivity.this, LinearLayout_activity.class));finish();/* 結(jié)束本Activity */} else {hintTv.setText(getResources().getString(R.string.connect_failed));Generic.showMsg(mContext, "連接失敗", true);}super.onPostExecute(result);}/*** 功能：http連接 Android提供兩種http客戶端， HttpURLConnection 和 Apache HTTP* Client，它們都支持HTTPS，能上傳和下載文件 配置超時時間，用于IPV6和 connection pooling， Apache* HTTP client在Android2.2或之前版本有較少BUG* 但在Android2.2或之后，HttpURLConnection是更好的選擇，在這里我們用的是 Apache HTTP Client* 凡是對IO的操作都會涉及異常，所以要try和catch* * @param url* @return InputStream*/private InputStream http(String url) {HttpResponse res;DefaultHttpClient httpclient = new DefaultHttpClient();/** 創(chuàng)建http客戶端，* 才能調(diào)用它的各種方法*/httpclient.getParams().setParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, 500);/* 設(shè)置超時時間 */try {HttpGet hg = new HttpGet(url);/** 這是GET方法的http API，* GET方法是默認(rèn)的HTTP請求方法*/res = httpclient.execute(hg);return res.getEntity().getContent(); // 從響應(yīng)中獲取消息實(shí)體內(nèi)容} catch (IOException e) {}return null;}} }// /** // * 更新SharedPreferences 1.先判斷ip是否有"ip"值，沒有就將傳進(jìn)來的data賦值給ip 2.ip有值就取出，然后用冒號分隔開 // * 3.sp數(shù)組只能存放10組ip，如果超過了10組，先清零配置文件再更新 4.遍歷數(shù)組，如果已有當(dāng)前登錄成功的ip，則返回 // * 5.數(shù)組里不包含登錄成功的ip，則將當(dāng)前登錄成功的ip添加至sp數(shù)組并提交 // * // * @param ip // */ // private void writeSp(String data) { // if (!sp.contains("ip")) { // editor.putString("ip", data); // editor.commit(); // return; // } // // /** // * 配置文件里有ip，表示之前登錄成功了 // */ // String ip = sp.getString("ip", ""); // String[] ips = ip.split(":"); // // if (ips.length >= 10) { // editor.clear(); // editor.commit(); // editor.putString("ip", data); // editor.commit(); // return; // } // // for (int i = 0; i < ips.length; i++) { // if (ips[i].equals(data)) // return; // } // editor.putString("ip", data + ":" + ip);/* 放在以前成功了的ip的前面 */ // editor.commit(); // } // // /** // * 自動完成框的下拉選項(xiàng) 當(dāng)點(diǎn)擊"history_user"ImageView控件時將調(diào)用該方法 這里只是具體實(shí)現(xiàn)xml文件的Onclick // */ // public void showDropDown(View v) { // ipEdt.showDropDown(); // }

?

LinearLayout_activity.java

package my.work.Library;import com.mjpeg.io.MjpegInputStream; import com.mjpeg.view.MjpegView;import android.app.Activity; import android.os.Bundle;import my.work.Library.R;public class LinearLayout_activity extends Activity {public static LinearLayout_activity instance = null;private MjpegInputStream mis = null;private MjpegView mjpegView = null;protected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.mainactivty);/*構(gòu)造RadioGroup的5的RadioButton*/instance = this;mis = MjpegInputStream.getInstance();mjpegView = (MjpegView) findViewById(R.id.mjpegview);initMjpegView();} private void initMjpegView() {if (mis != null) {mjpegView.setSource(mis);// 設(shè)置數(shù)據(jù)來源mjpegView.setDisplayMode(mjpegView.getDisplayMode());/*設(shè)置mjpegview的顯示模式*//*** setFps和getFps方法是為了在屏幕的右上角動態(tài)顯示當(dāng)前的幀率* 如果我們只需觀看畫面，下面這句完全可以省去*/mjpegView.setFps(mjpegView.getFps());/*** 調(diào)用mjpegView中的線程的run方法，開始顯示畫面*/mjpegView.setDisplayMode(MjpegView.FULLSCREEN_MODE);/*全屏*/mjpegView.startPlay();}}}

?

轉(zhuǎn)載于:https://www.cnblogs.com/yihujiu/p/5997859.html

總結(jié)

以上是生活随笔為你收集整理的网络摄像头Androi端显示(mjpeg)源码分析的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。