学步园

<br /> /*******************************************************<br /> * This is a sip servlet.And it is not finished yet.<br /> * Current version is 1.0<br /> * Author Norz<br /> * 03/06/2010<br /> ********************************************************/<br /> package myServlet;<br /> import javax.annotation.Resource;<br /> import javax.naming.Context;<br /> import javax.naming.InitialContext;<br /> import javax.naming.NamingException;<br /> import javax.servlet.sip.Address;<br /> import javax.servlet.sip.Proxy;<br /> import javax.servlet.sip.SipErrorEvent;<br /> import javax.servlet.sip.SipErrorListener;<br /> import javax.servlet.sip.SipServlet;<br /> import javax.servlet.sip.SipFactory;<br /> import javax.servlet.sip.SipServletResponse;<br /> import javax.servlet.sip.SipSession;<br /> import java.io.IOException;<br /> import java.util.HashMap;<br /> import java.util.Properties;<br /> import javax.servlet.Servlet;<br /> import javax.servlet.ServletConfig;<br /> import javax.servlet.ServletException;<br /> import javax.servlet.sip.SipServletRequest;<br /> @SuppressWarnings("unused")<br /> @javax.servlet.sip.annotation.SipServlet<br /> public class MyServlet extends SipServlet implements SipErrorListener,Servlet{<br /> /**<br /> * Serial version UID.<br /> */<br /> private static final long serialVersionUID = 1L;</p> <p> private static final String CONTACT_HEADER = "Contact";<br /> private static final String SDPContent = "application/sdp";<br /> private static final String HoldFlag = "a=sendonly";<br /> private static final String ResFlag = "a=recvonly";</p> <p> //call status<br /> private static final String BUSY = "busy";<br /> private static final String HELD = "held";<br /> private static final String WAITING = "waiting";</p> <p> private static CallStatusContainer callsc;<br /> /**<br /> * The SIP Factory. Can be used to create URI and requests.<br /> */<br /> @Resource<br /> private SipFactory sipFactory;</p> <p> public MyServlet(){<br /> }<br /> /**<br /> * @inheritDoc<br /> */<br /> @SuppressWarnings("unchecked")<br /> protected void doRegister(SipServletRequest req)<br /> throws ServletException, IOException {<br /> int response = SipServletResponse.SC_OK;<br /> SipServletResponse resp = req.createResponse(response);</p> <p> HashMap<String,String> users = (HashMap<String,String>)getServletContext().getAttribute("registeredUsersMap");<br /> if(users == null)<br /> users = new HashMap<String,String>();<br /> getServletContext().setAttribute("registeredUserMap", users);<br /> Address address = req.getAddressHeader(CONTACT_HEADER);<br /> String fromURI = req.getFrom().getURI().toString();</p> <p> int expires = address.getExpires();<br /> if( expires < 0) {<br /> expires = req.getExpires();<br /> }<br /> if(expires == 0) {<br /> users.remove(fromURI);<br /> if( callsc.getSpecStatus(req.getFrom().toString()) != null) {<br /> callsc.removeSpecCall(req.getFrom().toString());<br /> }<br /> } else {<br /> resp.setAddressHeader(CONTACT_HEADER, address);<br /> users.put(fromURI, address.getURI().toString());<br /> }</p> <p> resp.send();<br /> }<br /> /**<br /> * @inheritDoc<br /> */<br /> protected void doSuccessResponse(SipServletResponse resp)<br /> throws ServletException, IOException {<br /> int response = SipServletResponse.SC_OK;<br /> if(resp.getStatus() == response)<br /> {<br /> String status = callsc.getSpecStatus(resp.getTo().toString());<br /> if( status == HELD )<br /> {<br /> resp.setContentLength(0);<br /> resp.send();<br /> KeyStepOfCallWait(resp);<br /> } else<br /> {<br /> callsc.addCall(resp.getFrom().toString(), resp.getTo().toString(), BUSY);<br /> callsc.addCall(resp.getTo().toString(), resp.getFrom().toString(), BUSY);<br /> }<br /> }<br /> }<br /> /**<br /> * If receive a 182 queued,set the call to HELD,and change response to 183.<br /> * This mechanism focus on To.So when doSuccessResponse also focus on To<br /> * callsc.getSpecStatus(String To)<br /> */<br /> protected void doProvisionalResponse(SipServletResponse resp)<br /> throws ServletException, IOException {<br /> int response = SipServletResponse.SC_SESSION_PROGRESS;<br /> if( resp.getStatus() == SipServletResponse.SC_CALL_QUEUED)<br /> {<br /> Call call = new Call(resp.getFrom().toString(),resp.getTo().toString());<br /> call.setStatus(HELD);<br /> callsc.addCall(call.getFrom(),call.getTo(), HELD);//actually only To is HELD,and is needed.<br /> resp.setStatus(response);<br /> resp.send();<br /> }<br /> }<br /> /**<br /> * Check the session of the request,if it's a INITIAL state,handle it as<br /> * a normal Invite,else if it's a CONFIRMED state,check if it contains<br /> * SDP message.And send 200 back.<br /> */<br /> protected void doInvite(SipServletRequest req)<br /> throws ServletException, IOException {<br /> SipSession session = req.getSession();<br /> if( session.getState().equals(SipSession.State.INITIAL)) //This is a normal Invite<br /> {<br /> Proxy proxy = req.getProxy();<br /> proxy.setRecordRoute(true);<br /> proxy.setSupervised(true);<br /> proxy.proxyTo(req.getRequestURI());<br /> } else if(session.getState().equals(SipSession.State.CONFIRMED))//This's sent by a CONFIRMED session,so it's a re-invite<br /> {<br /> if(req.getContentType().equalsIgnoreCase(SDPContent) && req.getContentLength() != 0) { //The request contains a SDP info<br /> String str = req.getContent().toString();<br /> if(str.indexOf(HoldFlag) != -1 ) { //check if is a Call-Hold re-Invite<br /> int response = SipServletResponse.SC_OK;<br /> SipServletResponse resp = req.createResponse(response);<br /> resp.send();<br /> callsc.addCall(req.getFrom().toString(), req.getTo().toString(), HELD);<br /> /*<br /> * Add SDP MRS to request<br /> */<br /> Proxy proxy = req.getProxy();<br /> proxy.setSupervised(true);<br /> proxy.setRecordRoute(true);<br /> proxy.proxyTo(req.getRequestURI());<br /> }</p> <p> }<br /> }<br /> }<br /> /**<br /> * @inheritDoc<br /> */<br /> protected void doAck(SipServletRequest req)<br /> throws ServletException, IOException {<br /> //TODO: Implement this method<br /> }<br /> /**<br /> * @inheritDoc<br /> */<br /> protected void doBye(SipServletRequest req)<br /> throws ServletException, IOException {<br /> callsc.removeCall(req.getFrom().toString(), req.getTo().toString());<br /> callsc.removeCall(req.getTo().toString(), req.getFrom().toString());<br /> }<br /> /**<br /> * @inheritDoc<br /> */<br /> protected void doErrorResponse(SipServletResponse resp)<br /> throws ServletException, IOException {<br /> callsc.removeCall(resp.getFrom().toString(), resp.getTo().toString());<br /> callsc.removeCall(resp.getTo().toString(), resp.getFrom().toString());<br /> }<br /> @Override<br /> public void noAckReceived(SipErrorEvent arg0) {<br /> // TODO Auto-generated method stub</p> <p> }<br /> @Override<br /> public void noPrackReceived(SipErrorEvent arg0) {<br /> // TODO Auto-generated method stub</p> <p> }</p> <p> public void KeyStepOfCallWait(SipServletResponse resp) throws IOException {<br /> Address To = (Address) resp.getTo().getURI();<br /> Address From = (Address) resp.getFrom().getURI();<br /> SipSession session = resp.getSession();<br /> SipServletRequest request = session.createRequest("INVITE");<br /> request.setAddressHeader("From", From);<br /> request.setAddressHeader("To", To);<br /> request.send();<br /> request.setAddressHeader("To", From);<br /> request.setAddressHeader("From", To);<br /> request.send();<br /> }<br /> }<br />