免费毕设之基于Java的远程视频会议系统（系统+论文）

5.1 系统开发环境

系统：Microsoft Windows XP Professional Service Pack 2

开发语言：JAVA

编程环境：Eclipse

JMF版本：JMF 2.1.1

JDK版本：JDK 5.0

Eclipse版本：Eclipse3.2

5.2 系统实现

5.2.1服务器端套接字建立

数据通讯是双向的，客户端通过套接字请求数据通讯后，服务器端需要有一个响应客户端请求通讯的服务程序，该服务器程序应用ServerSocket类完成与客户端的通讯。

ServerSocket类用来监听和响应客户端的连接请求，并接受客户端发送的数据信息。ServerSocket类在服务器端等待其他机器同它的连接，一旦客户端程序建立一个套接字连接，ServerSocket类就会通过accept（）方法返回一个对应的服务器端套接字对象，以便进行直接通讯。从两台计算机连接成功起，服务器端与客户端就得到了一个真正的“套接字-套接字”连接，此时利用Socket类中的getInputStream()及getOutputStream（）方法从每端的套接字产生对应的InputStream和OutputStream对象，并将套接字数据流封装到缓冲区内以便进行两台机器之间的数据通讯。

serverSocketChannel =ServerSocketChannel.open();//打开连接通道

serverSocketChannel.socket().bind(newInetSocketAddress(12345));

//绑定IP与端口号

getConnection();//接收连接请求

charSet =Charset.forName("UTF-8");//开启服务器套接字通道

serverSocketChannel =ServerSocketChannel.open();

serverSocketChannel.socket().bind(newInetSocketAddress(12345));     serverSocketChannel.configureBlocking(false);

//设置阻塞模式为非阻塞模式等待一个连接

5.2.2客户端套接字建立

客户端使用Socket类的方法建立（类似于服务器端），客户端向套接字对象中的数据流输出和获取数据。客户端程序试图与服务器之间在Socket层次上建立一个连接，通过套接字输入流读取方法从套接字数据流中获取服务器信息，以及写入数据到套接字输出流中向服务器发送信息，并且等待服务器的答复。如果连接成功，则该客户端程序通过套接字与服务器可以进行正常的数据交换。

socketChannel =SocketChannel.open();打开连接通道

socketChannel.connect(new InetSocketAddress(InetAddress.getByName

(serverAddress),12345));//连接到服务器

receiveMessage = new ReceivingThread();//构造接收信息线程

receiveMessage.start();//运行线程

socketChannel.write(writeBuffer);//往通道里写入消息

socketChannel.read(readBuffer);//读取通道中消息

5.2.3视音频发送

视音频数据以RTP实时流的形式发送出去，通过会话管理器（Session Manager）传输RTP数据的步骤为：

1.  产生一个JMF处理器（Processor），为每一种RTP格式设置相应的轨迹格式。

2.  从处理器获取输出数据源。

3.  会话管理器产生一个发送数据流，即以数据源和序号作为参数调用会话管理器的createSendStream（）方法。

4.  开始会话传输。

5.  通过监听ControllerEvent事件控制会话的过程。

6.  停止会话，删除会话管理器。

定义以下内容：

// 媒体定位  IP 端口 处理器 会话管理器  输出数据源

private MediaLocator Locator;

private String IpAddress;

private int portBase;

private Processor processor=null;

private RTPManger rtpMgrs[];

private DataSource dataOutput=null;

具体实现函数如下：

//发送数据函数

public RTPTransmit(Processorprocessor,String ipAddress, String pb){}

//为媒体定位器产生一个处理器

private String createProcessor(){}

// 为处理器的每一个媒体磁道产生一个RTP会话

private String createTransmitter() {}

// 让处理器开始传输

public synchronized String start(){}

// 停止传输

  publicvoid stop(){}

  //组播线程类

classCreateJoinMuiltcastThread extends Thread {}

//处理器的状态监听器类

class StateListener implements ControllerListener {}

5.2.4视音频接收

接收网络实时媒体数据流是通过java.media包中定义的各种RTP事件监听器和RTP事件处理类来处理和控制的，使用java.media包中的Player类可以实时播放网络多媒体数据流，java.media包中的处理媒体流接收和播放完成了整个接收RTP数据的过程。接收部分程序为每一种新接收到的媒体数据流产生一个播放器，一边接收媒体流数据，一边将媒体数据播放出来，其实现分为以下几个步骤：

1. 实现ReceiveStreamListener监听接口，监听NewReceiveStreamEvent事件。

2. 当接收到NewReceiveStreamEvent事件后，通过事件获取接收媒体数据流（ReceiveStream），然后通过接收媒体数据流获取RTP数据源（DataSource）。

3. 将数据源传给Manager.createPlayer()产生一个播放器。

4. 给播放器添加监听器，等到播放器实现后，即可显示播放数据。

定义以下内容：

String sessions[] = null;            // RTP会话字符串数组

RTPManager mgrs[] = null;            // RTP管理器数组

Vector playerPanels = null;          // 管理播放器窗口的向量

boolean dataReceived = false;        // 是否接收到数据的标志

Object dataSync = new Object();      // 同步对象

具体实现函数如下：

//接收数据实现函数

public Receive(String sessions[]) {}

//初始化RTP会话，准备接收数据

protected boolean initialize(){}

//关闭播放窗口

protected void close(){}

//判断数据是否接收完成

 public boolean isDone() {}

// 通过播放器查找播放窗口

PlayerPanel find(Player p) {}

// 通过接收数据流查找播放窗口

PlayerPanel find(ReceiveStream strm) {}

//实现ReceiveStreamListener监听接口

public synchronized void update(ReceiveStreamEvent evt) {}

源文件