发表于

在查询出商品的时候，就将当前数据锁定，直到我们修改提交之后。在中途过程中商品被锁定，无法被其他人修改

过程

  • 修改autocommit模式为0，默认为1即为自动提交
  • select status from t_goods where id=1 for update;

此时另起一个查询，发现无法查询到该商品了，一直需要等到上一条sql提交为止

  • commit

此时另外一个查询终于可以查到内容了

发表于

apikey和appsecret区别

微信支付只需要用到AppId、ApiKey、mchId即可

进行公众号相关的开发才需要用到AppSecret

获取OpenId

1
https://open.weixin.qq.com/connect/oauth2/authorize?appid=wx77963cc3616036e7&redirect_uri=https://yxjf.188lanxi.com/ClickFarming/getOpenid?param=3311111111111999&response_type=code&scope=snsapi_userinfo&state=2#wechat_redirect

替换appid，记得需要去公众号网页授权域名才能跳转到redirect_uri

发表于

锁场景

  • 单机部署时，锁机制可用ReentrantLock可重入锁，或者用synchronized特殊字段锁住，高并发时推荐使用ReentrantLock，效率更高

  • 分布式部署时，因为需要布置多个服务器，不同服务器之间锁不互通，所以需要一个共同的中间件去达成锁的通信，推荐只用redis，当然还有数据库的悲观锁、乐观锁

redis分布式锁

  • 原理：setnx+expire，并开启事务（使其具有原子性），两项操作必须都执行成功，一项操作失败，另一项操作也需回退，执行完后del释放锁
  • 保证事务方法：使用lua脚本（经常使用在游戏上，效率非常高），该脚本拥有原子性
  • 上述分布式锁可能发生的问题
    • redis挂了========>可以高可用集群
    • 超时时间设置========>根据你的业务时间来进行配置
    • 业务时间>超时时间=========> 自动续钟（定义一个守护线程：查看锁的过期时间，如果发现锁要过期，但业务还没完成，则自动加时间）

使用redisson来实现

官方提供的redis分布式锁的实现

步骤

  • pom包引入redisson的实现

发表于

Runnable 不可返回值

Callable 可以返回值，返回Future（Java8可用CompletableFuture）

Callable.call()必须有返回时，FutureTask.get()方法才会执行，否则一直阻塞

Java8新提供CompletableFuture，可以传入回调对象，当异步任务完成或者发生异常时，自动调用回调对象的回调方法

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
/**
 * 串行执行
 * @throws IOException
 * @throws InterruptedException
 */
@Test
void CompletableFuture() throws IOException, InterruptedException {
    // 第一个任务:
    CompletableFuture<String> cfQuery = CompletableFuture.supplyAsync(() -> "今天");
    // cfQuery成功后继续执行下一个任务:
    CompletableFuture<String> cfFetch = cfQuery.thenApplyAsync((code) -> code + "星期");
    CompletableFuture<String> ThFetch = cfFetch.thenApplyAsync((code) -> code + "五");
    // 并行 ----多个条件只需要满足一个
    CompletableFuture<Object> future = CompletableFuture.anyOf(cfFetch, cfQuery, ThFetch);

    // cfFetch成功后打印结果:
    ThFetch.thenAccept((result) -> {
        System.out.println("消息: " + result);
    });
    // 主线程不要立刻结束，否则CompletableFuture默认使用的线程池会立刻关闭:
    Thread.sleep(2000);
}

也可以并行执行，逻辑流程为：
其中CompletableFuture.anyOf()含义为：只要任意一个成功，即可执行下面的逻辑，CompletableFuture.allOf()含义为：全部成功之后执行下面逻辑


阅读全文 »

发表于 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
server {
        listen       80;
        server_name  malltest.bankbaoxian.com;

        location /{
            proxy_pass http://XXX.XXX.XXX.XXX:XXXX;
            proxy_set_header Host $host;
            proxy_set_header X-Real-IP $remote_addr;
            proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
            proxy_set_header X-real-uri      $request;
        }
        
	     location /icbc {
	        proxy_pass http://XXX.XXX.XXX.XXX:XXXX;
	        proxy_set_header Host $host;
	        proxy_set_header X-Real-IP $remote_addr;
	        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
	        proxy_set_header X-real-uri      $request;
	
	       }
}

同一个域名可以有不同的跳转，location不同即可

Nginx故障转移而导致请求重复

注意点：如果请求超时（nginx timeout时间设置为3秒，应用接口比如5秒后才有响应），GET请求会重复分发，POST请求会幂等，所以GET请求不能用在新增和删除数据，只能用在查询。但是如果服务器确实挂了，POST请求还是会转发的

Nginx故障转移导致的服务器雪崩

场景

高并发场景下，A机器每秒有5000请求超时，故障转移到B、C机器，而导致原本已经满负荷的B、C机器雪上加霜而发生雪崩

解决

  • 设置proxy_next_upstream_tries，限制将请求传递到下一个服务器的可能尝试次数。默认为0，即一直传递下去
  • 设置proxy_next_upstream_timeout，重试超时时间，过了时间之后就不再进行重试

反向代理和正向代理

  • 正向代理

正向代理：比如说VPN，我国访问不了谷歌，但是通过VPN代理即可访问，即内网访问外网

反向代理：外网通过NG访问内网，优点：保证内网的安全，负载均衡

总结

正向代理即是客户端代理, 代理客户端, 服务端不知道实际发起请求的客户端

反向代理即是服务端代理, 代理服务端, 客户端不知道实际提供服务的服务端

正向代理和反向代理的区别

发表于

val自增

比如说想要实现点赞功能，用户点击一次，调用redisTemplate.opsForValue().increment(key, delta);方法即可

redis 主从哨兵

  • 从redis配置
1
2
3
4
5
6
7
port 6002
# 新版本/代替了slaveof  
slaveof 127.0.0.1 6000
# 如果主redis配置了密码 这里也需要配置相同密码
masterauth 123456 
 
requirepass 123456

redis容易出现的问题

  • 缓存穿透
    数据库和缓存中都没有该数据，有人恶意请求的话，所有的请求都会到达数据库导致数据库崩溃。

    • 布隆过滤器
    • 增加接口的安全性，比如添加校验
    • 当缓存取不到数据时，也将key写入缓存，val为null，有效期设置短些，比如30s

  • 缓存击穿
    数据库有数据缓存中没有该数据，因为缓存有过期时间，如果过期的一瞬间突然涌入大量的相同请求，那么这些请求因为从缓存中无法获取值而转向数据库，导致数据库并发量突然增大而奔溃

    • 比如一些热点的数据设置为不过期
    • 加上互斥锁，当缓存不存在时，加锁去从数据库中获取内容放到缓存中
  • 缓存雪崩
    数据库有数据缓存中没有该数据，缓存中大批量的数据到过期时间，那一瞬间查询量巨大的情况下，数据库可能会宕机
    • redis集群、哨兵
    • 过期时间随机设置
    • 热点数据永不过期

发表于

一直只会nginx跳转，今天遇到一个新的跳转方法，用portlet.jar包去跳转

1
nohup java -cp "portlet.jar:" com.bs.tools.jproxy 8089 192.168.17.40 8081 >> proxy8089.out 2>&1 &

当前的8089端口会跳转到192.168.17.40的8081端口，当有时银行有专线时，可以凭此跳转

发表于

今天遇到一个问题，mybatis传入0这个参数，但是sql打印时0参数并没有设置进去，通过debug发现是mapper的问题

1
2
3
<if test="corpusId != null and corpusId != ''">
    and corpus_id = #{corpusId}
</if>

如果参数类型为int或者long，那么当传入的参数为0时，corpusId != ''判断为false，所以该判断条件没有加入

解决方法

所有数字类型，mapper中无需添加XXX != ''条件，否则没有办法传入0参数

发表于

path:/Users/mintaoyu/Library/Preferences/IntelliJIdea2018.3

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
-Xms2g
-Xmx2g
-XX:ReservedCodeCacheSize=1024m
-XX:+UseCompressedOops
-Dfile.encoding=UTF-8
-XX:+UseConcMarkSweepGC
-XX:SoftRefLRUPolicyMSPerMB=50
-ea
-Dsun.io.useCanonCaches=false
-Djava.net.preferIPv4Stack=true
-Djdk.http.auth.tunneling.disabledSchemes=""
-XX:+HeapDumpOnOutOfMemoryError
-XX:-OmitStackTraceInFastThrow
-Xverify:none

-XX:ErrorFile=$USER_HOME/java_error_in_idea_%p.log
-XX:HeapDumpPath=$USER_HOME/java_error_in_idea.hprof

发表于 

1
2
3
4
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>

entity层

1
2
3
4
5
6
7
8
9
10
11
@Data
@Document(indexName = "buy", type = "_doc")
public class TArticle implements Serializable {
    private static final long serialVersionUID = -34674011594388686L;
    /**
    * 文章id
    */
    @Id
    private Long id;
    // 省略
}

controller层，引入ElasticsearchTemplate，进行增删查改

阅读全文 »
0%