基于TR-069 协议的开发(一) ACS的搭建.doc

TR 069是DSL Fourm提出来的一种协议，即CWMP协议，主要是对 用户终端设备的管理。其功能主要有两块组成ACS(Auto Config Server)和CPE(Customer Pression Equalment)。其具体功能(PPT) 根据协议的描述 CPE会定时呼叫ACS,ACS也可以呼叫CPE。ACS呼叫CPE的时候，其实是向CPE发送一个ConnectionRequest,经过授权认证等过程后，CPE会发个Inform给ACS,其中包含了EventCode，根据EnventCode我们就可已知道是CPE主动呼叫的,还是ACS呼叫后，CPE才建立的连接。TR-069规定响应ACS的呼叫后的Inform Event Code是6 Connection Request。 我也是第一次进行通信方面的开发，以前没有接触过的东西。首先得要下个协议，在这里我有个感受，就是要下个原版的TR-069协议，自己去慢慢的理解，不懂单词要查，虽然是全英文的，但是也是最权威的，也是原滋原味的。 可能看了协议后会觉得很蒙，很多代名词都不懂。SOAP,RPC。SOAP和PRC感觉有点像WebService,其实我也没有webservice的开发经验，但是我觉得在TR-069协议中，ACS 通过SOAP协议指定要调用CPE的哪些方法，以及需要的参数。然后通过RPC在CPE端执行指定的方法，返回方法执行后的结果。然后在通过SOAP协议返回执行后的结果给CPE。 假如A系统有个查询手机号码的归属地的功能，那么B系统中也要实现这个功能，那么两个系统可以通过通信的方式进行数据交互。B系统通过SOAP协议指定需要执行的功能（方法）和参数（手机号码），然后发送给A系统。A系统接受了SOAP协议包含的XML，开始解析，然后调用自身的method，然后将执行后的结果封装成XML 格式的数据后发给B系统，B系统解析后获取执行的结果。总之，最重要的是通信。 ACS和CPE都是支持HTTP协议，所有ACS只需要有HTTP容器就可以了。所以很自然的，我们就想到了Servlet来实现。我也不知道是啥格式的XML,但是公司催的紧，所有赶紧开工了。既然不知道怎么实现，但是CPE会定时呼叫的，所有先把它呼叫后的东西接收过来看看，到底是什么。 目前测试的CPE是H3C的AP。第一，创建ACSServlet,准备接收消息。代码如下： Java代码 1 import java.io.BufferedReader; 2 import java.io.IOException; 3 import java.io.InputStream; 4 import java.io.InputStreamReader; 5 import java.io.OutputStream; 6 import java.util.HashMap; 7 import javax.servlet.ServletException; 8 import javax.servlet.http.HttpServlet; 9 import javax.servlet.http.HttpServletRequest; 10 import javax.servlet.http.HttpServletResponse; 11 import javax.servlet.http.HttpSession; 12 import com.seahigh.tyt.acs.util.AcsUtil; 13 /* 14 * ACS serverImp 15 * 16 * author 汪心利 17 * Create Time 2009-1-4下午04:34:42 (c)copy right seahigh 2009 18 */ 19 public class ACSServlet extends HttpServlet 20 21 private static final long serialVersionUID = 1L; 22 23 public void doGet(HttpServletRequest request, HttpServletResponse response) 24 throws ServletException 25 26 27 public void doPost(HttpServletRequest request, HttpServletResponse response) 28 throws ServletException, IOException 29 / session 记住已执行的method 30 31 InputStream in = request.getInputStream(); 32 String ip = request.getRemoteAddr(); 33 InputStreamReader ir = new InputStreamReader(request.getInputStream(); 34 BufferedReader input = new BufferedReader(ir); 35 String line; 36 String xml = ; 37 while (line = input.readLine() != null) 38 if (line.trim().length() = 0) 39 continue; 40 xml += line; 41 42 in.close(); 43 input.close(); 44 System.out.println(ip+Post:+xml); 45 46 47 然后在web.xml中配置Servlet了Xml代码 1 2 3 4 5 This is the description of my J2EE component 6 7 8 This is the display name of my J2EE component 9 ACS 10 com.seahigh.ACS 11 ACS 12 /acs/* 13 index.jsp 14 一个TR-069的模拟器,原理就是用HttpClient模拟TR-069的Client端,发送SOAP Message到ACS Server. 发送SOAP Message的代码如下: Java代码 1 public class MessageSender 2 /* 3 * Logger for this class 4 */ 5 private static final Log logger = LogFactory.getLog(MessageSender.class); 6 private HttpClient httpClient; 7 private PostMethod postMethod; 8 private MessageFactory messageFactory; 9 private String url; 10 private NameValuePair sessionId; 11 12 public MessageSender(String ip) 13 this.httpClient = new HttpClient(); 14 try 15 this.messageFactory = MessageFactory.newInstance(); 16 catch (SOAPException e) 17 logger.error(e.getMessage(); 18 19 this.url = generateRequestUrl(ip); 20 21 22 private String generateRequestUrl(String ip) 23 return http:/ + ip + :8080/vantage/TR069; 24 25 26 public SOAPMessage sendMessage(SOAPMessage input) throws IOException, SOAPException 27 this.postMethod = new PostMethod(this.url); 28 byte dataAsBytes = null; 29 if (input = null) 30 logger.debug(Send a empty post); 31 dataAsBytes = new byte0; 32 else 33 ByteArrayOutputStream data = new ByteArrayOutputStream(); 34 input.writeTo(data); 35 dataAsBytes = data.toByteArray(); 36 37 RequestEntity entity = new ByteArrayRequestEntity(dataAsBytes); 38 this.postMethod.setRequestEntity(entity); 39 if (this.sessionId != null) 40 this.postMethod.addParameter(this.sessionId); 41 42 this.httpClient.executeMethod(this.postMethod); 43 sessionId = this.postMethod.getParameter(SessionID); 44 InputStream in = this.postMethod.getResponseBodyAsStream(); 45 if (null = in) 46 return null; 47 48 return this.messageFactory.createMessage(null, in); 49 50 最初的code里面,只有一个PostMet