> 今天把个人的电脑重置了一下，并重新安装了一下环境，这篇博客主页来记录一下个人常用的一些软件,以便以后查询使用

### 浏览器

[Microsoft Edge](https://www.microsoft.com/en-us/edge)

[Chrome](https://www.google.cn/intl/zh-CN/chrome/)

[火狐](https://www.mozilla.org/zh-CN/firefox/download/thanks/)

### 开发常用

[open jdk](https://aws.amazon.com/cn/corretto/)

[Windows Terminal](https://github.com/microsoft/terminal/releases)（Windows新版终端）

[Gradle](https://gradle.org/releases/)

[Apache Maven](https://maven.apache.org/download.cgi)

[Node.js](https://nodejs.org/zh-cn/)

[Yarn](https://classic.yarnpkg.com/zh-Hans/docs/install#windows-stable)

[Git](https://git-scm.com/download/win)

[IDEA](https://www.jetbrains.com/idea/download/other.html)

[VS Code](https://code.visualstudio.com/)

[WebStorm](https://www.jetbrains.com/webstorm/download/other.html)

[Postman](https://www.postman.com/downloads/)

[RedisDesktopManager](https://github.com/uglide/RedisDesktopManager/releases?after=0.9.0-3)

[Termius](https://www.termius.com/windows)（SSH工具）

[Sublime Text 3](http://www.sublimetext.com/3)

[Sourcetree](https://www.sourcetreeapp.com/)(Git工具)

[Robo 3T](https://robomongo.org/download)

[Hbuilderx](https://www.dcloud.io/hbuilderx.html)(App打包工具)

### 其他

[7-zip](https://www.7-zip.org/)

[Typora](https://www.typora.io/#windows)

[shadowsocks](https://github.com/shadowsocks/shadowsocks-windows/releases)

[TIM](https://tim.qq.com/download.html)

[微信](https://pc.weixin.qq.com/?t=win_weixin&platform=wx&lang=zh_CN)


window常用软件

> Maven私服的完美方案还是首选**nexus oss** ,这个**nuxus oss**这个方案虽然比较周全,但是还是比较吃内存的.我的1核2G的服务器跑满了,所以选了这个备选方案,这个方案只是个简单的备选方案,所以没有用户管理,同步中央仓库这类功能,如果服务器性能足够,还是选择**nuxus oss**比较好一些

- 安装准备
  - Linux服务器
  - Nginx服务器(也可以使用Apache服务器或者Tomcat服务器代替)
  
- 配置Nginx

  ```config
   server {
      listen       80;
      server_name  maven.example.com;
  
  
      location / {
          root   /repository;
          autoindex on;
          index  index.html index.htm ;
      }
  
      
      error_page   500 502 503 504  /50x.html;
      
      location = /50x.html {
          root   /repository;
      }
  
      location ~ /\.ht {
          deny  all;
      }
  }
  ```

- 配置本地Maven

  修改本地**settings.xml**下的**servers**标签

  ```xml
    <servers>
      <server>
          <id>my-server</id>
          <username>root</username>
          <password>root</password>
          <filePermissions>664</filePermissions>
      </server> 
    </servers>
  ```

  配置打包上传项目中**pom.xml**

  ```xml
  <distributionManagement>
      <repository>
          <id>my-server</id>
          <url>scp://maven.example.com/repository</url>
      </repository>
  </distributionManagement>
  
  <build>
      <extensions>
          <extension>
              <groupId>org.apache.maven.wagon</groupId>
              <artifactId>wagon-ssh</artifactId>
              <version>2.10</version>
          </extension>
      </extensions>
  </build>
  ```

  然后在项目中**mvn deploy**就可以上传项目了

使用Nginx搭建轻量化Maven私服

第一次给新电脑push新项目,不小心输入错误密码,结果提示如下的错误：

![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15862440531962190.png)

#### 解决方法

- 方法一(不推荐)
解决方案：
	```shell
	git config --system --unset credential.helper
	```
	缺点: 会导致每次都会输需要输入用户名和密码
- 方法二(推荐)
 进入控制面板 用户账户中的**凭据管理器** 进行删除
![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15862447913902539.png)

git清除认证失败的账户

### WebSocket

- 什么是WebSocket:

    WebSocket 是 HTML5 开始提供的一种在单个 TCP 连接上进行全双工通讯的协议。

    普通http协议有一个严重的缺陷,通信只能有客户端发起.假如服务端有了连续的变化,客户端如果想获知,只能用轮询来获取.但轮询的效率低，非常浪费资源,这时WebSocket就此诞生了.

    WebSocket 于2008年诞生，2011年成为国际标准。它的最大特点就是，服务器可以主动向客户端推送信息，客户端也可以主动向服务器发送信息，是真正的双向平等对话，属于服务器推送技术的一种.


    ![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15858063970268527.png)


    其他特点包括:

    1. 建立在 TCP 协议之上，服务器端的实现比较容易
    2. 与 HTTP 协议有着良好的兼容性。默认端口也是80和443，并且握手阶段采用 HTTP 协议
    3. 数据格式比较轻量，性能开销小，通信高效
    4. 可以发送文本，也可以发送二进制数据
    5. 没有同源限制，客户端可以与任意服务器通信
    6. 协议标识符是ws（如果加密，则为wss），服务器网址就是 URL

    ![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15858077044610400.jpg)
    
---

### 下面简单介绍一下spring boot下如何整合WebSocket


#### 这里使用tio框架进行WebSocket服务的搭建
```gradle
plugins {
	id 'org.springframework.boot' version '2.2.6.RELEASE'
	id 'io.spring.dependency-management' version '1.0.9.RELEASE'
	id 'java'
}

group = 'com.example'
version = '0.0.1-SNAPSHOT'
sourceCompatibility = '1.8'

repositories {
	mavenCentral()
}

dependencies {
	implementation 'org.springframework.boot:spring-boot-starter'
	implementation 'org.t-io:tio-websocket-spring-boot-starter:3.6.0.v20200315-RELEASE'
	testImplementation('org.springframework.boot:spring-boot-starter-test') {
		exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'
	}
}

test {
	useJUnitPlatform()
}
```
引入**tio-websocket-spring-boot-starter**依赖


#### 构建服务端
1. 给SpringBoot Application 主类添加 **@EnableTioServerServer** 注解
    ```java
    @SpringBootApplication
    @EnableTioWebSocketServer
    public class DemoApplication {

        public static void main(String[] args) {
            SpringApplication.run(DemoApplication.class, args);
        }

    }
    ```

2. 修改配置文件
    ```yml
    tio:
      websocket:
        server:
        port: 9998
        # 心跳时间
        heartbeat-timeout: 60000
    ```

3. 创建消息处理类
    ```java
    @Configuration
    public class MyWebSocketMsgHandler implements IWsMsgHandler {


        /**
        * 握手时走这个方法，业务可以在这里获取cookie，request参数等
        */
        @Override
        public HttpResponse handshake(HttpRequest httpRequest, HttpResponse httpResponse, ChannelContext channelContext) throws Exception {
            return httpResponse;
        }

        /**
        * 握手成功后触发该方法
        */
        @Override
        public void onAfterHandshaked(HttpRequest httpRequest, HttpResponse httpResponse, ChannelContext channelContext) throws Exception {
            System.out.println("握手成功");
        }

        /**
        * 当ws是基于BINARY(字节)传输的，会执行此方法
        */
        @Override
        public Object onBytes(WsRequest wsRequest, byte[] bytes, ChannelContext channelContext) throws Exception {
            System.out.println("接收到bytes消息");
            return null;
        }

        /**
        * 当客户端发close flag时，会走这个方法
        */
        @Override
        public Object onClose(WsRequest wsRequest, byte[] bytes, ChannelContext channelContext) throws Exception {
            return null;
        }

        /**
        * 当ws是基于TEXT传输的，就会走到这个方法
        */
        @Override
        public Object onText(WsRequest wsRequest, String s, ChannelContext channelContext) throws Exception {
            System.out.println("接收到文本消息："+s);
            return fakeAi(s);
        }

        private String fakeAi(String input){
            if (input == null || "".equals(input)) {
                return "你说什么？没听清︎";
            }
            return input.replace('你', '我')
                    .replace("吗", "")
                    .replace('?', '!')
                    .replace('？', '！');
        }
    }
    ```
4. 构建客户端
```html
<!DOCTYPE html>
<html lang="en">

<head>
    <meta charset="UTF-8">
    <title>WebSocket客户端</title>
    <link href="https://cdn.bootcss.com/twitter-bootstrap/4.4.1/css/bootstrap.min.css" rel="stylesheet">
</head>

<body>
    <style>
        .jumbotron {
            width: 100%;
        }

        #text {
            height: 3rem;
            font-size: 1rem;
            line-height: 3rem;
            margin: 1rem;
        }

        .btn {
            margin-right: 5px;
        }

        #connect {
            margin-left: 1rem;
        }

        #log {
            margin: 1rem 0 0 1rem;
        }
    </style>
    <div class="container">
        <div class="row">
            <div class="jumbotron">
                <input type="text" placeholder="请输入你想传输的内容" id="text" class="col-lg-12" />
                <input type="button" value="连接" class="btn btn-info" id="connect" onclick="connect()" />
                <input type="button" value="发送" class="btn btn-success" id="sent" disabled="disabled"
                    onclick="sent()" />
                <input type="button" value="断开" class="btn btn-danger" id="disconnect" disabled="disabled"
                    onclick="disconnect()" />

                <div id="log">
                    <p>聊天记录:</p>
                </div>
            </div>
        </div>
    </div>
    <script type="text/javascript">
        let text = document.querySelector('#text');
        let connectBtn = document.querySelector("#connect");
        let sentBtn = document.querySelector("#sent");
        let disconnectBtn = document.querySelector("#disconnect");
        let logDiv = document.querySelector("#log");

        let ws = null;

        function connect() {
            ws = new WebSocket("ws://localhost:9998/test");
            ws.onopen = function () {
                setConnected(true);
                log('和服务端连接成功！');
            };
            ws.onmessage = function (event) {
                log('服务端说：' + event.data);
            };
            ws.onclose = function () {
                setConnected(false);
                log('和服务端断开连接！')
            }
        }

        function sent() {
            if (ws != null) {
                ws.send(text.value);
                log('客户端说：' + text.value);
            } else {
                log('请先建立连接！')
            }
        }

        function disconnect() {
            if (ws != null) {
                ws.close();
                ws = null;
            }
            setConnected(false);
        }

        function log(value) {
            let content = document.createElement('p');
            content.innerHTML = value;
            logDiv.appendChild(content);
            text.value = '';
        }

        function setConnected(connected) {
            connectBtn.disabled = connected;
            disconnectBtn.disabled = !connected;
            sentBtn.disabled = !connected;
        }
    </script>
</body>

</html>
```

---
 #### 运行效果

 ![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15858169181687414.PNG)

使用spring boot 搭建WebSocket

由于MongoDB默认是不开启权限认证的,但这样是非常危险的,这时就需要开启mongoDB用户认证

##### 开启mongoDB用户认证步骤
1. 开启安全认证

    在启动命令中添加 ``--auth`` 如:
    ```shell
    ./mongod --logpath=/usr/local/mongodb/log/logs --dbpath=/data/db2/ --fork
    ```
2. 添加管理员用户

    连接mongo实例,添加一个管理员用户,如添加一个用户名为jsmith,密码为123456的管理员用户
    ```shell
    # 使用mongo shell连接到实例
    ./mongo --port 27017
    # 添加管理员用户
    db.createUser({ user: 'jsmith', pwd: '123456', roles: [ { role: "userAdminAnyDatabase", db: "admin" } ] });
    ```

---

##### mongoDB所有的角色
1. 数据库用户角色：read、readWrite
2. 数据库管理角色：dbAdmin、dbOwner、userAdmin
3.  集群管理角色：clusterAdmin、clusterManager、clusterMonitor、hostManager
4. 备份恢复角色：backup、restore
5. 所有数据库角色：readAnyDatabase、readWriteAnyDatabase、userAdminAnyDatabase、dbAdminAnyDatabase
6. 超级用户角色：root ,这里还有几个角色间接或直接提供了系统超级用户的访问（dbOwner 、userAdmin、userAdminAnyDatabase）
7. 内部角色：__system

##### 具体角色权限
- Read：允许用户读取指定数据库
- readWrite：允许用户读写指定数据库
- dbAdmin：允许用户在指定数据库中执行管理函数，如索引创建、删除，查看统计或访问system.profile
- userAdmin：允许用户向system.users集合写入，可以找指定数据库里创建、删除和管理用户
- clusterAdmin：只在admin数据库中可用，赋予用户所有分片和复制集相关函数的管理权限。
- readAnyDatabase：只在admin数据库中可用，赋予用户所有数据库的读权限
- readWriteAnyDatabase：只在admin数据库中可用，赋予用户所有数据库的读写权限
- userAdminAnyDatabase：只在admin数据库中可用，赋予用户所有数据库的userAdmin权限
- dbAdminAnyDatabase：只在admin数据库中可用，赋予用户所有数据库的dbAdmin权限。
- root：只在admin数据库中可用。超级账号，超级权限。

#### 参考文档
[MongoDB 认证、添加用户、用户权限控制](https://blog.csdn.net/xiaoxiangzi520/article/details/81094378)



mongoDB数据库开启身份认证

- 打开控制台，在控制台里输入`echo %USERPROFILE%` 并记录打印的数值

  ![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15794060025622984.PNG)

- 接着输入`mkdir %USERPROFILE%\AppData\Local\Terminal\`创建文件夹

  ![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15794063199220538.PNG)

- 接着输入`explorer %USERPROFILE%\AppData\Local\Terminal\` ,打开刚才创建的文件夹，并[下载图标](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/linux/terminal.ico) ，并复制到刚才弹出的资源管理器里面

  ![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15794060111483849.PNG)

- 创建一个**addwt.reg**的文件,编辑一下内容，并保存

  ```
  Windows Registry Editor Version 5.00
  
  [HKEY_CLASSES_ROOT\Directory\Background\shell\wt]
  @="Terminal"
  "Icon"="%USERPROFILE%\\AppData\\Local\\Terminal\\terminal.ico"
  ;在这里输入将C:\\Users\\Guiyun\\换成echo %USERPROFILE% 打印的数值，记得将所有的\转译成\\
  [HKEY_CLASSES_ROOT\Directory\Background\shell\wt\command]
  @="C:\\Users\\Guiyun\\AppData\\Local\\Microsoft\\WindowsApps\\wt.exe"
  ```

- 双击**addwt.reg**文件，一路选是就可以了

- 现在在单击右键，terminal 就出现了

  ![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15794060182899287.jpg)

- 打开windows terminal的配置文件，添加`"startingDirectory": null`这个配置

  ```json
  
  // To view the default settings, hold "alt" while clicking on the "Settings" button.
  // For documentation on these settings, see: https://aka.ms/terminal-documentation
  
  {
      "$schema": "https://aka.ms/terminal-profiles-schema",
  
      "defaultProfile": "{61c54bbd-c2c6-5271-96e7-009a87ff44bf}",
  
      "profiles":
      [
          {
              // Make changes here to the powershell.exe profile
              "guid": "{61c54bbd-c2c6-5271-96e7-009a87ff44bf}",
              "name": "Windows PowerShell",
              "commandline": "powershell.exe",
              "hidden": false,
              // 添加这一行，能默认打开进入右键所在的文件夹
              "startingDirectory": null
          },
          {
              // Make changes here to the cmd.exe profile
              "guid": "{0caa0dad-35be-5f56-a8ff-afceeeaa6101}",
              "name": "cmd",
              "commandline": "cmd.exe",
              "hidden": false
          },
          {
              "guid": "{b453ae62-4e3d-5e58-b989-0a998ec441b8}",
              "hidden": false,
              "name": "Azure Cloud Shell",
              "source": "Windows.Terminal.Azure"
          }
      ],
  
      // Add custom color schemes to this array
      "schemes": [],
  
      // Add any keybinding overrides to this array.
      // To unbind a default keybinding, set the command to "unbound"
      "keybindings": []
  }
  ```

  这样右键配置windows terminal就好了
  
  ![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15794060688605540.jpg)


如何将windows terminal 添加到右键菜单

### 安装Elasticsearch

- 演示环境
  - 所演示的环境为Debian 10 1核4G，在仅仅安装es的情况下建议内存大于2G

![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15789931078968625.png)

 - 预先准备

    - JDK环境

    - 未root用户

      ```shell
      # 创建用户
      adduser admin
      # 切换为刚刚创建的用户
      su admin
      # 切换到/home/admin目录下
      cd /home/admin
      ```

- 下载并解压

  ```shell
  # 下载es
  curl -L -O https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-7.5.0-linux-x86_64.tar.gz
  # 解压
  tar -zxvf elasticsearch-7.5.0-linux-x86_64.tar.gz
  ```

- 预先配置

  ```shell
  # 进入es目录下并修改配置
  vim config/elasticsearch.yml
  # 添加配置为es数据为任何ip都可以访问
  network.host: 0.0.0.0
  # 配置发现节点地址
  discovery.seed_hosts: ["127.0.0.1", "[::1]"]
  # 修改节点名
  node.name: node-1
  #
  cluster.initial_master_nodes: ["node-1"]
  ```

- 运行es

  ```shell
  # 运行es
  ./bin/elasticsearch
  # 后台运行es
  ./bin/elasticsearch -d
  # 查询运行日志
  cat logs/elasticsearch.log
  ```

  运行完成后`curl 127.0.0.1:9200` 或者访问http://ip:9200 判断

  ![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15790683363231557.png)

- 会遇到的错误

  - `[1]: max virtual memory areas vm.max_map_count [65530] is too low, increase to at least [262144]` 这个问题是elasticsearch用户拥有的内存权限太小，至少需要262144内存

    ```shell
    # 切换root用户下
    sysctl -w vm.max_map_count=262144
    ```


### 安装可视化环境Kibana

- 下载并解压

  ```shell
  # 下载并解压
  curl -O https://artifacts.elastic.co/downloads/kibana/kibana-7.5.1-linux-x86_64.tar.gz
  tar -xzf kibana-7.5.1-linux-x86_64.tar.gz
  ```

- 修改配置文件

  ```shell
  # 修改配置文件
  vim config/kibana.yml
  # 添加任何ip都可以访问
  server.host: "0.0.0.0"
  # 默认语言改为中文
  i18n.locale: "zh-CN"
  ```

- 运行Kibana

  ```
  ./bin/kibana
  ```

  然后访问http://ip:5601 即可

  ![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15790680738037239.jpg)

![](https://guiyunweb-blog.oss-cn-shanghai.aliyuncs.com/images/15790682305583092.png)

- 会遇到的错误

  - `error while loading shared libraries: libnss3.so: cannot open shared object file: No such file or directory ` 缺少libnss3组件

    ```shell
    # 安装组件即可
    apt-get install libnss3-dev
    ```

    

Elasticsearch及其可视化工具Kibana的安装指南

## 常用的应用场景
>死信队列常常用作延时关闭订单(如订单的超时后的取消订单等)，虽然小项目中可以用定时轮询的方法进行检查，但是数据量一旦比较大时，定时轮询将给数据库带来不小的压力，而且定时间隔无法进行动态调整，特别是一个系统中，同时存在好几个定时器的时候，就显得非常的麻烦，同时给数据库造成巨大的访问压力。这时候就可以使RabbitMQ的死信队列。

## 概念解释

### DLX
- Dead Letter Exchange 的缩写
- DLX也叫死信邮箱（网上的译法），死信交换机（字面翻译）。归根结底就是一个交换机，当队列中出现死信时，通过这个交换机将死信重新发送到死信队列中（指定好rabbitmq会自动发送）。

### 什么是死信
- 消息被拒绝（basic.reject或basic.nack）并且requeue=false.
- 消息TTL过期
- 队列达到最大长度（队列满了，无法再添加数据到mq中）

### 死信交换机
 - 在定义业务队列的时候，要考虑指定一个死信交换机，死信交换机可以和任何一个普通的队列进行绑定，然后在业务队列出现死信的时候就会将数据发送到死信队列。

### 什么是死信队列
 - 死信队列实际上就是一个普通的队列，只是这个队列跟死信交换机进行了绑定，用来存放死信而已。
> 消息变成死信后，会被重新投递（publish）到另一个交换机上（Exchange）,这个交换机就被称作DLX及死信交换机，然后交换机根据绑定规则转发到对应的队列上，监听该队列就可以被重新消费。

> 生产者-->发送消息-->交换机-->队列-->变成死信队列-->DLX交换机-->队列-->监听-->消费者

## 示例代码

### 添加依赖

```gradle
implementation 'org.springframework.boot:spring-boot-starter-amqp'
```
### 添加配置

```yml
spring:
  rabbitmq:
    host: 10.0.0.19
    port: 5672
    username: guiyun
    password: 111222
```

### 添加配置类

```java
import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.HashMap;
import java.util.Map;

/**
 * @author Guiyun
 * @date 2020/1/7 下午 1:51
 */
@Configuration
public class RabbitConfig{

    /**
     * 死信队列 交换机标识符
     */
    private static final String DEAD_LETTER_QUEUE_KEY = "x-dead-letter-exchange";
    /**
     * 死信队列 交换机绑定键标识符
     */
    private static final String DEAD_LETTER_ROUTING_KEY = "x-dead-letter-routing-key";


    /**
     * 创建死信交换机
     * @return
     */
    @Bean("deadLetterExchange")
    public Exchange deadLetterExchange() {
        return ExchangeBuilder.directExchange("DL_EXCHANGE").durable(true).build();
    }


    /**
     * 创建一个死信队列.
     * @return
     */
    @Bean("deadLetterQueue")
    public Queue deadLetterQueue() {
        Map<String, Object> args = new HashMap<>(2);
        //声明 死信交换机
        args.put(DEAD_LETTER_QUEUE_KEY, "DL_EXCHANGE");
        //声明 死信路由键
        args.put(DEAD_LETTER_ROUTING_KEY, "KEY_R");
        return QueueBuilder.durable("DL_QUEUE").withArguments(args).build();
    }

    /**
     * 定义死信队列转发队列.
     * @return the queue
     */
    @Bean("redirectQueue")
    public Queue redirectQueue() {
        return QueueBuilder.durable("REDIRECT_QUEUE").build();
    }

    /**
     * 死信路由通过 DL_KEY 绑定键绑定到死信队列上.
     * @return the binding
     */
    @Bean
    public Binding deadLetterBinding() {
        return new Binding("DL_QUEUE", Binding.DestinationType.QUEUE, "DL_EXCHANGE", "DL_KEY", null);

    }

    /**
     * 死信路由通过 KEY_R 绑定键绑定到死信队列上.
     * @return the binding
     */
    @Bean
    public Binding redirectBinding() {
        return new Binding("REDIRECT_QUEUE", Binding.DestinationType.QUEUE, "DL_EXCHANGE", "KEY_R", null);
    }

}

```

### 生产者向业务队列发送消息

```java
@Autowired
RabbitTemplate rabbitTemplate;

public void spend(JSONObject data) {
    CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
    MessagePostProcessor messagePostProcessor = message -> {
        MessageProperties messageProperties = message.getMessageProperties();
        // 设置编码
        messageProperties.setContentEncoding("utf-8");
        // 设置过期时间5秒
        messageProperties.setExpiration(5000);
        return message;
    };
    rabbitTemplate.convertAndSend("DL_EXCHANGE", "DL_KEY", data, messagePostProcessor, correlationData);
}
    
```

### 死信队列消费者

```java
import com.alibaba.fastjson.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.io.IOException;

/**
 * @author Guiyun
 * @date 2020/1/7 上午 11:09
 */
@Component
@RabbitListener(queues = "DL_QUEUE")
public class DeadLetterConsumer {

    private static final Logger log = LoggerFactory.getLogger(DeadLetterConsumer.class);


    @RabbitListener(queues = {"REDIRECT_QUEUE"})
    public void redirect(JSONObject json) throws IOException {
        log.info(json.toJSONString());
    }
}

```



利用RabbitMQ 的死信队列来做定时任务

- 查看当前镜像源
```shell
yarn config get registry
```
- 切换成淘宝镜像源
```shell
yarn config set registry https://registry.npm.taobao.org
```
 

yarn 变换为淘宝镜像源

本教程会指导你如何在 Debian 8 的机器上快速升级到 Debian 9 

**以下安装步骤都在** root **用户下完成，请自行使用** su **命令切换到** root **用户**

此教程仅适用于 KVM、Xen 等可以更换内核的虚拟环境或独立服务器，OpenVZ 等无法更换内核的环境是不能升级的

1、备份数据

如果你的机器不是新开的，上面跑了一些服务，那么强烈建议备份好数据，我们推荐你备份所有的软件配置和数据库，因为升级以后，大部分软件都会更新版本，一部分软件甚至是无法滚回的，比如 Mariadb 会升级到 10.1，如果你不备份，而你的数据库没法在新的系统上运行，那么损失就大了

以下内容你可以根据自己的需求来备份

1. 服务器上应用的源代码，比如 WordPress
2. 数据库，比如 MySQL, SQLite3, Postgres
3. 配置文件，比如 Nginx, Apache, DNS, PHP
4. 邮件和账号
5. 系统添加的用户和 SSH Key

当然，新开的机器的话，别废话，直接看下面的步骤

2、更新系统

首先检查你当前的系统版本
```shell
root@debian ~ # lsb_release -a
No LSB modules are available.
Distributor ID:	Debian
Description:	Debian GNU/Linux 8.8 (jessie)
Release:	8.8
Codename:	jessie
```
然后按照以下顺序更新系统
```shell
apt-get update 
apt-get upgrade 
apt-get dist-upgrade
```
建议重启一次

3、替换 sources.list 源文件

Debian 8 代号 Jessie ，我们需要替换 /etc/apt/sources.list 里的源为 Debian 9 的代号 Stretch 或 Stable

备份一下原来的文件
```shell
cp -r /etc/apt/sources.list /etc/apt/sources.list.old
```

然后直接替换
```shell
sed -i 's/jessie/stretch/g' /etc/apt/sources.list
```

当然也可以替换为 stable ，但是我们并不建议这么做，因为未来 Debian 10 成为 stable 版的时候也会自动升级从而可能造成错误

注意的是，如果你的系统带有 /etc/apt/sources.list.d/*.list 文件，也就是某些软件会单独在这个目录下生成 .list 文件，那么也记得对应修改，修改前请先去官网查看是否有 Debian 9 Stretch 版本，没有的话升级就会失败

替换后，你的 /etc/apt/sources.list 文件就会像这个样子
```shell
deb http://deb.debian.org/debian/ stretch main
deb-src http://deb.debian.org/debian/ stretch main

deb http://security.debian.org/debian-security/ stretch/updates main
deb-src http://security.debian.org/debian-security/ stretch/updates main

deb http://deb.debian.org/debian/ stretch-updates main
deb-src http://deb.debian.org/debian/ stretch-updates main
```

4、更新系统

还是老步骤，建议一步一步来
```shell
apt-get update 
apt-get upgrade
```
5、升级系统

更新完系统之后，就可以直接升级了
```shell
apt-get dist-upgrade
```

升级过程中会让你选择是否保留旧的配置文件，这个就取决于自行选择，如果出现一长串软件版本更新、CA 证书更新的文本，可以按 q 跳过查看

6、重启并验证系统

全部更新完毕，直接重启系统

reboot

如果不出意外，重启后进入服务器并验证系统

```shell
root@debian ~ # lsb_release -a
No LSB modules are available.
Distributor ID:	Debian
Description:	Debian GNU/Linux 9.0 (stretch)
Release:	9.0
Codename:	stretch
```


再次提醒，升级系统是个大工程，如在生产环境下进行请务必务必务必备份好数据，如果没备份就直接升级，那么后果自负



[参考网站](https://sb.sb/blog/debian-8-upgrade-to-debian-9/)

Guiyunweb's blog

到目前为止共有11篇博客

2020-05-20 02:44:35 window常用软件

2020-05-09 01:44:23 使用Nginx搭建轻量化Maven私服

2020-04-07 07:32:22 git清除认证失败的账户

2020-04-02 08:43:44 使用spring boot 搭建WebSocket

2020-04-01 09:04:57 mongoDB数据库开启身份认证

2020-01-19 03:53:02 如何将windows terminal 添加到右键菜单

2020-01-15 06:11:40 Elasticsearch及其可视化工具Kibana的安装指南

2020-01-07 09:39:47 利用RabbitMQ 的死信队列来做定时任务

2019-12-28 03:35:45 yarn 变换为淘宝镜像源

2019-12-28 00:43:57 Debian 8 升级至 Debian 9 教程