在对象中缩放 mjpeg
使用gocv我正在将图像流式传输到object我的 html5 页面上的元素。
该页面是：
<!DOCTYPE html>
<html>
<head>
<title>Cam Streaming with gocv</title>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<link href="css/style.css" rel="stylesheet">
</head>
<body>
<!-- <div id ="content"></div> -->
<object data="http://localhost:8080/camera" width="300" height="200" alt="Cam streaming"></object>
</body>
<<script>
/* (function(){
document.getElementById("content").innerHTML='<object type="text/html" data="http://localhost:8080/cam" ></object>';
})();
*/
</script>
</html>
慕桂英546537浏览 98回答 1
1回答
-
泛舟湖上清波郎朗
我在代码中找到了答案go，即使用以下方法调整图像大小："image/jpeg""golang.org/x/image/draw"作为： // Decode the image (from PNG to image.Image): src, _ := j.Decode(bytes.NewReader(jpeg)) // Set the expected size that you want: dst := image.NewRGBA(image.Rect(0, 0, src.Bounds().Max.X/3, src.Bounds().Max.Y/3)) // Resize: draw.NearestNeighbor.Scale(dst, dst.Rect, src, src.Bounds(), draw.Over, nil) buf := new(bytes.Buffer) // Encode to `buf`: j.Encode(buf, dst, nil) copy(s.frame, header) // copy(s.frame[len(header):], jpeg) copy(s.frame[len(header):], buf.Bytes())所以，我的流媒体完整代码变成了：// Package mjpeg implements a simple MJPEG streamer.//// Stream objects implement the http.Handler interface, allowing to use them with the net/http package like so:// stream = mjpeg.NewStream()// http.Handle("/camera", stream)// Then push new JPEG frames to the connected clients using stream.UpdateJPEG().package mjpegimport ( "bytes" "fmt" "image" j "image/jpeg" "log" "net/http" "sync" "time" "golang.org/x/image/draw")// Stream represents a single video feed.type Stream struct { m map[chan []byte]bool frame []byte lock sync.Mutex FrameInterval time.Duration}const boundaryWord = "MJPEGBOUNDARY"const headerf = "\r\n" + "--" + boundaryWord + "\r\n" + "Content-Type: image/jpeg\r\n" + "Content-Length: %d\r\n" + "X-Timestamp: 0.000000\r\n" + "\r\n"// ServeHTTP responds to HTTP requests with the MJPEG stream, implementing the http.Handler interface.func (s *Stream) ServeHTTP(w http.ResponseWriter, r *http.Request) { log.Println("Stream:", r.RemoteAddr, "connected") w.Header().Add("Content-Type", "multipart/x-mixed-replace;boundary="+boundaryWord) c := make(chan []byte) s.lock.Lock() s.m[c] = true s.lock.Unlock() for { time.Sleep(s.FrameInterval) b := <-c _, err := w.Write(b) if err != nil { break } } s.lock.Lock() delete(s.m, c) s.lock.Unlock() log.Println("Stream:", r.RemoteAddr, "disconnected")}// UpdateJPEG pushes a new JPEG frame onto the clients.func (s *Stream) UpdateJPEG(jpeg []byte) { header := fmt.Sprintf(headerf, len(jpeg)) if len(s.frame) < len(jpeg)+len(header) { s.frame = make([]byte, (len(jpeg)+len(header))*2) } // Decode the image (from PNG to image.Image): src, _ := j.Decode(bytes.NewReader(jpeg)) // Set the expected size that you want: dst := image.NewRGBA(image.Rect(0, 0, src.Bounds().Max.X/3, src.Bounds().Max.Y/3)) // Resize: draw.NearestNeighbor.Scale(dst, dst.Rect, src, src.Bounds(), draw.Over, nil) buf := new(bytes.Buffer) // Encode to `buf`: j.Encode(buf, dst, nil) copy(s.frame, header) // copy(s.frame[len(header):], jpeg) copy(s.frame[len(header):], buf.Bytes()) s.lock.Lock() for c := range s.m { // Select to skip streams which are sleeping to drop frames. // This might need more thought. select { case c <- s.frame: default: } } s.lock.Unlock()}// NewStream initializes and returns a new Stream.func NewStream() *Stream { return &Stream{ m: make(map[chan []byte]bool), frame: make([]byte, len(headerf)), FrameInterval: 50 * time.Millisecond, }}我的任何输出变成：
随时随地看视频慕课网APP
相关分类
Go