PoC TBCPÏûÏ¢½âÎöºÍ¹¹ÔìµÄJAVAʵÏÖ

TBCPMessageFactory.java
/**
* ÎļþÃû: TBCPMessageFactory.java
*/
package tbcpstack;
import java.text.MessageFormat;
import org.apache.log4j.Logger;
import TBCPException;
/**
*
* TODO TBCPÏûÏ¢¹¹½¨¹¤³§
*/
public class TBCPMessageFactory {
/**
* Logger for this class
*/
private static final Logger logger = Logger.getLogger(TBCPMessageFactory.class);
private static final String POCNAME = "PoC1";
/**
* °´ÕÕOMA PoC UserPlaneÀï¹æ¶¨µÄTBCP Talk Burst RequestÏûÏ¢¸ñʽ½øÐй¹Ôì¡£
*
* @param ssrc
* SSRC of PoC Client requesting permission to send a talk burst
* @param priority
* Ö»ÄÜΪ1¡¢2¡¢3¡£ 1 - normal priority£»2 - high priority£»3 -
* pre-emptivepriority
* @return bytes of TalkBurstRequest
* @throws TBCPException
*/
public static byte[] createTBCPTalkBurstRequest(long ssrc, int priority) throws TBCPException {
if ((1 <= priority) && (priority <= 3)) {
byte[] data = new byte[16];
data[0] = 102;// TB-priority-level
data[1] = 2;// TB-priority-length
byte[] priorityValueBytes = ByteConversion.uIntIntToByteWord(priority);// TB-priority
// value
data[2] = priorityValueBytes[0];
data[3] = priorityValueBytes[1];
data[4] = 103;// Time-stamp
data[5] = 8;// Time-stamp-length
// Timestamp value
byte[] timeStampValueBytes = ByteConversion.longToByte(TimeStamp.getCurrentTime().ntpValue());
for (int i = 0; i < 8; i++) {
data[i + 6] = timeStampValueBytes[i];
}
data[14] = 0;// ºóÁ½Î»Òª²¹Îª0
data[15] = 0;
byte[] name = POCNAME.getBytes();
return prepareRTCPAppPacket(ssrc, TBCPMessageType.TBCP_REQUEST, name, data);