This is done using JMF (Java Media Framework). Voice data is read from a file using `MediaLocator’. It is used as the data source for a `Processor’. The `Processor’ specifies and converts the audio data to a certain format and then output the converted data into a `DataSink’. The `DataSink’ then transfers the stream to its destination address and port.
Leave a CommentCategory: SIP Speaker
SIPSpeaker is a system that provides answering machine service. When the system receives a SIP call, it will establish a new session with user client and send voice data to the user. The user can configure a customized message using a web interface.
The administrator of the system can configure the interface and port number for the web interface; he/she can also configure SIP service interface, port number as well as user name, either using a configuration file or command line arguments. Done in 2010.
A SessionManager' is used to manage all the sessions. The SessionManager’ keeps a list of sessions. When it receives data, it will first check which session the data belongs to. Then the data is given to the corresponding session. If it does not belong to any session in the list, a new session will be created and added to the session list.
The basic code looks like this:
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.logging.Level;
import java.util.logging.Logger;
/**
*
* @author Daoyuan
*/
public class SessionManager extends Thread {
String user;
String host;
int port;
String voiceFile;
String defaultVoice;
boolean listening = true;
public static ArrayList sessionList;
DatagramSocket serverSocket = null;
public SessionManager(String user, String host, int port, String voiceFile,
String defaultVoice) {
this.user = user;
this.host = host;
this.port = port;
this.voiceFile = voiceFile;
this.defaultVoice = defaultVoice;
sessionList = new ArrayList();
try {
serverSocket = new DatagramSocket(port);
} catch (SocketException ex) {
Logger.getLogger(SessionManager.class.getName()).log(Level.SEVERE, null, ex);
System.out.println("Unable to listen on port " + port);
}
}
@Override
public void run() {
byte[] receiveData = newbyte[2048];
new Thread() {
@Override
public void run() {
while (true) {
try {
Thread.sleep(5);
} catch (InterruptedException ex) {
Logger.getLogger(SessionManager.class.getName()).log(Level.SEVERE, null, ex);
}
if (sessionList.size() != 0) {
for (int i= 0; i < sessionList.size(); i++) {
if (sessionList.get(i).status.equals("destroyed")) {
sessionList.remove(i);
}
}
}
}
}
}.start();
while (listening) {
DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);
try {
serverSocket.receive(receivePacket);
} catch (IOException ex) {
Logger.getLogger(SessionManager.class.getName()).log(Level.SEVERE, null, ex);
}
if (isNewSession(receivePacket)) {
System.out.println("New session created!");
}
}
serverSocket.close();
}
public void stopListening() {
listening = false;
}
private boolean isNewSession(DatagramPacket receivePacket) {
InetAddress IPAddress = receivePacket.getAddress();
int remotePort = receivePacket.getPort();
String sessionName = IPAddress + ":" + remotePort;
if (sessionList.size() == 0) {
Session s = new Session(this.serverSocket, IPAddress, remotePort, voiceFile, defaultVoice, user);
s.setName(sessionName);
s.requests.add(receivePacket);
sessionList.add(s);
s.start();
return true;
} else {
for (int i = 0; i < sessionList.size(); i++) {
if (sessionList.get(i).getName().equals(sessionName)) {
sessionList.get(i).requests.add(receivePacket);
return false;
}
}
Session s = newSession(this.serverSocket, IPAddress, remotePort, voiceFile, defaultVoice, user);
s.setName(sessionName);
s.requests.add(receivePacket);
sessionList.add(s);
s.start();
return true;
}
}
}
Leave a CommentEach session has a ‘status’, it can be ‘new’, ‘establishing’, ‘cancelling’, ‘established’, ‘tearingdown’ and ‘destroyed’.
When a new session is created, its status is ‘new’.
When an ‘INVITE’ is received, it sends out an ‘OK’ message and change its status to ‘establishing’.
After receiving an ‘ACK’ message the status will be changed to ‘established’.
Then begins the transferring of voice data using RTP.
When the sending finishes the status will become ‘tearingdown’.
A ‘BYE’ message is also sent to the client.
The status becomes ‘destroyed’ after getting ‘OK’ from the client.
When a ‘CANCEL’ message is received, the status becomes ‘cancelling’.
Then it sends back ‘OK’ and ‘Request Terminated’ messages.
After received an ‘ACK’, the status becomes ‘destroyed’.
The thread is as follows:
@Override
public void run() {
while (true) {
if (requests.size() == 0) {
try {
Thread.sleep(10);
} catch (InterruptedException ex) {
Logger.getLogger(Session.class.getName()).log(Level.SEVERE, null, ex);
}
} else {
final DatagramPacket packet = requests.get(0);
final String request = new String(packet.getData());
System.err.println(request);
sipRequest = new SIPRequest(request);
if (request.toUpperCase().startsWith("INVITE")) {
System.out.println("Got INVITE");
if (!status.equals("new")) {
requests.remove(0);
continue;
}
String requestLine = request.substring(6).trim();
String uri = requestLine.substring(0, requestLine.indexOf(' '));
//System.out.println(uri);
String usr = "";
if (uri.toUpperCase().startsWith("SIP:")) {
usr = uri.substring(4, uri.indexOf('@'));
} else {
usr = uri.substring(0, uri.indexOf('@'));
}
if (!usr.equalsIgnoreCase(user)) {
sendUserNotFound(sipRequest);
status = "tearingdown";
System.out.println("Status: " + status);
continue;
}
sendTrying(sipRequest);
sendRinging(sipRequest);
final String rtpport = request.substring(request.indexOf("m=audio") + 8, request.indexOf("m=audio") + 13);
final String sdp = getSDP(request);
new Thread() {
@Override
public void run() {
File file = new File("wav/" + voiceFile);
if (file.exists()) {
locator = new MediaLocator("file:/" + file.getAbsolutePath());
} else {
System.out.println("Using default voice file!");
locator = new MediaLocator("file:/" + file.getAbsolutePath());
}
transmitter = new Transmitter(locator, packet.getAddress().toString().substring(1), rtpport);
transmitter.prepare();
}
}.start();
new Thread() {
@Override
public void run() {
try {
Thread.sleep(5000);
} catch (InterruptedException ex) {
Logger.getLogger(Session.class.getName()).log(Level.SEVERE, null, ex);
}
if (status.equals("establishing")) {
sendOK(sipRequest, sdp, rtpport);
} else {
try {
transmitter.stop();
} catch (NullPointerException ex) {
Logger.getLogger(Session.class.getName()).log(Level.SEVERE, null, ex);
System.out.println("Transmitter already stopped!");
}
}
}
}.start();
requests.remove(0);
status = "establishing";
System.out.println("Status: " + status);
} else if (request.toUpperCase().startsWith("ACK")) {
System.out.println("Got ACK");
//sendOK(sipRequest);
requests.remove(0);
if (status.equals("establishing")) {
status = "established";
System.out.println("Status: " + status);
new Thread() {
@Override
public void run() {
transmitter.start();
long duration = new VoiceInfo(locator).getDuration();
try {
Thread.sleep(duration);
} catch (InterruptedException ex) {
Logger.getLogger(Session.class.getName()).log(Level.SEVERE, null, ex);
}
try {
transmitter.stop();
} catch (NullPointerException ex) {
Logger.getLogger(Session.class.getName()).log(Level.SEVERE, null, ex);
System.out.println("Transmitter already stopped!");
}
if (!status.equals("tearingdown") && !status.equals("destroyed")) {
sendBye(sipRequest);
status = "tearingdown";
System.out.println("Status: " + status);
}
}
}.start();
} else if (status.equals("tearingdown")) {
status = "destroyed";
System.out.println("Status: " + status);
break;
} else if (status.equals("cancelling")) {
status = "destroyed";
System.out.println("Status: " + status);
break;
}
} else if (request.toUpperCase().startsWith("BYE")) {
System.out.println("Got BYE");
sendOKWithoutSDP(sipRequest);
requests.remove(0);
try {
transmitter.stop();
} catch (NullPointerException ex) {
Logger.getLogger(Session.class.getName()).log(Level.SEVERE, null, ex);
System.out.println("Transmitter already stopped!");
}
status = "destroyed";
System.out.println("Status: " + status);
break;
} else if (request.toUpperCase().startsWith("SIP/2.0 200")) {
requests.remove(0);
System.out.println("Got OK");
if (status.equals("tearingdown")) {
status = "destroyed";
System.out.println("Status: " + status);
break;
}
} else if (request.toUpperCase().startsWith("CANCEL")) {
requests.remove(0);
System.out.println("Got CANCEL");
status = "cancelling";
System.out.println("Status: " + status);
sendOKWithoutSDP(sipRequest);
sendTerminated(sipRequest);
} else {
requests.remove(0);
}
}
}
}
Leave a CommentWhen the web server receives a POST' message from the web page, it will first check whether the message is valid. If so, freeTTS‘ is used to generate a voice file and the file is saved in the `wav’ directory with pre-configured file name.
The voice generator looks as follows:
import com.sun.speech.freetts.Voice;
import com.sun.speech.freetts.VoiceManager;
import com.sun.speech.freetts.audio.SingleFileAudioPlayer;
/**
*
* @author Daoyuan
*/
public class VoiceGenerator {
String message;
public VoiceGenerator(String message){
this.message = message;
}
public void generateVoiceFile(String filename){
Voice voice;
VoiceManager vm = VoiceManager.getInstance();
voice = vm.getVoice("kevin16");
voice.allocate();
String baseName = filename.substring(0, filename.toLowerCase().indexOf(".wav"));
SingleFileAudioPlayer sfap = new SingleFileAudioPlayer("wav/" + baseName, javax.sound.sampled.AudioFileFormat.Type.WAVE);
voice.setAudioPlayer(sfap);
voice.speak(message);
sfap.close();
voice.deallocate();
}
}
Leave a CommentSIPSpeaker is a system that provides answering machine service. When the system receives a SIP call, it will establish a new session with user client and send voice data to the user. The user can configure a customized message using a web interface.
The administrator of the system can configure the interface and port number for the web interface; he/she can also configure SIP service interface, port number as well as user name, either using a configuration file or command line arguments.
The system supports multiple session to be communicated at the same time. It uses SIP to manage sessions, and SDP as the handshake protocol to reach an agreement on media format transfered on wire.
JMF is used to support audio playback. And FreeTTS is used to convert message from text to audio format.
Leave a Comment