zoukankan      html  css  js  c++  java
  • 多线程进行数据同步

    package com.haiyisoft.base.bc.controller;

    import java.util.HashMap;
    import java.util.Map;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;

    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;

    import com.alibaba.fastjson.JSON;
    import com.haiyisoft.base.config.UrlConfig;
    import com.haiyisoft.base.util.HttpClientUtil;
    import com.haiyisoft.base.vo.ReturnValueVo;
    import com.haiyisoft.cloud.persist.DBTool;
    import com.haiyisoft.cloud.persist.Record;

    @RestController
    @RequestMapping("/thread")
    public class MultipleThreadController {

    @Autowired
    private UrlConfig urlConfig;

    @RequestMapping("/active")
    public void multipleThreads() {

    int nThreads = 5;
    ExecutorService pool = Executors.newFixedThreadPool(nThreads);
    for (int i = 0; i < nThreads; i++) {
    System.out.println(i + "--------ddddddddd");
    final int k = i;
    pool.execute(new Runnable() {
    @Override
    public void run() {
    methodInvoke(k, nThreads);
    }
    });

    }
    // methodInvoke(1, nThreads);

    }

    public void methodInvoke(int i, int nThreads) {

    int offset = 10 * 10 / nThreads;
    // int offset = 500 / nThreads;
    int startIndex = offset * (i) + 1;
    /***
    * 13176928019、13081647555
    * 13326382598
    */

    String sql = "select * from user_info where msisdn in(13326382598) ";
    // + " limit " + startIndex + "," + offset;
    DBTool tool = new DBTool();
    Record[] records = tool.executeQuery(sql, null);
    if (records.length > 0) {
    for (Record record : records) {
    String userId = record.get("USER_ID").toString();
    Map<String, String> map = new HashMap<String, String>();
    map.put("userId", userId);
    map.put("appId", "00011");
    System.out.println("userId:"+userId);
    // String url = "http://114.115.157.109:8002/fsfieldms/ms/userInfo/settleCenterMemberRegister.shtml"; //正式
    String url = "http://114.116.25.98:8002/fsfieldms/ms/userInfo/settleCenterMemberRegister.shtml"; //测试

    // String url =urlConfig.getReturnfeeservice()+"/ms/userInfo/settleCenterMemberRegister.shtml";
    String res = HttpClientUtil.doPost(url, map, "UTF8");
    System.out.println("res:"+res);
    ReturnValueVo vo = JSON.parseObject(res, ReturnValueVo.class);
    if ("0".equals(vo.getStatus()) || "1112".equals(vo.getStatus())) {
    // System.out.println(vo.getObj().toString());
    String updateSQL = "UPDATE USER_INFO SET if_format = 1 WHERE USER_ID = "+userId;
    tool.executeUpdate(updateSQL, null);
    }
    }
    }
    }
    }

  • 相关阅读:
    dedecms 权重排序问题
    HTML5学习笔记简明版(1):HTML5介绍与语法
    通过jquery 获取文本框的聚焦和失焦方法
    14种网页图片和文字特效的jQuery插件代码
    input文本框实现宽度自适应代码实例,input文本框
    html5,html5教程
    css的#和.的区别
    css style与class之间的区别,cssclass
    网页点击按钮弹出遮罩层,拖动和关闭效果
    基于CSS+dIV的网页层,点击后隐藏或显示
  • 原文地址:https://www.cnblogs.com/zhangzhiqin/p/10621147.html
Copyright © 2011-2022 走看看