使用https 双向验证
代码应该系酱:
```
import ssl
import aiohttp
sslcontext = ssl.create_default_context(cafile='/path_to_client_root_ca')
sslcontext.load_cert_chain(certfile=cert_file, keyfile=client_key)
conn = aiohttp.TCPConnector(ssl_context=sslcontext)
async with aiohttp.ClientSession(connector=conn) as session:
pass
```
尚未测试。等待使用。
使用
session
async with aiohttp.ClientSession() as session:
async with session.get('https://api.github.com/events') as resp:
print(resp.status)
print(await resp.text())
简单使用
async with aiohttp.request('GET', 'https://api.github.com/events') as resp:
[查看更多...]

来自 大脸猫 发送于 2018-01-26 12:13 - 0 条评论

哈哈。pb是个好东西。用http请求,则更棒棒。直接上代码:
```python
async def call_proto_http(url, req):
try:
data = req.SerializeToString()
length = len(data)
except Exception as e:
pass
headers = {'Content-type': 'application/x-protobuf',
'Content-Length': str(length)}
async with aiohttp.ClientSession() as session:
async with session.post(url, timeout=10, data=data, headers=headers) as response:
# logging.debug('post_json url {}, data {}'.format(url, data))
status = response.status
content = await response.read()
logging.debug(
"call_proto_http url:{} [查看更多...]

来自 大脸猪 发送于 2019-09-17 15:10 - 0 条评论

这是内容,这下不会忘记了吧。
超强音形ibus码表
yong-lin-2.3.0-3
erbi
超强二笔输入法x64
用主流输入法打二笔.rar
二笔词典
像我这种2B青年,当然有时记不住码,那就得查词典了。
附:码表
```
import codecs
import sys
argv = sys.argv
input_word = argv[1]
with codecs.open("/Users/yzh/workspace/py_test/erbi.txt") as f:
f_str = f.read()
获得所有词
f_str = f_str.split("\n")
ret = []
for line in f_str:
key = line.split(" ")[0].strip()
words = line.split(" ")[1].strip()
words = words.split(" ")
for word in words:
if word == input_word:
ret.append(key)
print(ret)
```
二笔编码方式# [查看更多...]

来自 大脸猫 发送于 2015-07-01 20:36 - 0 条评论

来自:https://blog.csdn.net/u010230794/article/details/82143179
go
//开箱即用
var sm sync.Map
//store 方法,添加元素
sm.Store(1,"a")
//Load 方法,获得value
if v,ok:=sm.Load(1);ok{
fmt.Println(v)
}
//LoadOrStore方法,获取或者保存
//参数是一对key:value,如果该key存在且没有被标记删除则返回原先的value(不更新)和true;不存在则store,返回该value 和false
if vv,ok:=sm.LoadOrStore(1,"c");ok{
fmt.Println(vv)
}
if vv,ok:=sm.LoadOrStore(2,"c");!ok{
fmt.Println(vv)
}
//遍历该map,参数是个函数,该函数参的两个参数是遍历获得的key和value,返回一个bool值,当返回false时,遍历立刻结束。
sm.Range(func(k,v interface{})bool{
fmt.Print(k)
fmt.Print(":")
fmt.Print(v)
fmt.Println()
return true
})#br [查看更多...]

来自 大脸猪 发送于 2019-08-16 14:41 - 0 条评论

调试工具操作
```console
- 启动
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties
列出topicc
./kafka-topics.sh --zookeeper 9.43.186.132:2181,9.43.186.152:2181,9.43.186.176:2181 --list
创建topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --topic test --partitions 1 --replication-factor 1
查看topic的状态
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
消费者 读数据
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning --group superpig
生产者
bin/kafka- [查看更多...]

来自 大脸猫 发送于 2019-04-13 10:49 - 0 条评论

有时,在确保group当前没有consumer的情况下,可以将这个group的偏移设置成最新,以保证下次启动时,group能从最新的消息消费。
代码:
```go
func initKafka() (err error) {
defer checkerr.MarkPanic(&err)
topics := []string{"hello"}
groupId := "superpig"
addr := []string{"127.0.0.1:9092"}
client, err := sarama.NewClient(addr, nil)
checkerr.CheckError(err)
partionIds, err := client.Partitions(topics[0])
checkerr.CheckError(err)
defer client.Close()
time.Sleep(time.Second)
config := cluster.NewConfig()
config.Consumer.Return.Errors = true
config.Group.Return.Notifications = true
config.Version = sarama.V2_0_0_0
config.Consumer.Offsets.Initi [查看更多...]

来自 大脸猪 发送于 2019-08-26 19:44 - 0 条评论

下载安装包
wget https://dl.google.com/go/go1.12.7.linux-amd64.tar.gz
解压
tar -zxvf go1.12.7.linux-amd64.tar.gz
mv go /home/
mkdir /home/gopath -p
设置环境变量,最好添加到bashrc中
export GOROOT=/home/go/
export PATH=$PATH:/home/go/bin/
export GO111MODULE=on
export GOPATH=/home/gopath
[查看更多...]

来自 大脸猪 发送于 2019-07-19 16:21 - 0 条评论

这个问题很难弄。还会影响到python的系统函数os.stat等。
解决方法如下:
执行命令:
bash
apt-get install -y locales
locale-gen en_US.UTF-8
修改配置文件:
```bash
vim ~/.bashrc
写入
export PYTHONIOENCODING=utf-8
export LANG='en_US.UTF-8'
export LC_ALL='en_US.UTF-8'
```
[查看更多...]

来自 大脸猪 发送于 2017-01-03 01:43 - 0 条评论

显示规则
iptables -L
iptables -t nat -L
设置端口白名单
```
仅允许22, 80 端口访问
iptables -A INPUT -p tcp --dport 22 -j ACCEPT
iptables -A OUTPUT -p tcp --sport 22 -j ACCEPT
iptables -A INPUT -p tcp --dport 80 -m state --state NEW,ESTABLISHED -j ACCEPT
iptables -A OUTPUT -p tcp --sport 80 -m state --state NEW,ESTABLISHED -j ACCEPT
取消其它端口访问
iptables -P INPUT DROP
```
阻止一个端口访问
iptables -A INPUT -p tcp --dport 4003 -j DROP
允许一个ip/mac访问
```
iptables -A INPUT -s 192.168.0.3 -p tcp --dport 22 -j ACCEPT
iptables -I INPUT 1 -p tcp --destination-port 4003 -m mac --mac-source 52:54:ff:00:03:03 -j ACCEPT
```
# [查看更多...]

来自 大脸猪 发送于 2017-01-18 16:11 - 0 条评论