zhaoyahui_666的博客

原创 Dependency ‘io.spring.platform:platform-bom:Cario-SR7‘ not found

加上后，发现还是不行。检查maven配置也没有问题。idea使用的是2020.3.3版本，更换为2020.1.1版本后，问题解决了。那么必然是idea的问题了。

原创 spring-cloud gateway 自定义滑动窗口限流

【代码】spring-cloud gateway 自定义滑动窗口限流。

原创 java.nio.charset.MalformedInputException: Input length = 1

java.nio.charset.MalformedInputException: Input length = 1

原创 maven导入本地jar包

maven导入本地jar

原创 Apple Store Openapi Token生成

Apple Store Review拉取

原创 c#格式化json string

c#格式化json string

原创 获取ip接口

获取ip

原创 curl 显示响应状态码

curl 显示响应状态码

原创 Consul Manager解决consul ui权限问题

源码地址consul ui没有访问权限，所有人都可以修改key/value，不安全。所以，发现了Consul Manager这个开源的dashboard可以通过权限管理，还可以为不同的角色设置的不同的权限。

原创 c# mongodb insert 忽略Null参数入库

using MongoDB.Bson;using MongoDB.Bson.Serialization.Conventions;using MongoDB.Driver;string age = null;var document = new{ name = "添加到mongodb", age = age,};MongoClientSettings settings= MongoClientSettings.FromConnectionString("mongodb://.

原创 Postman测试Rpc

原创 rabbitmq交换器类型

fanout它会把所有发送到该交换器的消息路由到所有与该交换器绑定的队列中direct它会把消息路由到那些BingingKey 和RoutingKey完全匹配的队列中topic和direct类似，比其更灵活，支持通配符匹配

原创 java执行linux命令

private void exeCommand(String command){ try { String[] cmd = new String[]{"sh","-c",command}; Process process = Runtime.getRuntime().exec(cmd); BufferedInputStream bis = new BufferedInputStream( .

原创 linux比较两个文件的差异

diff 文件1路径 文件2路径 > 差异文件路径

原创 go注册到consul

package coreimport ( "log" consulapi "github.com/hashicorp/consul/api")func RegService() { config := consulapi.DefaultConfig() config.Address = "127.0.0.1:8500" //consul地址 reg := consulapi.AgentServiceRegistration{} reg.Name = "ilocal-golang-s.

原创 go创建web项目

https://github.com/gin-gonic/gin

原创 jestClient增删改查

import com.alibaba.fastjson.JSON;import io.searchbox.client.JestClient;import io.searchbox.client.JestClientFactory;import io.searchbox.client.JestResult;import io.searchbox.client.config.HttpClientConfig;import io.searchbox.core.Bulk;import io.sear.

原创 jestClient实时操作数据后实时刷新到各分片

Index index = new Index.Builder(user).index(TABLE_NAME).type(TYPE).id(UUIDUtils.getUUID()).refresh(true).build();//refresh设置为true

原创 Gson解析日期字段报错

报错的原因：1.查到的字段值是时间戳，而接收类型是date；2.查到的字段值是时间戳（毫秒），而gson默认转换秒值；可以通过自行对日期进行反序列化，兼容解析各种日期格式：import com.google.gson.JsonDeserializationContext;import com.google.gson.JsonDeserializer;import com.google.gson.JsonElement;import com.google.gson.JsonParseE

原创 JSON.toJSONString日期类型继续保存成date

JSON.toJSONString(obj);//会将date变成时间戳。JSON.toJSONStringWithDateFormat(obj,"yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");//继续保存为时间戳

原创 jest scan cursor all

import org.apache.commons.lang3.StringUtils;import redis.clients.jedis.Jedis;import redis.clients.jedis.ScanParams;import redis.clients.jedis.ScanResult;import redis.clients.jedis.Tuple;import java.util.ArrayList;import java.util.List;public clas.

原创 go操作elasticsearch

package mainimport ( "context" "fmt" "log" "os" "reflect" "github.com/olivere/elastic/v7")var client *elastic.Clientvar host = "http://127.0.0.1:9200/"type Employee struct { FirstName string `json:"first_name"` LastName string `json:".

原创 go操作redis

package mainimport ( "fmt" "github.com/garyburd/redigo/redis")func main() { c, err := redis.Dial("tcp", "localhost:6379") if err != nil { fmt.Println("conn redis failed,", err) defer c.Close() return } fmt.

原创 go操作mysql

package mainimport ( "fmt" _ "github.com/go-sql-driver/mysql" "github.com/jmoiron/sqlx")type Person struct { Id int `db:"id"` Name string `db:"name"` Age string `db:"age"`}var Db *sqlx.DBfunc init() { databa.

原创 go mod

mkdir hellocd hellogo mod init hello

原创 Questdb安装

#拉取镜像docker pull questdb/questdb#后台运行docker run -d -p 9000:9000 questdb/questdb

原创 .net core 将list＜string＞转成字符串，并添加引号

List<string> list=new();list.Add("xx1");list.Add("xx2");//第一种var mailStr = "";foreach (var mail in list){ mailStr += "'" + mail.ToString() + "'" + ",";}mailStr = mailStr[0..^1];Console.WriteLine(mailStr);//第二种Console.WriteLine(strin.

原创 python操作clickhouse

第一种方式import requestsSSL_VERIFY = Falsehost = 'http://127.0.0.1:8123'db = '数据库名称'table = '表名'#插入query_dict = { 'query': "insert into 数据库名称.表名(api,param,create_time,time) values('python-api','参数',now(),11)"}#查询query_dict = { 'query':

原创 python上传文件

# -*- coding: UTF-8 -*-from flask import Flask,request,Responseapp = Flask(__name__) @app.route('/upload', methods=['GET', 'POST'])def upload_file(): f = request.files['file'] f.save('/temp/{}'.format(f.filename)) return 'success'if __.

原创 python下载文件

from flask import Flask,request,Responseapp = Flask(__name__)@app.route('/', methods=["GET"])def download(): file = request.args.get("file", 0) f = open(file,'r') data = f.read() f.close() return Response(data, content_type='appl.

原创 pyhton请求接口

安装pip install requests请求import requests#GETres = requests.get("http://10.0.20.22:9999/actuator/health")print(res.text)#POSTurl = "api地址"jsonParam = { "pageIndex":1, "pageSize":10}headers={ "Authorization":"MDNlNTQwMjNhOGFmNzdj

原创 python操作elasticsearch

安装pip install elasticsearch pip install elasticsearch[async] #支持异步插入from elasticsearch import Elasticsearchfrom elasticsearch import AsyncElasticsearchesClient = Elasticsearch(hosts="127.0.0.1",port=9200)esClient.index(index="indexName",doc

原创 python操作mongodb

安装pip install pymongo插入#!/usr/bin/python3 import pymongomyclient = pymongo.MongoClient('mongodb://账号:密码@ip:27017/')mydb = myclient["dbname"]coll = mydb["collectName"]record={ 'name':'hello', 'age':22}id=coll.insert_one(record)prin

原创 python操作mysql

安装pip install pymysql插入import pymysqlconn = pymysql.connect(host='10.0.20.9',user="root",passwd="GCFSlfyZIvxxs",db="go2global")cursor=conn.cursor()cursor.execute('insert into Person (Name,Age) values (\"{}\",{})'.format('你是谁',33))cursor.close()

原创 python读取文件中的数据

方式1f = open('文件路径','r', encoding="utf-8")data = f.read()f.close()方式2data = os.system('type {}'.format('文件路径'))

原创 python flask提供API

安装flaskpipe install flask编码# -*- coding: UTF-8 -*-from flask import Flask,requestapp = Flask(__name__)@app.route('/get', methods=["GET"])def get(): name= request.args.get("name", 0) return nameif __name__ == '__main__': app

原创 python操作redis

import redisredisClient=redis.StrictRedis(host='127.0.0.1',port=6379,db=0)redisClient.set('hello','world 20211224')redisClient.expire('hello',1000*60)v = redisClient.get('hello')print(v)

原创 viso studio添加NuGet程序包源

原创 jestClient查询count

import io.searchbox.client.JestClient;import io.searchbox.client.JestClientFactory;import io.searchbox.client.config.HttpClientConfig;import io.searchbox.core.Count;import io.searchbox.core.CountResult;import org.elasticsearch.index.query.BoolQueryBu.

原创 .net core api传参方式

1.bodyusing Microsoft.AspNetCore.Mvc;namespace myweb.Controllers{ [Route("api/[controller]/[action]")] [ApiController] public class MyController : ControllerBase { [HttpPost] public object Method1([FromBody] Model mode