xuxiuxi

2017-08-11 5f12988a77d078a5e5155c9a301e45bfd288d7e5

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
package cn.com.basic.face.util; 
 
import java.io.BufferedInputStream; 
import java.io.ByteArrayInputStream; 
import java.io.DataInputStream; 
import java.io.IOException; 
import java.io.InputStream; 
import java.net.URI; 
import java.util.Properties; 
 
import org.apache.http.HttpResponse; 
import org.apache.http.client.ClientProtocolException; 
import org.apache.http.client.methods.HttpGet; 
import org.apache.http.impl.client.DefaultHttpClient; 
 
import android.graphics.Bitmap; 
import android.graphics.BitmapFactory; 
 
public class MjpegInputStream extends DataInputStream { 
    private final byte[] SOI_MARKER = { (byte) 0xFF, (byte) 0xD8 }; 
    private final byte[] EOF_MARKER = { (byte) 0xFF, (byte) 0xD9 }; 
    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; 
 
    public static MjpegInputStream read(String url) { 
        HttpResponse res; 
        DefaultHttpClient httpclient = new DefaultHttpClient();      
        try { 
            res = httpclient.execute(new HttpGet(URI.create(url))); 
            return new MjpegInputStream(res.getEntity().getContent());               
        } catch (ClientProtocolException e) { 
        } catch (IOException e) {} 
        return null; 
    } 
 
    public MjpegInputStream(InputStream in) { super(new BufferedInputStream(in, FRAME_MAX_LENGTH)); } 
 
    private int getEndOfSeqeunce(DataInputStream in, byte[] sequence) throws IOException { 
        int seqIndex = 0; 
        byte c; 
        for(int i=0; i < FRAME_MAX_LENGTH; i++) { 
            c = (byte) in.readUnsignedByte(); 
            if(c == sequence[seqIndex]) { 
                seqIndex++; 
                if(seqIndex == sequence.length) return i + 1; 
            } else seqIndex = 0; 
        } 
        return -1; 
    } 
 
    private int getStartOfSequence(DataInputStream in, byte[] sequence) throws IOException { 
        int end = getEndOfSeqeunce(in, sequence); 
        return (end < 0) ? (-1) : (end - sequence.length); 
    } 
 
    private int parseContentLength(byte[] headerBytes) throws IOException, NumberFormatException { 
        ByteArrayInputStream headerIn = new ByteArrayInputStream(headerBytes); 
        Properties props = new Properties(); 
        props.load(headerIn); 
        return Integer.parseInt(props.getProperty(CONTENT_LENGTH)); 
    }    
 
    public Bitmap readMjpegFrame() throws IOException { 
        mark(FRAME_MAX_LENGTH); 
        int headerLen = getStartOfSequence(this, SOI_MARKER); 
        reset(); 
        byte[] header = new byte[headerLen]; 
        readFully(header); 
        try { 
            mContentLength = parseContentLength(header); 
        } catch (NumberFormatException nfe) {  
            mContentLength = getEndOfSeqeunce(this, EOF_MARKER);  
        } 
        reset(); 
        byte[] frameData = new byte[mContentLength]; 
        skipBytes(headerLen); 
        readFully(frameData); 
        return BitmapFactory.decodeStream(new ByteArrayInputStream(frameData)); 
    } 
}