xml复制代码   <dependency>
       <groupId>com.dangdang</groupId>
       <artifactId>sharding-jdbc-core</artifactId>
       <version>1.5.4</version>
   </dependency>

java复制代码@SpringBootApplication(exclude={DataSourceAutoConfiguration.class})

java复制代码@Component
public class DbSharding implements SingleKeyDatabaseShardingAlgorithm<Integer> {

    @Autowired
    private Db0Config db0Config;

    @Autowired
    private Db1Config db1Config;

    @Override
    public String doEqualSharding(Collection<String> availableTargetNames, ShardingValue<Integer> shardingValue) {
        Long value = shardingValue.getValue();
        if (value > 30000) {
            return db0Config.getDatabaseName();
        } else {
            return db1Config.getDatabaseName();
        }
    }

}

java复制代码@Component
public class TbSharding implements SingleKeyTableShardingAlgorithm<Integer> {

    @Override
    public String doEqualSharding(final Collection<String> tableNames, final ShardingValue<Integer> shardingValue) {
        for (String table : tableNames) {
            if (table.endsWith(shardingValue % 2 + "")) {
                return table;
            }
        }
        throw new IllegalArgumentException();
    }

}

复制代码db0
  ├── user_0 
  └── user_1 
db1
  ├── user_0 
  └── user_1

java复制代码@Configuration
public class DataSourceConfig {

    @Autowired
    private Db0Config db0Config;

    @Autowired
    private Db1Config db1Config;

    @Autowired
    private DbSharding  dbSharding;

    @Autowired
    private TbSharding tbSharding;

    @Bean
    public DataSource getDataSource() throws SQLException {
        return buildDataSource();
    }

    private DataSource buildDataSource() throws SQLException {

        Map<String, DataSource> dataSourceMap = new HashMap<>(2);
        //  添加数据源 db0和db1
        dataSourceMap.put(db0Config.getDatabaseName(), db0Config.dataSource());
        dataSourceMap.put(db1Config.getDatabaseName(), db1Config.dataSource());
        // 设置db0为默认源
        DataSourceRule dataSourceRule = new DataSourceRule(dataSourceMap, db0Config.getDatabaseName());

        // 设置分表，将查询虚拟表user根据规则映射到真实表中去
        TableRule userTableRule = TableRule.builder("user")
                .actualTables(Arrays.asList("user_0", "user_1"))
                .dataSourceRule(dataSourceRule)
                .build();

        // 分库分表策略
        ShardingRule shardingRule = ShardingRule.builder()
                .dataSourceRule(dataSourceRule)
                .tableRules(Arrays.asList(userTableRule))
                .databaseShardingStrategy(new DatabaseShardingStrategy("user_id", dbSharding))
                .tableShardingStrategy(new TableShardingStrategy("id", tbSharding)).build();
        DataSource dataSource = ShardingDataSourceFactory.createDataSource(shardingRule);
        return dataSource;
    }


    @Bean
    public KeyGenerator keyGenerator() {
        return new DefaultKeyGenerator();
    }

}

java复制代码@Slf4j
public class TestAIO {
    public static void main(String[] args) throws IOException {
        AsynchronousFileChannel channel = AsynchronousFileChannel.open(Paths.get("data2.txt"), StandardOpenOption.READ);
        ByteBuffer buffer = ByteBuffer.allocate(16);
        log.debug("read begin...");
        channel.read(buffer, 0, buffer, new CompletionHandler<Integer, ByteBuffer>() {
            @Override   //read成功
            public void completed(Integer result, ByteBuffer attachment) {
                log.debug("read complete...{}",result);
                attachment.flip();
                ByteBufferUtil.debugAll(buffer);
            }
            @Override   //read失败
            public void failed(Throwable exc, ByteBuffer attachment) {

            }
        });
        log.debug("read end...");
        System.in.read();
    }
}

xml复制代码<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
    <version>2.2.2.RELEASE</version>
    <scope>compile</scope>
</dependency>

java复制代码@Configuration
public class ConsumerConfig {

    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

}

java复制代码@RestController
public class ConsumerController {

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/index")
    public String index() {
        return "consumer远程调用provier：" + this.restTemplate.getForObject("http://provider/index", String.class);
    }
}

yml复制代码provider:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

java复制代码@Slf4j
public class NacosWeightedRule extends AbstractLoadBalancerRule {

    @Autowired
    private NacosDiscoveryProperties nacosDiscoveryProperties;

    @Override
    public void initWithNiwsConfig(IClientConfig iClientConfig) {
        //读取配置文件
    }

    @Override
    public Server choose(Object o) {
        ILoadBalancer loadBalancer = this.getLoadBalancer();
        BaseLoadBalancer baseLoadBalancer = (BaseLoadBalancer) loadBalancer;
        //获取要请求的微服务名称
        String name = baseLoadBalancer.getName();
        //获取服务发现的相关API
        NamingService namingService = nacosDiscoveryProperties.namingServiceInstance();
        try {
            Instance instance = namingService.selectOneHealthyInstance(name);
            log.info("选择的实例是port={},instance={}",instance.getPort(),instance);
            return new NacosServer(instance);
        } catch (NacosException e) {
            e.printStackTrace();
            return null;
        }
    }
}

bash复制代码49ba59abbe56e057	#16位
e10adc3949ba59abbe56e057f20f883e	# 32位

arduino复制代码HashMap<String, String> hashMap = new HashMap<>();
hashMap.put("test", "test");

vbnet复制代码public V put(K key, V value) {
    return putVal(hash(key), key, value, false, true);
}
static final int hash(Object key) {
    int h;
    return (key == null) ? 0 : (h = key.hashCode()) ^ (h >>> 16);
}

php复制代码<?php
/**
 * PHP实现NBA赛事结果通知即时推送
 */
//设置时区
if (PHP_VERSION >= '5.1') date_default_timezone_set('PRC');

$nba = new Nba();
$nba->run();

class Nba
{
    // 关注的球队列表
    // private $teams = ['洛杉矶湖人', '布鲁克林篮网'];
    private $teams = ['洛杉矶湖人'];

    // 开始执行
    public function run()
    {
        echo "开始监测NBA今日赛程 - ". date("Y-m-d H:i:s") . PHP_EOL;

        // 查询今日NBA比赛清单
        $todayMatchsResult = $this->getMatchResult();
        if ($todayMatchsResult['code'] == '1') {
            // 解析比赛结果，提取需要推送的比赛结果
            $parseMatchsResult = $this->parseMatchs($todayMatchsResult['matchs']);
            if ($parseMatchsResult) {
                $this->pushMsg($parseMatchsResult);
            } else {
                echo "暂无比赛结果需要推送";
            }
        } else {
            // 查询失败
            echo $todayMatchsResult['msg'];
        }
    }

    /**
     * 将需要推送的比赛结果， 通过 聚合云推 推送至邮件、钉钉、微信等
     * 聚合云推官网： https://tui.juhe.cn/?f=nba
     * @param null $msgs
     */
    private function pushMsg($msgs = null)
    {
        // 记录已经推送过的msg文件
        $logFile = dirname(__FILE__).DIRECTORY_SEPARATOR."notify_log.txt";
        $logContent = file_get_contents($logFile);
        $logList = explode("\n", $logContent);

        // 在聚合云推个人中心获取到的token
        $token = "cd513bd*******b7261e566a3";
        // 在聚合云推创建的ServiceID
        $service_id = "1O***Ho";
        // 自定义标题
        $title = "NBA赛事结果";
        $doc_type = "text";

        foreach ($msgs as $m) {
            // 消息内容MD5，简单记录本地文件，用于判断是否已经推送，避免重复 (当然也可以使用数据库、缓存等手段)
            $mHash = md5($m);
            if (in_array($mHash, $logList)) {
                // 重复推送
                echo "{$m}，推送结果：999 - 已经推送过，无需重复推送" . PHP_EOL;
            } else {
                // 开始推送
                $params = [
                    'token' => $token,
                    'service_id' => $service_id,
                    'title' => $title,
                    'doc_type' => $doc_type,
                    'content' => $m
                ];
                $pushResContent = $this->juheHttpRequest('https://tui.juhe.cn/api/plus/pushApi', http_build_query($params), 1);
                $pushRes = json_decode($pushResContent, true);
                echo "{$m}，推送结果：{$pushRes['code']} - {$pushRes['reason']}" . PHP_EOL;

                // 记录log
                file_put_contents($logFile, $mHash, FILE_APPEND);
            }
        }
    }

    /**
     * 解析NBA比赛结果，提取关注的球队比赛结果
     * @param null $matchs
     */
    private function parseMatchs($matchs = null)
    {
        $matchText = null;
        if ($matchs) {
            foreach ($matchs as $m) {
                if (in_array($m['team1'], $this->teams) || in_array($m['team2'], $this->teams)) {
                    // 有关注的球队且完赛
                    if ($m['status'] == '3') {
                        // 整合比赛球队和结果信息
                        $matchText[] = "{$m['team1']} {$m['team1_score']} - {$m['team2_score']} {$m['team2']}";
                    }
                }
            }
        }
        return $matchText;
    }

    /**
     * 查询NBA今日比赛状态
     * 通过聚合提供的接口，接口详情：https://www.juhe.cn/docs/api/id/92?f=nba
     */
    private function getMatchResult()
    {
        // NBA赛事接口地址
        $apiUrl = 'http://apis.juhe.cn/fapig/nba/query';
        // 接口地址请求Key, 自行替换
        $apiKey = '69e76b5*********4b87690c8';
        $params = [
            'key' => $apiKey
        ];
        $requestContent = $this->juheHttpRequest($apiUrl, http_build_query($params));
        $requestResult = json_decode($requestContent, true);
        if ($requestResult) {
            $errorCode = $requestResult['error_code'];
            if ($errorCode == 0) {
                // 请求成功
                $matchs = isset($requestResult['result']['matchs']) ? $requestResult['result']['matchs'] : null;
                if ($matchs) {
                    $todayMatchs = null;
                    foreach ($matchs as $key => $match) {
                        $matchDate = $match['date'];
                        if ($matchDate == date("Y-m-d")) {
                            // 今日比赛列表
                            $todayMatchs = $match['list'];
                            break;
                        }
                    }
                    // 返回比赛列表
                    return ['code' => '1', 'msg' => '请求成功', 'matchs' => $todayMatchs];
                } else {
                    // 无比赛记录
                    return ['code' => '1', 'msg' => '请求成功', 'matchs' => null];
                }
            } else {
                // 请求异常
                return ['code' => '2', 'msg' => '请求异常：' . $errorCode, 'matchs' => null];
            }
        } else {
            // 请求异常，可能网络异常
            return ['code' => '2', 'msg' => '请求异常：网络异常', 'matchs' => null];
        }
    }

    /**
     * 发起网络请求函数
     * @param string $url 请求的URL
     * @param bool $params 请求的参数内容
     * @param int $ispost 是否POST请求
     * @return bool|string 返回内容
     */
    private function juheHttpRequest($url, $params = false, $ispost = 0)
    {
        // $httpInfo = [];
        $ch = curl_init();

        curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
        curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/41.0.2272.118 Safari/537.36');
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 3);
        curl_setopt($ch, CURLOPT_TIMEOUT, 12);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        if ($ispost) {
            curl_setopt($ch, CURLOPT_POST, true);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
            curl_setopt($ch, CURLOPT_URL, $url);
        } else {
            if ($params) {
                curl_setopt($ch, CURLOPT_URL, $url . '?' . $params);
            } else {
                curl_setopt($ch, CURLOPT_URL, $url);
            }
        }
        $response = curl_exec($ch);
        if ($response === FALSE) {
            // echo "cURL Error: ".curl_error($ch);
            return false;
        }
        // $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        // $httpInfo = array_merge($httpInfo, curl_getinfo($ch));
        curl_close($ch);
        return $response;
    }
}

javascript复制代码# 每分钟执行一次
*/1 * * * * /usr/bin/php nba.php >> /data/log.txt

bash复制代码cat /data/log.txt

yaml复制代码洛杉矶湖人 102 - 109 密尔沃基雄鹿，推送结果：200 - success
开始监测NBA今日赛程 - 2021-11-18 18:41:00
洛杉矶湖人 102 - 109 密尔沃基雄鹿，推送结果：999 - 已经推送过，无需重复推送
开始监测NBA今日赛程 - 2021-11-18 18:42:01
洛杉矶湖人 102 - 109 密尔沃基雄鹿，推送结果：999 - 已经推送过，无需重复推送
开始监测NBA今日赛程 - 2021-11-18 18:42:39
洛杉矶湖人 102 - 109 密尔沃基雄鹿，推送结果：999 - 已经推送过，无需重复推送
开始监测NBA今日赛程 - 2021-11-18 18:43:00
洛杉矶湖人 102 - 109 密尔沃基雄鹿，推送结果：999 - 已经推送过，无需重复推送

sql复制代码trim(leading ' ' from str) ==> ltrim(str)
trim(trailing ' ' from str) ==> rtrim(str)

sql复制代码find_in_set(str, strList)

sql复制代码format(N, D, local)

sql复制代码SELECT lcase('AAA');
--> aaa
SELECT ucase('aaa');
--> AAA

sql复制代码SELECT repeat(str, n)

sql复制代码lpad(str, length, repeatStr);
rpad(str, length, repeatStr);

py复制代码li = list(range(7))
print(li)
tu = tuple(range(7))
print(tu)
se = set(range(7))
print(se)

scss复制代码[0, 1, 2, 3, 4, 5, 6]
(0, 1, 2, 3, 4, 5, 6)
{0, 1, 2, 3, 4, 5, 6}

py复制代码li = list(range(7))
tu = tuple(range(7))
se = set(range(7))

print(*li,*tu,*se)

复制代码0 1 2 3 4 5 6 0 1 2 3 4 5 6 0 1 2 3 4 5 6

py复制代码dic = {"name":"sian","name2":"sian"}
a = {'a':0,**dic,'c':1}

print(a)

css复制代码{'a':0,"name":"sian","name2":"sian",'c':1}

py复制代码li = [1,2,3]
a = [1,*li,0]

print(a)

csharp复制代码[1, 1, 2, 3, 0]

py复制代码print(i for i in range(7))

csharp复制代码<generator object <genexpr> at 0x000002502D43A510>

py复制代码li = [i for i in range(7)]
se = {i for i in range(7)}
print(li,se)

csharp复制代码[0, 1, 2, 3, 4, 5, 6] {0, 1, 2, 3, 4, 5, 6}

py复制代码print(*[i for i in range(7)])

复制代码0 1 2 3 4 5 6

py复制代码def function(num,*args):
    print(num)
    print(args)
    print(*args)
    
function(1,2,3,4,5,6,7)
function('a',1,2,3,'b')

css复制代码1
(2, 3, 4, 5, 6, 7)
2 3 4 5 6 7
a
(1, 2, 3, 'b')
1 2 3 b

python复制代码def function(first,*args,last="c"):
    print("first:",first)
    print(args)
    print("last:",last)

function(1,2,3,4,5,6,7)

makefile复制代码first: 1
(2, 3, 4, 5, 6, 7)
last: c

py复制代码def function(first='a',*args):
    print("first:",first)
    print(args)
    
function(1,2,3,4,5,6,7)

makefile复制代码first: 1
(2, 3, 4, 5, 6, 7)

py复制代码def function(first='a',**kwargs):
    print("first:",first)
    print(kwargs)
    
function(1,name = "Sian", age = 25,b=2)

css复制代码first: 1
{'name': 'Sian', 'age': 25, 'b': 2}