【Microsoft Azure学习之旅】消息服务Service Bus的学习笔记及Demo示例

 1 //create a topic in name space
 2 public void Create(TopicInfo topic){
 3     System.out.println("=>CreateTopic");
 4     try{
 5         if(!IsAlreadyExist(topic)){
 6             CreateTopicResult result = service.createTopic(topic);
 7             System.out.println("Create Topic Result: " + result.toString());
 8         }
 9         else{
10             System.out.println("This Topic already exist, doesn‘t need to create");
11         }
12     }
13     catch (ServiceException e){
14         System.out.println("ServiceException encountered: " + e.getMessage());
15     }
16     System.out.println("<=CreateTopic");
17 }
18 
19 //send message to a topic
20 public void SendMessage(TopicInfo topic){
21     System.out.println("=>SendMessage");
22     try{
23         BrokeredMessage msg = new BrokeredMessage("testMsg");
24         
25         //set one property to this msg
26         msg.setProperty("testProperty", "kevin01");
27         
28         service.sendTopicMessage(topic.getPath(), msg);
29     }
30     catch (ServiceException e){
31         System.out.println("ServiceException encountered: " + e.getMessage());
32     }
33     System.out.println("<=SendMessage");
34 }

 1 //create a subscription in name space
 2 public void Create(TopicInfo topic, SubscriptionInfo sub){
 3        System. out.println("=>CreateSubscription" );
 4        try{
 5           System. out.println("Topic Info: " + topic .getPath().toString());
 6          
 7           if(!IsAlreadyExist(topic , sub )){
 8              CreateSubscriptionResult result = service.createSubscription(topic .getPath(), sub);
 9               //and we can create a rule for this topic/subscription
10               //RuleInfo rule = new RuleInfo();
11              System. out.println("Create Subscription Result: " + result.toString());
12           }
13           else{
14              System. out.println("This subscription already exist. No need to create");
15           }
16       }
17        catch (ServiceException e ){
18           System. out.println("ServiceException encountered: " + e.getMessage());
19       }
20       System. out.println("<=CreateSubscription" );
21 }
22 
23 
24 //receive message from subscription
25 public void ReceiveMessage(TopicInfo topic, SubscriptionInfo sub){
26       System. out.println("=>ReceiveMessage" );
27       ReceiveMessageOptions opts = ReceiveMessageOptions. DEFAULT;
28        opts.setReceiveMode(ReceiveMode. PEEK_LOCK);
29        try{
30              ReceiveSubscriptionMessageResult result = service.receiveSubscriptionMessage(topic .getPath(), sub.getName(), opts);
31              
32              BrokeredMessage msg = result.getValue();
33              
34               if(msg != null && msg.getMessageId() != null){
35                     //print the message info
36                    System. out.println("Body: " + msg .toString());
37                    System. out.println("Message ID: " + msg.getMessageId());
38                    
39                    System. out.println("Custom Property Value: " + msg.getProperty("testProperty" ));
40                    
41                     //delete this message
42                     service.deleteMessage( msg);
43              }
44               else{
45                    System. out.println("There‘s no message in this subscription. Topic: " + topic.getPath() + ", Subscription: " + sub .getName());
46              }
47       }
48        catch (ServiceException e ){
49           System. out.println("ServiceException encountered: " + e.getMessage());
50       }
51       System. out.println("<=ReceiveMessage" );
52 }

 1 //test topic/subscription
 2 public static void main(String[] args){
 3     //create a topic, and send a message to this topic
 4     ServiceBusTopicHandler topicHandler = new ServiceBusTopicHandler();
 5     TopicInfo topic = new TopicInfo("testtopic");
 6     topicHandler.Create(topic);
 7     topicHandler.SendMessage(topic);
 8     
 9     //create a subscription about this topic, and receive message from this subscription
10     ServiceBusSubscriptionHandler subHandler = new ServiceBusSubscriptionHandler();
11     SubscriptionInfo sub = new SubscriptionInfo("testsubscription");
12     subHandler.Create(topic, sub);
13     
14     while(true){
15         subHandler.ReceiveMessage(topic, sub);
16     }
17 }