一次机房停电引发的思考今天早上到公司的时候,接到开发反馈DEV环境所有接口都卡,耗时都在一分钟以上,严重影响开发正常工作,然后通过网关的日志定位到原因是因为kafka集群不可用(总共3个broker,前一天晚上机房停电导致leader节点挂了),导致网关的反爬过滤器里面发送kafka消息的代码kafkaTemplat.send阻塞了60s,当时在想这个send方法不是异步的吗,为什么会阻塞60s?
分类:
其他好文 时间:
2020-07-31 01:13:59
阅读次数:
93
一、greenlet模块 如果我们在单个线程内有20个任务,要想实现在多个任务之间切换,使用yield生成器的方式过于麻烦(需要先得到初始化一次的生成器,然后再调用send。。。非常麻烦),而使用greenlet模块可以非常简单地实现这20个任务直接的切换。 from greenlet import ...
分类:
其他好文 时间:
2020-07-30 14:50:03
阅读次数:
64
from selenium import webdriver options = webdriver.ChromeOptions() options.add_argument("--auto-open-devtools-for-tabs") driver = webdriver.Chrome(chr ...
分类:
编程语言 时间:
2020-07-30 14:26:27
阅读次数:
110
1 # #!/usr/bin/python3 2 # -*- coding: utf-8 -*- 3 # @Time : 2020/7/30 9:07 4 # @Author : Gengwu 5 # @FileName: Keys_Option.py 6 # @Software: PyCharm ...
分类:
编程语言 时间:
2020-07-30 10:48:30
阅读次数:
124
Expect脚本批量执行命令 #!/bin/bash cat /root/iplist|while read line do a=($line) expect <<EOF set timeout 3 spawn ssh root@${a[0]} expect { "*yes/no" { send " ...
分类:
其他好文 时间:
2020-07-29 21:53:49
阅读次数:
77
import concurrent import requests; from concurrent.futures import ThreadPoolExecutor import os; import parsel; def send_request(url): header = { "user ...
分类:
编程语言 时间:
2020-07-29 21:35:20
阅读次数:
91
直接代码: 1 public abstract class Mediator { 2 public abstract void send(String message,Colleague coll); 3 } Mediator 1 public class ConcreteMediator exte ...
分类:
其他好文 时间:
2020-07-29 17:31:24
阅读次数:
69
layui.use(['laydate','form','layer'],function(){ var form = layui.form; layer = layui.layer;//end //加载角色列表 loadRoleList(); //取得ID acc_id = localStorag ...
分类:
Web程序 时间:
2020-07-29 14:39:36
阅读次数:
127
背景: 项目开发客服聊天系统,使用socket.io进行开发,前端采用vue-element-admin,后端语言php,项目在本地运行功能正常,但是发布到测试环境的时候,socket的连接一直不成功,可以成功返回socketid,但是请求时并没有将sid作为参数进行请求。 解决过程: 1.首先从s ...
分类:
其他好文 时间:
2020-07-24 16:11:45
阅读次数:
70
集成小米推送服务 这类推送一般官方文档都比较详细,如果想要更加详细的了解建议查看官方文档 官方文档地址:https://dev.mi.com/console/appservice/push.html 在正式开发前需要做一些准备 1、开发者需要登录开发者网站进入推送服务(申请AppID, AppKey ...
分类:
移动开发 时间:
2020-07-24 09:49:38
阅读次数:
142