Mq测试
Mq测试
东门非树 发表于3年前
Mq测试
  • 发表于 3年前
  • 阅读 44
  • 收藏 1
  • 点赞 0
  • 评论 0

【腾讯云】如何购买服务器最划算?>>>   

摘要: 项目使用Mq推送及时消息

public class MqSubscriberTest extends Thread {
 private Semaphore semaphore = new Semaphore(0);
 ScheduledExecutorService service = Executors.newScheduledThreadPool(100);
 MessageMqSubscriberRunnable listeningTask  = null;
 public static void main(String[] args) {

  try {
   MqSubscriberTest test = new MqSubscriberTest();
   MessageMqSubscriberRunnable listeningTask = new MessageMqSubscriberRunnable();
   test.service.schedule(listeningTask, 1, TimeUnit.SECONDS);
   test.start();
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  } //启动服务器  
  
 }

 public MqSubscriberTest() throws IOException {
  //rverSocket = new ServerSocket(port);
  System.out.println("ComServer Start");
 }
 public void run(){
  try {
   this.semaphore.acquire();
  } catch (InterruptedException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
  }
}

共有 人打赏支持
粉丝 0
博文 10
码字总数 4040
×
东门非树
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: