Java在線視頻聊天

Java在線視頻聊天

　　import java.awt.*;

　　import java.awt.p_w_picpath.*;

　　import java.awt.event.*;

　　import java.util.*;

　　import java.io.*;

　　import java.net.*;

　　import javax.p_w_picpathio.*;

　　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.p_w_picpath.codec.jpeg.*;

　　class VAplay extends JFrame implements Runnable

　　{

　　//定義視頻圖像播放器

　　private static Player player = null;

　　//定義音頻播放器

　　private static Player player2 = null;

　　//獲取視頻設備

　　private CaptureDeviceInfo device = null;

　　//獲取音頻設備

　　private CaptureDeviceInfo device2 = null;

　　//媒體定位器

　　private MediaLocator locator = null;

　　private Image p_w_picpath;

　　private Buffer buffer = null;

　　private BufferToImage b2i = null;

　　//設置攝像頭驅動類型

　　String str = "vfw:Microsoft WDM Image Capture (Win32):0";

　　//定義播放組件變量

　　Component comV,comVC,comA;

　　//定義面板

　　JPanel p1,p2,p3,p4;

　　JLabel label=new JLabel("對方ＩＰ：");

　　//初始時，在接收圖像窗口顯示一幅靜態圖片

　　JLabel label2=new JLabel(new ImageIcon("p_w_picpath//load.gif"));

　　//定義二個線程，用於接收數據和發送數據

　　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());

　　//加載文本數據傳輸類

　　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);

　　//負責接收對方數據

　　thread1.start();

　　//負責向對方發送數據

　　thread2.start();

　　addWindowListener(new WindowAdapter()

　　{

　　public void windowClosing(WindowEvent e)

　　{

　　System.exit(0);

　　}

　　});

　　setVisible(true);

　　validate();

　　}

　　//在本地播放視頻

　　private void jbInit() throws Exception

　　{

　　//初始化設備,真人視頻，str爲設備驅動

　　device = CaptureDeviceManager.getDevice(str);

　　//肯定所需的協議和媒體資源的位置

　　locator = device.getLocator();

　　try

　　{

　　//調用sethint後Manager會盡力用一個能和輕量級組件混合使用的Renderer來建立播放器

　　Manager.setHint(Manager.LIGHTWEIGHT_RENDERER,new Boolean(true));

　　//經過管理器建立播放線程使player達到Realized狀態

　　player = Manager.createRealizedPlayer(locator);

　　player.start();

　　if((comV = player.getVisualComponent()) != null)

　　//player.getVisualComponent()是一個播放視頻媒體組件。

　　{

　　p4.add(comV,"Center");

　　}

　　if((comVC=player.getControlPanelComponent())!=null)

　　//player.getControlPanelComponent()是顯示時間的組件

　　{

　　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類跟蹤一個Image對象的裝載，完成圖像加載

　　MediaTracker mt = new MediaTracker(this.p4);

　　try

　　{

　　mt.addImage(p_w_picpath, 0);//裝載圖像

　　mt.waitForID(0);//等待圖像所有裝載

　　}

　　catch (Exception e)

　　{

　　e.printStackTrace();

　　}

　　//將圖像信息寫入緩衝區

　　BufferedImage buffImg = new BufferedImage(new_w, new_h,BufferedImage.TYPE_INT_RGB);

　　Graphics g = buffImg.createGraphics();

　　g.drawImage(p_w_picpath, 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("找不到音頻設備！");

　　}

　　try

　　{

　　player2 = Manager.createRealizedPlayer(device2.getLocator());

　　player2.start();

　　if((comA = player2.getControlPanelComponent())!=null)

　　{

　　p3.add(comA,"South");

　　}

　　}

　　catch(Exception e)

　　{

　　e.printStackTrace();

　　}

　　}

　　//線程，接收或發送視頻圖像數據

　　public void run()

　　{

　　DatagramPacket pack=null;

　　DatagramSocket maildata=null;

　　byte data[]=new byte[320*240];

　　try

　　{

　　//定義數據包

　　pack=new DatagramPacket(data,data.length);

　　//定義數據報接收包

　　maildata=new DatagramSocket(999);

　　}

　　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);

　　//在接收圖像窗口顯示視頻圖像

　　label2.setIcon(new ImageIcon(message));

　　label.setText("對方ＩＰ："+pack.getAddress()+

　　" 端口："+pack.getPort());

　　}

　　catch(Exception e)

　　{

　　System.out.println("接收圖像數據失敗！");

　　}

　　}

　　}

　　else if(Thread.currentThread()==thread2)

　　{

　　try

　　{

　　//捕獲要在播放窗口顯示的圖象幀

　　FrameGrabbingControl fgc = (FrameGrabbingControl) player.getControl(

　　"javax.media.control.FrameGrabbingControl");

　　// 獲取當前禎並存入Buffer類

　　buffer = fgc.grabFrame();

　　b2i = new BufferToImage( (VideoFormat) buffer.getFormat());

　　p_w_picpath = b2i.createImage(buffer); //轉化爲圖像

　　//建立p_w_picpath圖像對象大小的圖像緩衝區

　　BufferedImage bi = (BufferedImage) createImage(p_w_picpath.getWidth(null),

　　p_w_picpath.getHeight(null));

　　//根據BufferedImage對象建立Graphics2D對象

　　Graphics2D g2 = bi.createGraphics();

　　g2.drawImage(p_w_picpath, null, null);

　　ByteArrayOutputStream output=new ByteArrayOutputStream();

　　//轉換成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("localhost");

　　DatagramPacket datapack1=new DatagramPacket(output.toByteArray(),output.size(),教育視頻,

　　address,555);

　　DatagramSocket maildata1=new DatagramSocket();

　　maildata1.send(datapack1);

　　Thread.sleep(400);

　　}

　　catch(Exception e)

　　{

　　System.out.println("視頻發送失敗！");

　　}

　　}

　　}

　　}

　　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("p_w_picpath//upload.gif"));

　　btn1=new JButton("電子文檔");

　　btn2=new JButton("發送信息");

　　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("localhost");

　　DatagramPacket data_pack=new DatagramPacket(buffer,buffer.length,address,888);

　　DatagramSocket mail_data=new DatagramSocket();

　　txt1.append("我說："+txt2.getText()+'\n');

　　mail_data.send(data_pack);

　　txt2.setText("");

　　}

　　catch(Exception e1)

　　{

　　System.out.println("聊天信息發送失敗！");

　　}

　　}

　　}

　　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(666);

　　}

　　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("某某說："+message+'\n');

　　}

　　catch(Exception e)

　　{

　　System.out.println("接收數據失敗！");

　　}

　　}

　　}

　　}// while end

　　} //run() end

　　}