转：android使用protobuf实现网络订单管理功能

http://my.oschina.net/ikende/blog/159930

在新版本的Beetle.NetPackage开源组件中集成了对Protobuf的支持,在android下可以简单地使用Beetle.NetPackage实现基于Protobuf的TCP通讯数据交互.下详细讲解实现一个网络订单管理功能的过程.

协议定义

既然使用Probobuf进行数据交互,那就需要基于Protobuf制定一系列的通信对象,主要包括数据请求和应答的数据对象格式.在做之前需要把需求整理一下明确一下有那些功能,由于Demo主要是用于介绍一下protobuf在Beetle.NetPackage下的使用所以功能并不复杂包括:订单分页查询和订单明细查看.具体Protobuf定义如下:

1. package ordermanager;
   
2. option java_package = "com.beetle.samples.ordermanager";
   
3. option java_outer_classname = "orderproto";
   
4. 
   
5. message GetEmployee
   
6. {
   
7.         optional string Name=1;
   
8. }
   
9. 
   
10. message GetEmployeeResponse
    
11. {
    
12.         repeated Employee Items=1;
    
13. }
    
14. 
    
15. message Employee
    
16. {
    
17.         optional string ID=1;
    
18.         optional string Name=2;
    
19. }
    
20. 
    
21. message GetCustomer
    
22. {
    
23.         optional string Name=1;
    
24. }
    
25. 
    
26. message GetCustomerResponse
    
27. {
    
28.         repeated Customer Items =1;
    
29. }
    
30. 
    
31. message Customer
    
32. {
    
33.         optional string ID=1;
    
34.         optional string Name=2;
    
35. }
    
36. 
    
37. message Response
    
38. {
    
39.         optional string Error=1;
    
40.         optional string Type =2;
    
41. }
    
42. 
    
43. message OrderSearch
    
44. {
    
45.         optional string        Employee=1;
    
46.         optional int32        PageIndex=2;
    
47.         optional string Customer =3;
    
48.         optional string FromDate =4;
    
49.         optional string ToDate =5;
    
50. }
    
51. message OrderSearchResponse
    
52. {
    
53.         repeated Order        Items =1;
    
54.         optional int32        PageIndex =2;
    
55.         optional int32  Pages =3;
    
56. }
    
57. message Order
    
58. {
    
59.         optional string OrderID=1;
    
60.         optional string Employee =2;
    
61.         optional string Customer =3;
    
62.         optional string OrderDate=4;
    
63.         optional string RequiredDate=5;
    
64.         optional string ShippedDate=6;
    
65.         optional string ShipName=7;
    
66.         optional string ShipAddress=8;
    
67.         optional string ShipCity =9;
    
68.         optional string ShipRegion=10;
    
69. }
    
70. message GetOrderDetail
    
71. {
    
72.         optional string OrderID =1;
    
73. }
    
74. message GetOrderDetailResponse
    
75. {
    
76.         repeated OrderDetail Items =1;
    
77. }
    
78. message OrderDetail
    
79. {
    
80.         optional string OrderID=1;
    
81.         optional string Product=2;
    
82.         optional double UnitPrice=3;
    
83.         optional int32        Quantity=4;
    
84.         optional float        Discount=5;
    
85. }

复制代码

主要制定了订单雇员,客户,订单和订单明细查询的数据交互格式.

通讯定义

Beetle.NetPackage基础通讯都已经封装好了,所以使用起来非常简单,probotuf的注册和创建相应的TCP连接只需要几行代码即可

1. ProtoPackage.Register(orderproto.class);
   
2.         mClient = new NetClient("10.0.2.2", 9088, new ProtoPackage(), this);
   
3.         mClient.Connect();

复制代码

以上代码是注册相关Protobuf对象信息,主要用于Beetle.NetPackage对protobuf进行自动化处理.然后定义一个基于Protobuf解释器的连接对象,交接入到相应IP端口的服务中.

消息接收定义

Beetle.NetPackage提供基础的Controller功能,因此只需要定义相关消息类型的方法即可.

1. public void OnGetOrderDetali(NetClient client, GetOrderDetailResponse e) {
   
2.                 final List details = e.getItemsList();
   
3. 
   
4.                 mHandler.post(new Runnable() {
   
5. 
   
6.                         @Override
   
7.                         public void run() {
   
8.                                 // TODO Auto-generated method stub
   
9.                                 mOrderDetailViewAdapter.clear();
   
10.                                 for (OrderDetail item : details) {
    
11.                                         mOrderDetailViewAdapter.add(item);
    
12.                                 }
    
13.                                 mOrderDetailDialog.show();
    
14.                                 ListView lv = (ListView) mOrderDetailDialog
    
15.                                                 .findViewById(R.id.lstOrderDetail);
    
16.                                 lv.setAdapter(mOrderDetailViewAdapter);
    
17.                         }
    
18.                 });
    
19.         }
    
20. 
    
21.         public void OnGetCustomerResponse(NetClient client, GetCustomerResponse e) {
    
22.                 mCustomers = e.getItemsList();
    
23.         }
    
24. 
    
25.         public void OnGetEmployeeResponse(NetClient client, GetEmployeeResponse e) {
    
26.                 mEmployees = e.getItemsList();
    
27.         }
    
28. 
    
29.         public void OnOrderSearchRespnose(NetClient client, OrderSearchResponse e) {
    
30.                 final List orders = e.getItemsList();
    
31.                 mPages = e.getPages();
    
32.                 mHandler.post(new Runnable() {
    
33. 
    
34.                         @Override
    
35.                         public void run() {
    
36.                                 // TODO Auto-generated method stub
    
37.                                 mOrderViewAdapter.clear();
    
38.                                 for (Order item : orders) {
    
39.                                         mOrderViewAdapter.add(item);
    
40.                                 }
    
41.                                 mOrderViewAdapter.notifyDataSetChanged();
    
42.                         }
    
43.                 });
    
44.         }

复制代码

通过调用以下方法则可以自动切入到相关消息方法中.

1. @Override
   
2.         public void Receive(NetClient client, Object msg) {
   
3.                 Controller.Invoke(this, mClient, msg);
   
4.         }

复制代码

消息发送请求

1. GetCustomer.Builder getcusomer = GetCustomer.newBuilder();
   
2.         mClient.Send(getcusomer.build());
   
3.         GetEmployee.Builder getemployee = GetEmployee.newBuilder();
   
4.         mClient.Send(getemployee.build());

复制代码

功能截图

         

  

         

下载代码： 
Beetle.NetPackage官网： 

原文链接：http://my.oschina.net/ikende/blog/159930