SIP简介

服务器端代码

publicclassChatRoomServerextendsSipServlet{

/**Contextattributekeytostoreuserlist.*/

publicstaticStringTHE_LIST="dev2dev.chatroomserver.userList";

/**Initparameterkeytoretrievethechatroom'saddress.*/

publicstaticStringTHE_NAME="dev2dev.chatroomserver.name";

/**Thischatroomserver'saddress,retrievedfromtheinitparams.*/

publicStringserverAddress;

/**Thisiscalledbythecontainerwhenstartinguptheservice.*/

publicvoidinit()throwsServletException{

super.init();

getServletContext().setAttribute(THE_LIST,newArrayList());

serverAddress=getServletConfig().getInitParameter(THE_NAME);

}

/**Thisiscalledbythecontainerwhenshuttingdowntheservice.*/

publicvoiddestroy(){

try

{

sendToAll(serverAddress,"Serverisshuttingdown--goodbye!");

}catch(Throwablee)

{//ignoreallerrorswhenshuttingdown.

e.printStackTrace();

}

super.destroy();

}

...

/**ThisiscalledbythecontainerwhenaMESSAGEmessagearrives.*/

protectedvoiddoMessage(SipServletRequestrequest)throws

ServletException,IOException{

request.createResponse(SipServletResponse.SC_OK).send();

Stringmessage=request.getContent().toString();

Stringfrom=request.getFrom().toString();

//Auseraskedtoquit.

if(message.equalsIgnoreCase("/quit")){

sendToUser(from,"Bye");

removeUser(from);

return;

}

//Addusertothelist

if(!containsUser(from)){

sendToUser(from,"Welcometochatroom"+serverAddress+

".Type'/quit'toexit.");

addUser(from);

}

//Iftheuserisjoiningthechatroomsilently,nomessage

//tobroadcast,return.

if(message.equalsIgnoreCase("/join")){

return;

}

//WecouldimplementmoreIRCcommandshere,

//see'target='_blank'>http://www.mirc.com/cmds.html[/code]
sendToAll(from,message);

}


/**

*Thisiscalledbythecontainerwhenanerrorisreceived

*regardingasentmessage,includingtimeouts.

*/

protectedvoiddoErrorResponse(SipServletResponseresponse)

throwsServletException,IOException{

super.doErrorResponse(response);

//Thereceiverofthemessageprobablydroppedoff.Remove

//thereceiverfromthelist.

Stringreceiver=response.getTo().toString();

removeUser(receiver);

}


/**

*Thisiscalledbythecontainerwhena2xx-OKmessageis

*receivedregardingasentmessage.

*/

protectedvoiddoSuccessResponse(SipServletResponseresponse)

throwsServletException,IOException{

super.doSuccessResponse(response);

//Wecreatedtheappsession,wehavetodestroyittoo.

response.getApplicationSession().invalidate();

}

　　第一个方法在收到一个MESSAGE消息时被调用。最初以一条200OK消息响应，表明收到了消息。然后它处理服务器命令，比如/join。最后，它调用一个业务逻辑方法来广播传入的消息。

　　传入的错误响应消息表明上一个请求失败了。这可能意味着有一个用户被断开了。只需将该用户从列表中移除即可。

　　成功的响应消息表明上一个MESSAGE消息被即时messenger正确地接收了。因此不再需要该会话，可以将其删除了。通常，MESSAGE消息是以无状态的形式发送的，并不保存消息之间的连接信息。（对于INVITE消息来说，情况不是这样的，它打开一个有状态的会话直到发送BYE。）

3.业务逻辑代码

　　其余的代码由helper方法组成。前两个方法向即时messenger发送消息。要发送消息，使用一个工厂创建以下两项：

0.一个SipApplicationSession（稍后将详细介绍）

1.一个请求消息

　　此时，可以随心所欲地修改消息。在我们的例子中，我们在有效负载中添加即时消息文本。最后，发送该消息。

privatevoidsendToAll(Stringfrom,Stringmessage)

throwsServletParseException,IOException{

SipFactoryfactory=(SipFactory)getServletContext().

getAttribute("javax.servlet.sip.SipFactory");


Listlist=(List)getServletContext().getAttribute(THE_LIST);

Iteratorusers=list.iterator();

while(users.hasNext()){//Sendthismessagetoallonthelist.

Stringuser=(String)users.next();


SipApplicationSessionsession=

factory.createApplicationSession();

SipServletRequestrequest=factory.createRequest(session,

"MESSAGE",serverAddress,user);

Stringmsg=from+"sentmessage:\n"+message;

request.setContent(msg.getBytes(),"text/plain");

request.send();

}

}


privatevoidsendToUser(Stringto,Stringmessage)

throwsServletParseException,IOException{

SipFactoryfactory=(SipFactory)getServletContext().

getAttribute("javax.servlet.sip.SipFactory");

SipApplicationSessionsession=factory.createApplicationSession();

SipServletRequestrequest=factory.createRequest(session,

"MESSAGE",serverAddress,to);

request.setContent(message.getBytes(),"text/plain");

request.send();

}


privatebooleancontainsUser(Stringfrom){

Listlist=(List)getServletContext().getAttribute(THE_LIST);

returnlist.contains(from);

}


privatevoidaddUser(Stringfrom){

Listlist=(List)getServletContext().getAttribute(THE_LIST);

list.add(from);

}


privatevoidremoveUser(Stringfrom){

Listlist=(List)getServletContext().getAttribute(THE_LIST);

list.remove(from);

}


}

部署描述符
　　对于HTTP
servlet，还必须编写web.xml部署描述符。而在SIPservlet中，对应的文件是sip.xml，我们在其中列出SIPservlet、初始化参数以及映射（哪个SIPservlet处理哪些SIP消息）。关于该文件语法的更多信息，请参见SIPServlet规范中15.5节的DTD。其语法类似于web.xml，但<servlet-mapping>标签除外。它不会将一个URL模式映射到servlet，而是（基于字段和子字段的内容）描述一个条件，SIP请求必须满足这个条件才能被映射到servlet。SIPServlet规范第11节描述了所有的字段、子字段以及用于该映射的条件。

　　注意，该映射只用于初始请求；同一个会话/对话中的后续请求由处理初始请求的同一servlet处理。

下面是用于ChatRoomServer的XML代码：

<?xmlversion="1.0"encoding="UTF-8"?>

<!DOCTYPEsip-app

PUBLIC"-//JavaCommunityProcess//DTDSIPApplication1.0//EN"

"http://www.jcp.org/dtd/sip-app_1_0.dtd">

<sip-app>

<servlet>

<servlet-name>ChatRoomServer</servlet-name>

<servlet-class>dev2dev.chatroomserver.ChatRoomServer</servlet-class>

<init-param>

<param-name>dev2dev.chatroomserver.name</param-name>

<!--Thiswillbereplacedbythebuildscript-->

<param-value>sip:chatroomname@serveraddress</param-value>

</init-param>

</servlet>


<servlet-mapping>

<servlet-name>ChatRoomServer</servlet-name>

<pattern>

<and>

<equal>

<var>request.uri.user</var>

<!--Thiswillbereplacedbythebuildscript-->

<value>chatroomname</value>

</equal>

<equal>

<var>request.method</var>

<value>MESSAGE</value>

</equal>

</and>

</pattern>

</servlet-mapping>


</sip-app>

　　代码看起来很复杂，其实并非如此。Servlet映射说明了：

　　如果请求URI的用户名部分等于chatroomname，则将传入的MESSAGE请求映射到ChatRoomServerServlet。

　　该聊天室名称只是一个占位符。在编译过程中，会用实际的聊天室名称替换关键字“chatroomname”。

　　这么做有什么用呢？您可以将同样的服务部署多次，每次都使用其独有的聊天室名称，而消息可以自动发送到相应的servlet。

构建、打包、部署
　　需要对SIP
servlet进行编译，并将其打包到SAR(ServletARchives)文件中。这些文件在功能上等效于WAR文件，结构也相同。参见图2：

图2.SAR文件结构

　　最后一步是部署，这根据SIP应用服务器的不同而不同。通常需要将SAR文件复制到一个部署文件夹中，然后部署应用程序。

　　下面的Ant脚本可以帮助部署：

<projectname="ChatRoomServer"default="build"basedir=".">


<!--Changethistospecifythenameofthechatroom.Inorderto

sendmessagestothischatroom,simplydeployjust4fun.sar,and

usetheaddresssip:just4fun@10.0.2.5060:5060.-->

<propertyname="chatroomname"value="just4fun"/>


<!--ChangethistotheaddressandportoftheSIPserver.-->

<propertyname="serveraddress"value="10.0.2.69:5060"/>


<!--ChangethistothelocationoftheSARdeploymentfolder.-->

<propertyname="sar.deployment"value=""/>


<propertyname="src"value="${basedir}/src"/>

<propertyname="lib"value="${basedir}/lib"/>

<propertyname="tmp"value="${basedir}/tmp"/>


<pathid="classpath">

<filesetdir="${lib}"/>

</path>


<targetname="build">

<mkdirdir="${tmp}"/>

<mkdirdir="${tmp}/WEB-INF"/>

<mkdirdir="${tmp}/WEB-INF/classes"/>

<mkdirdir="${tmp}/WEB-INF/lib"/>

<javacdebug="true"srcdir="${src}"destdir="${tmp}/WEB-INF/classes">

<classpathrefid="classpath"/>

</javac>

<copytodir="${tmp}/WEB-INF"file="${basedir}/sip.xml"/>

<replacefile="${tmp}/WEB-INF/sip.xml"token="chatroomname"value="${chatroomname}"></replace>

<replacefile="${tmp}/WEB-INF/sip.xml"token="serveraddress"value="${serveraddress}"></replace>

<zipdestfile="${basedir}/${chatroomname}.sar">

<zipfilesetdir="${tmp}"/>

</zip>

<copyfile="${basedir}/${chatroomname}.sar"todir="${sar.deployment}"/>

</target>


</project>

结果
　　聊天室应用程序运行之后，试着通过运行两个TextClient实例来访问它。要确保运行在同一机器上的SIP应用程序使用的是不同的端口。下面的例子显示了运行在同一机器上的3个应用程序：

·
运行在ChatRoomServer上的SIP应用服务器，地址是sip:just4fun@10.0.2.69:5060。

·
地址为sip:snoopy71@10.0.2.69:5061的Text
client。

·
地址为sip:maria119@10.0.2.69:5062的Text
client。

　　图3显示了结果。

图3.TextClient与ChatRoomServer交互

复杂应用程序
　　我知道本文中的例子相对于我们通常要构建的应用程序来说有点过于简单了，现实中的大多数SIP应用程序都由大量代码组成。

　　会话和状态：通常，SIP应用程序是一个状态机(statemachine)，其中呼叫或会话都是长时间保持的（有状态的），直到断开。对于SIPservlet，呼叫是由SipApplicationSession表示的，它可以带属性（状态）。在呼叫中，每个会话（呼叫的分支）由SipApplicationSession中的SipSession表示。（两人间的back-to-back会话要使用一个SipApplicationSession和两个SipSession。会议呼叫可能包含更多的SipSession。这些都可以带属性。容器会根据消息的上下文自动提供相应的会话对象。

　　分层设计：最糟糕的是将所有的代码放入单个的大型SIPservlet。应该按照相对独立的层来设计复杂的应用程序。一个明显的层就是包括连接池的数据库层。也可以包含一个与SIP信令分离的业务逻辑层。另一个方面是有效负载分析，它应该被构建为一个可重用的层。

　　其他技术：存在许多先进的SIPservlet技术，包括请求代理、重定向和循环、会话超时管理、身份验证、国际化、TCP支持、计时器、会话监听程序以及错误管理。很明显，本文并没有涵盖所有这些方面，但是您可以在SIPServlet规范中找到相关内容。

　　例子：可以参见“参考资料”部分，其中有可以帮助您了解更复杂的SIP编程的例子。

结束语
　　标准促进了互操作性，从而促进了协作。而协作——不管它是用于朋友间的轻松聊天，还是用于重要的文件传输——都是一件好事。

　　SIP是一个大有前途的电信标准，而SIPServletAPI则是轻松快速地开发服务器端SIP应用程序的极佳方式。在本文中，我们通过一个简单的例子，概述了SIPservlet编程。希望通过本文，能够帮助您在协作的道路上迈出一大步。

下载
·
TextClient应用程序

·
ChatRoomServer应用程序

参考资料
·
JAINSIPServletAPI

·
SIPServletDeveloper'sHomepage——包括大量信息以及SIP
servlet的例子

·
SIP:Creatingnext-generation
telecomapplications——对SIP的简介，以及一个示例SIP
servlet

·
SIPServletIntroduction&
SampleApplication白皮书（需要填写表单才能阅读白皮书）

原文出处:http://dev2dev.bea.com/pub/a/2006/02/sip-servlet.html

作者简介

EmmanuelProulx是一位J2EE和EnterpriseJavaBeans方面的专家，也是一位获得认证的WebLogicServer7.0工程师

一些和sip协议相关的FAQ
http://blog.csdn.net/IOKE/archive/2004/09/21/112030.aspx