docker 之 mysql 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

// mysql
https://hub.docker.com/_/mysql
docker pull mysql

// 运行 mysql 镜像
// --name 容器名字
// -e 为设置执行时的环境变量
// -d 为设置镜像，镜像名:版本
//-p 3306:3306   表示在这个容器中使用3306端口(第二个)映射到本机的端口号也为3306(第一个)

docker run --name first-mysql -p 3306:3306 -e MYSQL_ROOT_PASSWORD=123456 -d mysql:latest 
--default-authentication-plugin=mysql_native_password
--lower_case_table_names=1

其他参数参数说明
--restart=always 跟随docker启动
--privileged=true 容器root用户享有主机root用户权限
-v 映射主机路径到容器
-e MYSQL_ROOT_PASSWORD=root 设置root用户密码
-d 后台启动
--lower_case_table_names=1 设置表名参数名等忽略大小写

// 查看当前所有的数据库
show databases;

进入数据库 bash

1
docker exec -it first-mysql /bin/bash

连接数据库

1
2
3
4
5
mysql -u root -p

ALTER USER 'root'@'localhost' IDENTIFIED WITH mysql_native_password BY 'yourpassword';

flush privileges;

进入我们的容器

1
2
3
4
5
6
7
8
9
// 两种进入容器区别 
1.attach 进入
命令进入container（容器）有一个缺点，那就是每次从container中退出到前台时，container也跟着退出了。 
2.exec -it
退出container时，让container仍然在后台运行着

docker attach <ContainerID>

docker exec -it goofy_almeida /bin/bash

mysql 问题记录

1
2
3
4
5
6
7
8
9
10
11
12
问题1. MySQL said: Authentication plugin 
'caching_sha2_password' cannot be loaded: dlopen(/usr/
local/lib/plugin/caching_sha2_password.so, 2):  解决

// 进入数据库执行
ALTER USER 'root'@'%' IDENTIFIED WITH 
mysql_native_password BY '123456';


问题二.解决MAC电脑Sequel Pro encountered an unexpected error 问题

下载 https://sequelpro.com/test-builds 版本

展开全文 >>

小程序之一些业务上总结

关于小程序登录

UnionID 机制说明

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

如果开发者拥有多个移动应用、网站应用、和公众帐号（包括小程序），可
通过 UnionID 来区分用户的唯一性，因为只要是同一个微信开放平台帐号
下的移动应用、网站应用和公众帐号（包括小程序），用户的 UnionID 是
唯一的。换句话说，同一用户，对同一个微信开放平台下的不同应用，unionid是相同的。

//  获取渠道 (需要申请开发平台 300块哪个)

1.调用接口 wx.getUserInfo，从解密数据中获取 UnionID。注意本接口需要用户授权，请
开发者妥善处理用户拒绝授权后的情况。

2.如果开发者帐号下存在同主体的公众号，并且该用户已经关注了该公众号。开发者可以直接通
过 wx.login + code2Session 获取到该用户 UnionID，无须用户再次授权。

3.如果开发者帐号下存在同主体的公众号或移动应用，并且该用户已经授权登录过该公众号或移
动应用。开发者也可以直接通过 wx.login + code2Session 获取到该用户 UnionID ，无
须用户再次授权。

4.用户在小程序（暂不支持小游戏）中支付完成后，开发者可以直接通过getPaidUnionId接
口获取该用户的 UnionID，无需用户授权。注意：本接口仅在用户支付完成后的5分钟内有效，

请开发者妥善处理。

5.小程序端调用云函数时，如果开发者帐号下存在同主体的公众号，并且该用户已经关注了该公
众号，可在云函数中通过 cloud.getWXContext 获取 UnionID。

6.小程序端调用云函数时，如果开发者帐号下存在同主体的公众号或移动应用，并且该用户已经
授权登录过该公众号或移动应用，也可在云函数中通过 cloud.getWXContext 获取 UnionID。

微信开放平台绑定小程序流程
登录微信开放平台 — 管理中心 — 小程序 — 绑定小程序

关于模版消息关于 formid 获取

1
2
3
4
5
6
7
8
9
10
1. 支付
当用户在小程序内完成过支付行为，可允许开发者向用户在7天内推送有限
条数的模板消息（1次支付可下发3条，多次支付下发条数独立，互相不影
响）

2. 提交表单

当用户在小程序内发生过提交表单行为且该表单声明为要发模板消息的，开
发者需要向用户提供服务时，可允许开发者向用户在7天内推送有限条数的
模板消息（1次提交表单可下发1条，多次提交下发条数独立，相互不影响）

展开全文 >>

java 字符串性能调优

一、String 如何实现

  • Java 1.6 以及以前版本，String 对象对 char 数组进行了封装、 char 数组、 偏移量 offset、字符串个数 count、哈希值。

  • Java 1.7 版本 到 1.8版本 char 数组、哈希值。这样的好处的是 String 对象占用的内存少了。String.substring 方法不再共享 char[] 数据了，解决内存泄漏问题。

  • 从 Java 1.9 版本开始。使用byte[] 字段、coder。节约内存空间

二、String 不可变性

  • 保证 String 对象的安全性。

  • 保证 hash 属性值不会频繁变更，确保了唯一性。

  • 可以实现字符串常量池。

String 对象的优化

  • 构建超大字符串；

    • 显示地使用 StringBuilder。
    • 多线程编程中使用 StringBuffer。

  • 使用 String.intern 节省内存

  • 使用 String.indexOf() 替代 spilt()

展开全文 >>

kotlin 标准常用扩展函数的总结

1.扩展函数本质上并不是对原先的类新增一个方法，它是以静态导入的方式来实现的。

2.扩展函数跟原先的函数重名，并且参数都一样时，扩展函数会失效，调用的依旧是原先的函数。

3.扩展函数不具备多态性。

4.Java 也能调用 Kotlin 的扩展函数，可以把它当成是一个工具类来使用。

kotlin. 常用扩展函数的使用

  • with()

with 是将某个对象作为函数的参数，在函数块内可以通过 this 指代该对象。在函数块内可以直接调用对象的方法或者属性。

在 with 函数中还包含了 contract dsl，它是为编译器提供有关函数行为的附加信息，这有助于分析质量。 后面其他的扩展函数也有 contract dsl，在阅读源代码时可以忽略掉。

  • apply()

apply 函数是指在函数块内可以通过 this 指代该对象，返回值为该对象自己。在链式调用中，我们可以考虑使用它，从而不用破坏链式。

  • also()

also 是 Kotlin 1.1 新增的函数，类似于 apply 的功能。跟 apply 不同的是，also 在函数块内可以通过 it 指代该对象，返回值为该对象自己。

  • run()

run 函数类似于 apply 函数，但是 run 函数返回的是最后一行的值。

  • let()

let 函数把当前对象作为闭包的 it 参数，返回值是函数里面最后一行，或者指定 return。它看起来有点类似于 run 函数。

总结

函数 是否需要返回自己本身 传递参数
apply 是 this
also 是 it
with 否 this
run 否/返回函数最后一行 this
let 否/返回函数最后一行 it

展开全文 >>

Rxjava Disposable Transformer 的使用

一、Disposable

取消订阅 接口

Rxjava 1.x: Subscription

Rxjava 2.x: Disposable

二、Transformer(转换器) 在 Rxjava 中的使用

Transformer 能够将一个 Observable/Flowable/Single/Completable/Maybe 对象转换成另一个 Observable/Flowable/Single/Completable/Maybe 对象，与调用一系列的内联操作符一摸一样。

三、与 compose 操作符结合使用

compose 操作符能够从数据流中得到与原始的被观察者。当创建观察者是，compose操作符会立即执行，而不像其他的操作符需要在 onNext() 调用后才能执行。

展开全文 >>

Rxjava 背压

一、什么是背压

指在异步的情况下，被观察者发送事件速度远快于观察者处理的速度，从而导致下游的 buffer 溢出，这种情况叫做背压。

二、Rxjava 1.x背压策略

缓存池只有16

1.过滤限流
2.打包缓存
3.使用背压操作符

三、Rxjava 2.x背压策略

使用 Flowbale 支持背压，默认队列大小为 128，并且要求所有操作符强制支持背压。

5种背压策略。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

public enum BackpressureStrategy {
    /**
     * OnNext events are written without any buffering or dropping.
     * Downstream has to deal with any overflow.
     * <p>Useful when one applies one of the custom-parameter onBackpressureXXX operators.
     */
    MISSING,
    /**
     * Signals a MissingBackpressureException in case the downstream can't keep up.
     */
    ERROR,
    /**
     * Buffers <em>all</em> onNext values until the downstream consumes it.
     */
    BUFFER,
    /**
     * Drops the most recent onNext value if the downstream can't keep up.
     */
    DROP,
    /**
     * Keeps only the latest onNext value, overwriting any previous value if the
     * downstream can't keep up.
     */
    LATEST
}

1.MISSING

表示通过 Create 方法创建的 Flowable 没有指定背压策略，不会对通过 OnNext 发射的数据做缓存或丢弃处理，需要下游通过背压操作符(onBackpressureDrop()、onBackpressureLatest()、onBackpressureBuffer())指定背压策略。

2.ERROR

表示如果放入 Flowable 的一部缓存池中的数据超限了，则会抛出
Caused by: io.reactivex.exceptions.MissingBackpressureException: create: could not emit value due to lack of requests
异常。

3.BUFFER

表示 Flowable 异步缓存池同 Observable的一样没固定大小，可以无限制添加数据，不会抛出 MissingBackpressureException 异常，但会导致 oom；

4.DROP

表示如果Flow的异步缓存池满了，则会丢掉将要放入缓存池中的数据。

5.LATEST

表示缓存池满了，则会丢掉将要放入缓存池中的数据。跟DROP一样，不同的是不管缓存池的状态如何。LATEST 都会将最后一条数据强行放入缓存池中。

展开全文 >>

Rxjava 并行编程

并行不是并发，也不是同步，更不是异步。

并发是指一个处理器处理多个任务。并行是多个处理器或者是多核的处理器同时处理多个不同的任务。并行是同时发生的多个并发事件，具有并发的含义，而并发则不一定是并行。

一、借助 flatMap 实现并行

二、通过 Round-Robin 算法实现并行

三、ParallelFlowabe 实现并行

四、ParallelFlowabe 与 Scheduler

五、ParallelFlowabe 的操作符

六、ParallelFlowabe 和 Flowable.flatMap 比较

展开全文 >>

Rxjava 线程调度器

single 使用定长为 1 的线程池,重读利用这个线程。

newThread 每次都启用新的线程，并在新线程中执行操作。

computation 使用的固定线程池，大小为 CPU核数。

io 适合 io 操作 (读写操作、读写数据库、网络信息交互)所使用的 Scheduler ,行为模式和 newThread 差不多、区别在与 io() 的内部实现是一个无数量的上线的线程池，可以重复空闲的线程，因此多数情况下，io() 比 newThread()。

trampoline 直接在当前线程运行，如果在当前线程有其他人去正在执行，则会先暂停其他任务。

Schedulers.from 将 Executor 转化成一个调度器实例，可以自定义一个 Executor 来作为调度器。

展开全文 >>

小程序服务商会议总结

小程序 拥有 2亿日活跃。

一、小程序发展

1.附近小程序
  • 根据 LBS 排列附近小程序。改版之后的小程序根据算法显示附近的人气高的小程序。
2.同城配送接口
  • 集成顺丰、达达、众包等第三方接口。起到平台作用，控制物流端的服务质量。可以根据商品的单价和选择不同的服务。目前内测。

二、小程序安全

1.UGC 内容底线

  • 青少年保护

  • 姓名头像自定义

  • 领导人营销、滥用国家标志与建筑。

  • pgc 内容低俗表情

2.安全攻防策略

  • 靠技术也得靠人。

  • 小程序接口技术审核

三、餐饮玩法

好玩、每日签到、领取优惠券、领券下单、复购。

1.储值

  • 充值送（300送100 、500 送200 ）

  • 储值免单（买单的时候推荐、服务员业务机制）

  • 使用储值后，比例返还。

2.礼品卡
  • 逼格最重要

微信开放平台

展开全文 >>

RxJava 合并操作符和连接操作符

一、合并操作符

startWith() 在数据序列的开头增加一项数据

merge() 将多个 Observable 合并为一个。

mergeDelayError() 合并多个 Observable ，让没有错误的 Observable 都完成后在发射错误通知。

zip() 使用一个函数组合多个 Observable 发射的数据集合。然后在发射这个结果。

combineLatest() 当两个 Observable 中的任何一个发射一个数据时，通过一个指定的函数组合每个 Observable 发射的最新数据(一共两个数据)，然后发射这个函数的结果。

join() and groupJoin() 无论何时，如果一个 Observable 发射了一个数据项，就需要在另一个 Observable发射的数据项定义的时间窗口内，将两个 Observable发射的数据合并发射。

switchOnNext() 将一个发射 Observable 的 Observable转换成另一个 Observable，后者发射这些 Observable 最近发射的数据。

二、连接操作符

ConnectableObservable.connect() 指示一个可连接的 Observable 开始发射数据。

Observable.publish() 将一个 Observable 转换为一个可连接的 Observable。

Observable.replay() 确保所有的订阅者看到相同的数据序列，即使它们在 Observable 开始发射数据之后才订阅。

ConnectableObservable.refCount() 让一个可连接的 Ob
servable 表现得像一个普通的 Observable。

展开全文 >>