zoukankan      html  css  js  c++  java
  • 消息队列理解笔记

    消息队列解决的是将突发大量请求转换为后端能承受的队列请求,比如你的服务器一秒能处理100个订单,但秒杀活动1秒进来1000个订单,持续10秒,在后端能力无法增加的情况下,你可以用消息队列将总共10000个请求压在队列里,后台consumer按原有能力处理,100秒后处理完所有请求(而不是直接宕机丢失订单数据)

    所谓队列,就是按照队首先出的规则建立的数据结构,消息队列就是根据消息到来后按照一定的规则进行排序,但一定是队首的消息先得到应答的队列。
    比如:

    public static String do_post(String url, List<NameValuePair> name_value_pair) throws IOException {
    String body = "{}";
    DefaultHttpClient httpclient = new DefaultHttpClient();
    try {
    HttpPost httpost = new HttpPost(url);
    httpost.setEntity(new UrlEncodedFormEntity(name_value_pair, StandardCharsets.UTF_8));
    HttpResponse response = httpclient.execute(httpost);
    HttpEntity entity = response.getEntity();
    body = EntityUtils.toString(entity);
    } finally {
    httpclient.getConnectionManager().shutdown();
    }
    return body;
    }
    public static String do_get(String url) throws ClientProtocolException, IOException {
    String body = "{}";
    DefaultHttpClient httpclient = new DefaultHttpClient();
    try {
    HttpGet httpget = new HttpGet(url);
    HttpResponse response = httpclient.execute(httpget);
    HttpEntity entity = response.getEntity();
    body = EntityUtils.toString(entity);
    } finally {
    httpclient.getConnectionManager().shutdown();
    }
    return body;
    }

  • 相关阅读:
    vue-cli的使用
    修饰模式(Decorator结构型)C#简单例子
    c#继承中的函数调用
    c#桥接模式(bridge结构模式)
    c#浅谈反射内存的处理
    C#中的try catch finally
    C#微信公众号开发系列教程(接收事件推送与消息排重)
    用 C# 读取二进制文件
    c#语言-多线程中的锁系统(一)
    .NET程序内,访问私有或者保护成员的技巧
  • 原文地址:https://www.cnblogs.com/huangwentian/p/6896990.html
Copyright © 2011-2022 走看看