/***************************************************
*  程序文件名稱：　VAplay.java
*  功能：處理視頻圖像捕獲和音頻播放
***************************************************/
import java.awt.*;
import java.awt.image.*;
import java.awt.event.*;
import java.util.*;
import java.io.*;
import java.net.*;
import javax.imageio.*;
import javax.swing.*;
import javax.media.*;
import javax.media.protocol.*;
import javax.media.control.*;
import javax.media.util.*;
import javax.media.format.*;
import com.sun.image.codec.jpeg.*;

class VAplay extends JFrame implements Runnable
{
 //定義視頻圖像播放器
 private static Player player = null;
 //定義音頻播放器
 private static Player player2 = null;
 //獲取視頻設(shè)備
 private CaptureDeviceInfo device = null;
 //獲取音頻設(shè)備
 private CaptureDeviceInfo device2 = null;
 //媒體定位器
 private MediaLocator locator = null;
 private Image image;
 private Buffer buffer = null;
 private BufferToImage b2i = null;
 //設(shè)置攝像頭驅(qū)動(dòng)類型
 String str = "vfw:Microsoft WDM Image Capture (Win32):0";
 //定義播放組件變量
 Component comV,comVC,comA;
  //定義面板	
 JPanel p1,p2,p3,p4;
 JLabel label=new JLabel("對(duì)方ＩＰ：");
 //初始時(shí)，在接收?qǐng)D像窗口顯示一幅靜態(tài)圖片
 JLabel label2=new JLabel(new ImageIcon("image//load.gif"));
 //定義二個(gè)線程，用于接收數(shù)據(jù)和發(fā)送數(shù)據(jù)
 Thread thread1,thread2;
 
 VAplay()
  {
    super("★視頻傳輸★");
  	setBounds(150,100,500,500);
  	p1=new JPanel(new GridLayout(1,2));
  	p2=new JPanel(new GridLayout(2,1));
  	p3=new JPanel(new BorderLayout());
  	p4=new JPanel(new BorderLayout());
  	//加載文本數(shù)據(jù)傳輸類
  	p1.add(new TxtChat());
  	p1.add(p2);
  	p2.add(p3);
  	p2.add(p4);
  	p3.add("North",new JLabel("Java視頻圖像傳輸"));
  	p3.add(label2,"Center");
  	add(label,"North");
  	add(p1,"Center");
    try 
    	{
             //在本地播放視頻
      		jbInit();
             //在本地播放音頻
      		speaker();
    	}
    catch(Exception e) 
    	{
      		e.printStackTrace();
    	}
    thread1=new Thread(this);
    thread2=new Thread(this);
	//負(fù)責(zé)接收對(duì)方數(shù)據(jù)
	thread1.start();
	//負(fù)責(zé)向?qū)Ψ桨l(fā)送數(shù)據(jù)
	thread2.start();
		
    addWindowListener(new WindowAdapter()
    {
     public void windowClosing(WindowEvent e)
    	{
    		System.exit(0);
    	}
    });
    setVisible(true);
    validate();
  }
  	
 //在本地播放視頻
 private void jbInit() throws Exception 
 {    	
  //初始化設(shè)備，str為設(shè)備驅(qū)動(dòng)
  device = CaptureDeviceManager.getDevice(str);
  //確定所需的協(xié)議和媒體資源的位置
  locator = device.getLocator();
  try 
   {
    //調(diào)用sethint后Manager會(huì)盡力用一個(gè)能和輕量級(jí)組件混合使用的Renderer來(lái)創(chuàng)建播放器
    Manager.setHint(Manager.LIGHTWEIGHT_RENDERER,new Boolean(true));
    //通過(guò)管理器創(chuàng)建播放線程使player達(dá)到Realized狀態(tài)
    player = Manager.createRealizedPlayer(locator);
    player.start();

    if((comV = player.getVisualComponent()) != null) 
      //player.getVisualComponent()是一個(gè)播放視頻媒體組件。
      {
      	p4.add(comV,"Center");
      }
    if((comVC=player.getControlPanelComponent())!=null)
      //player.getControlPanelComponent()是顯示時(shí)間的組件
      {
      	p4.add(comVC,"South");
      }
   }
  catch (Exception e) 
   {
     e.printStackTrace();
   }
  setBounds(200,100,600, 550);
  setVisible(true);
  int new_w= p4.getWidth(); //輸出的圖像寬度
  int new_h= p4.getHeight(); //輸出的圖像高度
  //MediaTracker類跟蹤一個(gè)Image對(duì)象的裝載，完成圖像加載
  MediaTracker mt = new MediaTracker(this.p4);
  try 
   {
   	mt.addImage(image, 0);//裝載圖像
	mt.waitForID(0);//等待圖像全部裝載
   }
  catch (Exception e) 
   {
     e.printStackTrace();
   }
  //將圖像信息寫(xiě)入緩沖區(qū)
  BufferedImage buffImg = new BufferedImage(new_w, new_h,BufferedImage.TYPE_INT_RGB);
  Graphics g = buffImg.createGraphics();
  g.drawImage(image, 0, 0, new_w, new_h, this.p4);
  g.dispose();
 }
    
 //在本地播放音頻
 private void speaker() throws Exception
 {
  Vector deviceList = CaptureDeviceManager.getDeviceList(new 
      AudioFormat(AudioFormat.LINEAR,44100,16,2));
  if(deviceList.size()>0)
    {
     device2 = (CaptureDeviceInfo)deviceList.firstElement();
    }
  else
    {
     System.out.println("找不到音頻設(shè)備！");
    }
  try
   	{
     player2 = Manager.createRealizedPlayer(device2.getLocator());
     player2.start();
     if((comA = player2.getControlPanelComponent())!=null)
      {
    	p3.add(comA,"South");
      }
    }
  catch(Exception e)
    {
    	e.printStackTrace();
    }
 }
    
 //線程，接收或發(fā)送視頻圖像數(shù)據(jù)
 public void run()
 {	
  DatagramPacket pack=null;
  DatagramSocket maildata=null;
  byte data[]=new byte[320*240];
  try
   {
	//定義數(shù)據(jù)包
	pack=new DatagramPacket(data,data.length);
	//定義數(shù)據(jù)報(bào)接收包
	maildata=new DatagramSocket(5555);
   }
  catch(Exception e){  }
  while(true)
   {
  	if(Thread.currentThread()==thread1)
	 {
	  if(maildata==null)
		{
		 break;
		}
	  else
		{
		 try
		  {
		  	//接收
		   maildata.receive(pack);
		   ByteArrayInputStream input=new ByteArrayInputStream(data);
		   Image message=ImageIO.read(input);
		   //在接收?qǐng)D像窗口顯示視頻圖像
		   label2.setIcon(new ImageIcon(message));
		   label.setText("對(duì)方ＩＰ："+pack.getAddress()+
						" 端口："+pack.getPort());
		  }
		catch(Exception e)
		 {
		   System.out.println("接收?qǐng)D像數(shù)據(jù)失敗！");
		 }
	   }
	 }
	else if(Thread.currentThread()==thread2)
	 {
	  try
	  {
	   //捕獲要在播放窗口顯示的圖象幀
	   FrameGrabbingControl fgc = (FrameGrabbingControl) player.getControl(
       		"javax.media.control.FrameGrabbingControl");
       // 獲取當(dāng)前禎并存入Buffer類
       buffer = fgc.grabFrame(); 
       b2i = new BufferToImage( (VideoFormat) buffer.getFormat());
       image = b2i.createImage(buffer); //轉(zhuǎn)化為圖像
	   //創(chuàng)建image圖像對(duì)象大小的圖像緩沖區(qū)
	   BufferedImage bi = (BufferedImage) createImage(image.getWidth(null),
       image.getHeight(null));
       //根據(jù)BufferedImage對(duì)象創(chuàng)建Graphics2D對(duì)象
       Graphics2D g2 = bi.createGraphics();
       g2.drawImage(image, null, null);
 	   ByteArrayOutputStream output=new ByteArrayOutputStream();
	   //轉(zhuǎn)換成JPEG圖像格式
	   JPEGImageEncoder encoder = JPEGCodec.createJPEGEncoder( output );
	   JPEGEncodeParam jpeg = encoder.getDefaultJPEGEncodeParam(bi);
	   jpeg.setQuality(0.5f,false);
	   encoder.setJPEGEncodeParam(jpeg);
  	   encoder.encode(bi);
	   output.close();
	   InetAddress address=InetAddress.getByName("192.168.1.27");
	   DatagramPacket datapack1=new DatagramPacket(output.toByteArray(),output.size(),
					address,5000);
	   DatagramSocket maildata1=new DatagramSocket();
	   maildata1.send(datapack1);
	 //  Thread.sleep(400);
	  }
	 catch(Exception e)
	  {
		System.out.println("視頻發(fā)送失敗！");
	  }
	}
   }
  } 
    
 public static void main(String args[])
  {
	 new VAplay();
  }
}

class TxtChat extends JPanel implements ActionListener,Runnable
{
 JPanel p1,p2,p3,p4;
 JLabel jpic;
 JTextArea txt1,txt2;
 JButton btn1,btn2;
 JScrollPane scroll,scroll2;
 Thread thread;
 boolean boo1=false,boo2=false;
	
 TxtChat()
  {
	setLayout(new BorderLayout());
		
	txt1=new JTextArea();
	txt2=new JTextArea();
	p1=new JPanel(new GridLayout(2,1));
	p2=new JPanel();
	p3=new JPanel(new BorderLayout());
	jpic=new JLabel(new ImageIcon("image//upload.gif"));
	btn1=new JButton("電子文檔");
	btn2=new JButton("發(fā)送信息");
		
	scroll=new JScrollPane(txt1,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,
	JScrollPane.HORIZONTAL_SCROLLBAR_AS_NEEDED);
	scroll2=new JScrollPane(txt2,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,
	JScrollPane.HORIZONTAL_SCROLLBAR_AS_NEEDED);
	p1.add(scroll);
	p1.add(p3);
	p2.add(btn1);
	p2.add(btn2);
	p3.add(jpic,"North");
	p3.add(scroll2,"Center");
		
	add(p1,"Center");
	add(p2,"South");
		
	setVisible(true);
	Font f=new Font("",Font.PLAIN,18);
	txt1.setFont(f);
	txt1.setForeground(Color.red);
	txt2.setFont(f);
	txt2.setForeground(Color.blue);
	btn1.setBackground(Color.cyan);
	btn2.setBackground(Color.yellow);
		
	btn1.addActionListener(this);
	btn2.addActionListener(this);
		
	thread=new Thread(this);
	thread.start();

  }
	
 public void actionPerformed(ActionEvent e)
  {
   if(e.getSource()==btn2)
	{
     byte buffer[]=txt2.getText().trim().getBytes();
	 try
	  {
		InetAddress address=InetAddress.getByName("192.168.1.27");
		DatagramPacket data_pack=new DatagramPacket(buffer,buffer.length,address,6001);
		DatagramSocket mail_data=new DatagramSocket();
		txt1.append("我說(shuō)："+txt2.getText()+'\n');
		mail_data.send(data_pack);
		txt2.setText("");
	  }
	 catch(Exception e1)
	  {
		System.out.println("聊天信息發(fā)送失敗！");
	  }
	}
  }
	
 public void run()
  {
	DatagramPacket pack=null;
	DatagramSocket mail_data=null;
	byte data[]=new byte[8192];
	try
	 {
 	  pack=new DatagramPacket(data,data.length);
	  mail_data=new DatagramSocket(6000);
	 }
	catch(Exception e){  }
	while(true)
 	{
	 if(Thread.currentThread()==thread)
	  {
	   if(mail_data==null)
		{break;}
	   else
		{
		 try
		  {
		   mail_data.receive(pack);
		   int length=pack.getLength();
		   String message=new String(pack.getData(),0,length);
		   txt1.append("某某說(shuō)："+message+'\n');
		  }
		 catch(Exception e)
		  {
			System.out.println("接收數(shù)據(jù)失敗！");
		  }
		 }
	   }
	 }// while end
  }  //run() end
}