package com.mir.video.socket;

import java.awt.Color;
import java.awt.Graphics;
import java.awt.HeadlessException;
import java.awt.Image;
import java.io.BufferedInputStream;
import java.io.ByteArrayInputStream;
import java.io.DataInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;

import javax.imageio.ImageIO;
import javax.swing.JFrame;

import com.mir.Global;

/**
 * ClassName:SocketVideo
 * 
 * @author <font color="red">Edson</font>
 * @version
 * @since Ver 1.1
 * @Date 2014年6月27日 下午6:21:45
 * 
 * @see
 */
public class SocketVideo extends JFrame {
	private static final long serialVersionUID = 1L;
	private Image img;

	private SocketVideo() throws HeadlessException {
		// 设置显示标题
		this.setTitle("Socket模拟视频");
		// 设置窗口大小
		this.setSize(600, 480);
		// 设置是否显示
		this.setVisible(true);
		// 设置背景颜色
		this.setBackground(new Color(255));
	}

	@Override
	public void paint(Graphics g) {
		g.drawImage(img, 1, 1, 600, 480, this);
	}

	protected SocketVideo setImage(Image image) {
		this.img = image;
		return this;
	}
	
	public static void main(String[] args) throws IOException {
		Socket socket = null;
		SocketVideo frame = new SocketVideo();
		DataInputStream in = null;
		OutputStream out = null;
		byte[] buf = new byte[1024 * 1024 * 10];

		try {
			// 连接服务器
			socket = new Socket(Global.IP, Global.PORT);
			System.out.println("Client Start ");
			in = new DataInputStream(new BufferedInputStream(
					socket.getInputStream()));
			out = socket.getOutputStream();

			while (true) {
				// 向Server 写入数据 Server接收到数据后将不再阻塞
				out.write(1);
				out.flush();
				// 读取文件长度
				int len = (int) in.readLong();

				int length = 0;
				// 读取数据到byte[] 并得到流的长度
				length = in.read(buf);
				System.out.println("文件长度：" + len +" 字节");
				System.out.println("流  长  度：" + length +" 字节");
				if (len == length){
					frame.setImage(ImageIO.read(new ByteArrayInputStream(buf)))
							.repaint();
				}
				// 休眠100毫秒
				Thread.sleep(100);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}