/***************************************************
* 程序文件名称: 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;
//获取视频设备
private CaptureDeviceInfo device = null;
//获取音频设备
private CaptureDeviceInfo device2 = null;
//媒体定位器
private MediaLocator locator = null;
private Image image;
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("对方IP:");
//初始时,在接收图像窗口显示一幅静态图片
JLabel label2=new JLabel(new ImageIcon("image//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(image, 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(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("找不到音频设备!");
}
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("对方IP:"+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());
image = b2i.createImage(buffer); //转化为图像
//创建image图像对象大小的图像缓冲区
BufferedImage bi = (BufferedImage) createImage(image.getWidth(null),
image.getHeight(null));
//根据BufferedImage对象创建Graphics2D对象
Graphics2D g2 = bi.createGraphics();
g2.drawImage(image, 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("image//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
}
相关推荐
java 基于websocket实现的视频聊天,解压项目到对应位置部署到tomcat8即可使用
java 基于websocket实现的视频聊天,解压项目到对应位置部署到tomcat8即可使用
基于Java的视频会议系统是一种基于网络的实时视频会议系统,它可以实现多人视频会议、视频聊天等功能。该系统主要由会议控制器、视频处理器、音频处理器、网络通信模块等组成。 会议控制器负责会议的创建、管理和...
java视频聊天(anychat).zip
java语音视频聊天程序 实现了java 局域网内 语音视频 聊天的程序 基于jmf开发的 如果下载后该程序运行了 需要安装jfm 和配置jfm的环境变量 直接运行sounds包下的chatloginfame即可,handlens包下的程序为java的放大...
项目在线聊天系统,基于java开发的项目在线聊天系统,提供搭建视频
一个java初级的在线聊天学习视频,都是初级的东西,有助于了解一些基本IO使用!
anychat视频聊天,编译通过即可运行,很完善的聊天界面
这个版本支持一对一聊天,多对多聊天,以及传送文件等功能, 源码地址:https://github.com/js1688/cat 会持续更新 成果展现地址:https://www.tanjun.xyz 也可以直接下载此文件,maven构建项目所以源码才几十KB而已 没用...
视频聊天程序 在局域网中视频了视频聊天 运用sun公司提供的jmf做的
java语音视频聊天程序.zip
java + webrtc 实现的 视频聊天室 , 多对多的这个资源没有实现,这个资源只实现了一对一,后续的代码会在 github上持续更新 地址为: https://github.com/js1688/cat 成果展示地址:https://www.tanjun.xyz webrtc 真正...
Jitsi Android是一个Android(Jitsi)项目:港最功能丰富的沟通与支持加密的音频/视频、聊天和存在对SIP和XMPP。 # #与IntelliJ使用 1。确保你有(Java)和Android SDK安装在您的系统和(IntelliJ)是最新的版本(13.0.2)。 ...
java毕业设计——Java聊天室的设计与实现(论文+开题报告+答辩PPT+源代码+数据库+讲解视频).zip java毕业设计——Java聊天室的设计与实现(论文+开题报告+答辩PPT+源代码+数据库+讲解视频).zip java毕业设计——...
该资源包含了用Java写的实时的视频聊天Demo,利用的是webRTC技术,提供源码。 该资源来源于网络
java代码实现多线程聊天室,分服务器端与客户端
需要使用端口,域名访问时,必须对tomcat做自签名证书,如果只是在本地使用localhost访问,就不需要做自签名证书了。 项目地址:https://shiping.lipingoomoney.cn:8443/rtcdemo/