2. 程式人生 > >Spring Cloud 應用篇 之 Spring Cloud Sleuth + Zipkin（三）修改資料儲存方式

Spring Cloud 應用篇 之 Spring Cloud Sleuth + Zipkin（三）修改資料儲存方式

阿新 • • 發佈：2019-02-05

（一）簡介

預設情況下，Zipkin Server 會將跟蹤資訊儲存在記憶體中，每次重啟 Zipkin Server 都會使之前收集的跟蹤資訊丟失，並且當有大量跟蹤資訊時，記憶體儲存也會造成效能瓶頸，所以通常我們都需要將跟蹤資訊儲存到外部元件中，如 Mysql。

由於 Spring Boot 2.0 之後 Zipkin 不再推薦我們來自定義 Server 端了，那麼如何把 Zipkin Server 修改為 Mysql 儲存功能呢？答案還是和整合 RabbitMQ 一樣，在啟動 zipkin.jar 的時候，配置相關引數

（二）配置 zipkin server 

2.1 建立資料庫、表資訊

既然資料儲存改為 Mysql，那麼肯定要建立相關的表，建表的指令碼檔案 mysql.sql 在 GitHub 官方地址能查到，連結如下：

這裡會建立三張表，如下，具體表結構資訊，大家可以自己檢視


2.2 啟動 zipkin

zipkin.jar 的 配置檔案內容可以檢視 GitHub 上官方的提供

為了方便，我在這裡展示部分內容：

  1. zipkin:
  2.   collector:
  3.     rabbitmq:
  4.       # RabbitMQ server address list (comma-separated list of host:port)
  5.       addresses: ${<span class="hljs-symbol"><span class="hljs-symbol">RABBIT_ADDRESSES:</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="6"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-symbol"><span class="hljs-symbol">concurrency:</span></span> ${RABBIT_CONCURRENCY:
     
    1}
  6.       # TCP connection timeout in milliseconds
  7.       connection-timeout: ${<span class="hljs-symbol"><span class="hljs-symbol">RABBIT_CONNECTION_TIMEOUT:</span></span><span class="hljs-number"><span class="hljs-number">60000</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="9"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-symbol"><span class="hljs-symbol">password:</span></span> ${RABBIT_PASSWORD:
     
    guest}
  8.       queue: ${<span class="hljs-symbol"><span class="hljs-symbol">RABBIT_QUEUE:</span></span>zipkin}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="11"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-symbol"><span class="hljs-symbol">username:</span></span> ${RABBIT_USER:guest}
  9.       virtual-host: ${<span class="hljs-symbol"><span class="hljs-symbol">RABBIT_VIRTUAL_HOST:</span></span>/}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="13"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-symbol"><span class="hljs-symbol">useSsl:</span></span> ${RABBIT_USE_SSL:false}
  10.       uri: ${<span class="hljs-symbol"><span class="hljs-symbol">RABBIT_URI:</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="15"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">  <span class="hljs-symbol"><span class="hljs-symbol">storage:</span></span></div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="16"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">    strict-trace-<span class="hljs-symbol"><span class="hljs-symbol">id:</span></span> ${STRICT_TRACE_ID:true}
  11.     search-enabled: ${<span class="hljs-symbol"><span class="hljs-symbol">SEARCH_ENABLED:</span></span><span class="hljs-literal"><span class="hljs-literal">true</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="18"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">    <span class="hljs-symbol"><span class="hljs-symbol">type:</span></span> ${STORAGE_TYPE:mem}
  12.     mem:
  13.       # Maximum number of spans to keep in memory.  When exceeded, oldest traces (and their spans) will be purged.
  14.       # A safe estimate is 1K of memory per span (each span with 2 annotations + 1 binary annotation), plus
  15.       # 100 MB for a safety buffer.  You’ll need to verify in your own environment.
  16.       # Experimentally, it works with: max-spans of 500000 with JRE argument -Xmx600m.
  17.       max-spans: 500000
  18.     cassandra:
  19.       # Comma separated list of host addresses part of Cassandra cluster. Ports default to 9042 but you can also specify a custom port with ‘host:port’.
  20.       contact-points: ${<span class="hljs-symbol"><span class="hljs-symbol">CASSANDRA_CONTACT_POINTS:</span></span>localhost}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="28"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-comment"><span class="hljs-comment"># Name of the datacenter that will be considered "local" for latency load balancing. When unset, load-balancing is round-robin.</span></span></div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="29"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      local-<span class="hljs-symbol"><span class="hljs-symbol">dc:</span></span> ${CASSANDRA_LOCAL_DC:}
  21.       # Will throw an exception on startup if authentication fails.
  22.       username: ${<span class="hljs-symbol"><span class="hljs-symbol">CASSANDRA_USERNAME:</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="32"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-symbol"><span class="hljs-symbol">password:</span></span> ${CASSANDRA_PASSWORD:}
  23.       keyspace: ${<span class="hljs-symbol"><span class="hljs-symbol">CASSANDRA_KEYSPACE:</span></span>zipkin}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="34"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-comment"><span class="hljs-comment"># Max pooled connections per datacenter-local host.</span></span></div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="35"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      max-<span class="hljs-symbol"><span class="hljs-symbol">connections:</span></span> ${CASSANDRA_MAX_CONNECTIONS:8}
  24.       # Ensuring that schema exists, if enabled tries to execute script /zipkin-cassandra-core/resources/cassandra-schema-cql3.txt.
  25.       ensure-schema: ${<span class="hljs-symbol"><span class="hljs-symbol">CASSANDRA_ENSURE_SCHEMA:</span></span><span class="hljs-literal"><span class="hljs-literal">true</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="38"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-comment"><span class="hljs-comment"># 7 days in seconds</span></span></div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="39"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      span-<span class="hljs-symbol"><span class="hljs-symbol">ttl:</span></span> ${CASSANDRA_SPAN_TTL:604800}
  26.       # 3 days in seconds
  27.       index-ttl: ${<span class="hljs-symbol"><span class="hljs-symbol">CASSANDRA_INDEX_TTL:</span></span><span class="hljs-number"><span class="hljs-number">259200</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="42"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-comment"><span class="hljs-comment"># the maximum trace index metadata entries to cache</span></span></div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="43"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      index-cache-<span class="hljs-symbol"><span class="hljs-symbol">max:</span></span> ${CASSANDRA_INDEX_CACHE_MAX:100000}
  28.       # how long to cache index metadata about a trace. 1 minute in seconds
  29.       index-cache-ttl: ${<span class="hljs-symbol"><span class="hljs-symbol">CASSANDRA_INDEX_CACHE_TTL:</span></span><span class="hljs-number"><span class="hljs-number">60</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="46"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-comment"><span class="hljs-comment"># how many more index rows to fetch than the user-supplied query limit</span></span></div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="47"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      index-fetch-<span class="hljs-symbol"><span class="hljs-symbol">multiplier:</span></span> ${CASSANDRA_INDEX_FETCH_MULTIPLIER:3}
  30.       # Using ssl for connection, rely on Keystore
  31.       use-ssl: ${<span class="hljs-symbol"><span class="hljs-symbol">CASSANDRA_USE_SSL:</span></span><span class="hljs-literal"><span class="hljs-literal">false</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="50"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">    <span class="hljs-symbol"><span class="hljs-symbol">cassandra3:</span></span></div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="51"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-comment"><span class="hljs-comment"># Comma separated list of host addresses part of Cassandra cluster. Ports default to 9042 but you can also specify a custom port with 'host:port'.</span></span></div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="52"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      contact-<span class="hljs-symbol"><span class="hljs-symbol">points:</span></span> ${CASSANDRA_CONTACT_POINTS:localhost}
  32.       # Name of the datacenter that will be considered “local” for latency load balancing. When unset, load-balancing is round-robin.
  33.       local-dc: ${<span class="hljs-symbol"><span class="hljs-symbol">CASSANDRA_LOCAL_DC:</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="55"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-comment"><span class="hljs-comment"># Will throw an exception on startup if authentication fails.</span></span></div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="56"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-symbol"><span class="hljs-symbol">username:</span></span> ${CASSANDRA_USERNAME:}
  34.       password: ${<span class="hljs-symbol"><span class="hljs-symbol">CASSANDRA_PASSWORD:</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="58"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-symbol"><span class="hljs-symbol">keyspace:</span></span> ${CASSANDRA_KEYSPACE:zipkin2}
  35.       # Max pooled connections per datacenter-local host.
  36.       max-connections: ${<span class="hljs-symbol"><span class="hljs-symbol">CASSANDRA_MAX_CONNECTIONS:</span></span><span class="hljs-number"><span class="hljs-number">8</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="61"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-comment"><span class="hljs-comment"># Ensuring that schema exists, if enabled tries to execute script /zipkin2-schema.cql</span></span></div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="62"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-keyword"><span class="hljs-keyword">ensure</span></span>-<span class="hljs-symbol"><span class="hljs-symbol">schema:</span></span> ${CASSANDRA_ENSURE_SCHEMA:true}
  37.       # how many more index rows to fetch than the user-supplied query limit
  38.       index-fetch-multiplier: ${<span class="hljs-symbol"><span class="hljs-symbol">CASSANDRA_INDEX_FETCH_MULTIPLIER:</span></span><span class="hljs-number"><span class="hljs-number">3</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="65"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-comment"><span class="hljs-comment"># Using ssl for connection, rely on Keystore</span></span></div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="66"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      use-<span class="hljs-symbol"><span class="hljs-symbol">ssl:</span></span> ${CASSANDRA_USE_SSL:false}
  39.     elasticsearch:
  40.       # host is left unset intentionally, to defer the decision
  41.       hosts: ${<span class="hljs-symbol"><span class="hljs-symbol">ES_HOSTS:</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="70"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-symbol"><span class="hljs-symbol">pipeline:</span></span> ${ES_PIPELINE:}
  42.       max-requests: ${<span class="hljs-symbol"><span class="hljs-symbol">ES_MAX_REQUESTS:</span></span><span class="hljs-number"><span class="hljs-number">64</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="72"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-symbol"><span class="hljs-symbol">timeout:</span></span> ${ES_TIMEOUT:10000}
  43.       index: ${<span class="hljs-symbol"><span class="hljs-symbol">ES_INDEX:</span></span>zipkin}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="74"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      date-<span class="hljs-symbol"><span class="hljs-symbol">separator:</span></span> ${ES_DATE_SEPARATOR:-}
  44.       index-shards: ${<span class="hljs-symbol"><span class="hljs-symbol">ES_INDEX_SHARDS:</span></span><span class="hljs-number"><span class="hljs-number">5</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="76"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      index-<span class="hljs-symbol"><span class="hljs-symbol">replicas:</span></span> ${ES_INDEX_REPLICAS:1}
  45.       username: ${<span class="hljs-symbol"><span class="hljs-symbol">ES_USERNAME:</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="78"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-symbol"><span class="hljs-symbol">password:</span></span> ${ES_PASSWORD:}
  46.       http-logging: ${<span class="hljs-symbol"><span class="hljs-symbol">ES_HTTP_LOGGING:</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="80"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      legacy-reads-<span class="hljs-symbol"><span class="hljs-symbol">enabled:</span></span> ${ES_LEGACY_READS_ENABLED:true}
  47.     mysql:
  48.       host: ${<span class="hljs-symbol"><span class="hljs-symbol">MYSQL_HOST:</span></span>localhost}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="83"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-symbol"><span class="hljs-symbol">port:</span></span> ${MYSQL_TCP_PORT:3306}
  49.       username: ${<span class="hljs-symbol"><span class="hljs-symbol">MYSQL_USER:</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="85"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      <span class="hljs-symbol"><span class="hljs-symbol">password:</span></span> ${MYSQL_PASS:}
  50.       db: ${<span class="hljs-symbol"><span class="hljs-symbol">MYSQL_DB:</span></span>zipkin}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="87"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">      max-<span class="hljs-symbol"><span class="hljs-symbol">active:</span></span> ${MYSQL_MAX_CONNECTIONS:10}
  51.       use-ssl: ${<span class="hljs-symbol"><span class="hljs-symbol">MYSQL_USE_SSL:</span></span><span class="hljs-literal"><span class="hljs-literal">false</span></span>}</div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="89"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">  <span class="hljs-symbol"><span class="hljs-symbol">ui:</span></span></div></div></li><li><div class="hljs-ln-numbers"><div class="hljs-ln-line hljs-ln-n" data-line-number="90"></div></div><div class="hljs-ln-code"><div class="hljs-ln-line">    <span class="hljs-symbol"><span class="hljs-symbol">enabled:</span></span> ${QUERY_ENABLED:true}
  52.     ## Values below here are mapped to ZipkinUiProperties, served as /config.json
  53.     # Default limit for Find Traces
  54.     query-limit: 10
  55.     # The value here becomes a label in the top-right corner
  56.     environment:
  57.     # Default duration to look back when finding traces.
  58.     # Affects the “Start time” element in the UI. 1 hour in millis
  59.     default-lookback: 3600000
  60.     # When false, disables the “find a trace” screen
  61.     search-enabled: ${SEARCH_ENABLED:true}
  62.     # Which sites this Zipkin UI covers. Regex syntax. (e.g. http:\/\/example.com\/.*)
  63.     # Multiple sites can be specified, e.g.
  64.     # - .*example1.com
  65.     # - .*example2.com
  66.     # Default is “match all websites”
  67.     instrumented: .*
  68.     # URL placed into the <base> tag in the HTML
  69.     base-path: /zipkin

從它的配置檔案可以看出，storage 預設採用的是記憶體儲存，所以我們要設定 zipkin.storage.type=mysql，除此之外還要設定 zipkin.storage.mysql.host、port、username、password、db 等

下面貼出我的啟動命令：

  1. java -jar zipkin.jar --zipkin.collector.rabbitmq.addresses=localhost --zipkin.storage.type=mysql 
  2. --zipkin.storage.mysql.host=localhost --zipkin.storage.mysql.port=3306 --zipkin.storage.mysql.username=root 
  3. --zipkin.storage.mysql.password=mysql --zipkin.storage.mysql.db=zipkin

大家可以根據自己的資料庫資訊，修改相關配置即可

（三）驗證

至於 Zipkin Client 端，是不需要相關修改的，按照上面命令啟動 zipkin 後，訪問 http://localhost:8481/service1，檢視資料庫資訊，表 zipkin_annotations 和表 zipkin_spans 中已經資料儲存了

表 zipkin_annotations ：


表 zipkin_spans ：


表中所儲存的資訊我們已經非常熟悉，之前分析的內容都可以在這兩張表中體現出來。

從 GitHub 的官方配置檔案中，我們可以看到，Zipkin 在儲存方面除了對 Mysql 有擴充套件元件之外，還實現了對 CassCassandra 和 ElasElasticSearch 的支援擴充套件，具體的整合方式與 Mysql 的整合類似。


相關推薦

Spring Cloud 應用篇 之 Spring Cloud Sleuth + Zipkin（三）修改資料儲存方式

（一）簡介預設情況下，Zipkin Server 會將跟蹤資訊儲存在記憶體中，每次重啟 Zipkin Server 都會使之前收集的跟蹤資訊丟失，並且當有大量跟蹤資訊時，記憶體儲存也會造成效能瓶頸，所以通常我們都需要將跟蹤資訊儲存到外部元件中，如 Mysql。由於 Sprin

Spring Cloud 應用篇 之 Spring Cloud Config（配置中心）

為了方便儲存，轉自：https://blog.csdn.net/hubo_88/article/details/80692156 從前幾篇文章中我們就可以看出，在分散式系統中，服務數量會很多，如果要修改服務的配置檔案，會很麻煩，這個時候，我們想把配置檔案放在一個地方統一管理，實時更新，Sprin

Spring Cloud 應用篇 之 Hystrix Dashboard（斷路器監控） 的基本搭建

在以往的文章裡，已經講解了 斷路器 Hystrix 的基本使用，現在將介紹斷路器的監控 Hystrix Dashboard 的基本搭建。（一）簡介Hystrix Dashboard 是 Hystrix 的儀表盤元件，提供了資料監控，可以實時監控 Hystrix 的各個指標，然

Spring Cloud 應用篇 之 Ribbon 的基本使用

上一篇文章初步體驗了 Eureka 的基本使用，講了關於服務的註冊與發現。這一篇主要講解基於 Ribbon 實現的服務呼叫。（一）簡介Spring Cloud Ribbon 是一個基於 Http 和 TCP 的客服端負載均衡工具，它是基於 Netflix Ribbon 實現的

Spring Cloud 應用篇 之 Hystrix Turbine（斷路器聚合監控）的基本搭建

在講解了 Hystrix Dashboard 之後，我們知道了，Hystrix Dashboard 實現的是單節點模式，一次只能監控一個服務，當有很多服務的時候，這樣單節點模式去監控，就需要開啟多個瀏覽器視窗，顯然這是很麻煩的。這個時候，我們就可以用到 Spring Clou

Spring Cloud Spring Boot mybatis分布式微服務雲架構（三）屬性配置文件詳解（1）

定義 public 配置數據庫連接 clas cep and xml配置 其他 PE 相信很多人選擇Spring Boot主要是考慮到它既能兼顧Spring的強大功能，還能實現快速開發的便捷。我們在Spring Boot使用過程中，最直觀的感受就是沒有了原來自己整合Spri

Spring Cloud Stream消費失敗後的處理策略（三）：使用DLQ佇列（RabbitMQ）

應用場景 前兩天我們已經介紹了兩種Spring Cloud Stream對訊息失敗的處理策略： 自動重試：對於一些因環境原因（如：網路抖動等不穩定因素）引發的問題可以起到比較好的作用，提高訊息處理的成功率。 自定義錯誤處理邏輯：如果業務上，訊息處理失敗之後有明確的降級邏輯可以彌補的，可以採用這種

Spring Cloud Stream消費失敗後的處理策略（三）：使用DLQ隊列（RabbitMQ）

messages tap ica hello 方式 應用 manage oot 輸入 應用場景 前兩天我們已經介紹了兩種Spring Cloud Stream對消息失敗的處理策略： 自動重試：對於一些因環境原因（如：網絡抖動等不穩定因素）引發的問題可以起到比較好的作用，提

[原創]分散式系統之快取的微觀應用經驗談（三）【資料分片和叢集篇】

分散式系統之快取的微觀應用經驗談（三）【資料分片和叢集篇】 前言 　　近幾個月一直在忙些瑣事，幾乎年後都沒怎麼閒過。忙忙碌碌中就進入了2018年的秋天了，不得不感嘆時間總是如白駒過隙，也不知道收穫了什麼和失去了什麼。最近稍微休息，買了兩本與技術無關的書，其一是 Yann Martel 寫的《The

Spring原始碼學習之路---IOC實現原理（三）

原文地址：https://blog.csdn.net/zuoxiaolong8810/article/details/8548478          上一章我們已經初步認識了BeanFactory和BeanDefinition，一個是IOC的核心工廠介面，一個是IOC的be

spring boot 整合thyemleaf基本使用 日期的操作（三）

<!--格式化日期，預設的以瀏覽器預設語言為格式化標準--> <span th:text="${#dates.format(key)}"></span> <hr/> <!--自定義格式--> <span th:text="${#dat

Linux之《荒島餘生》（三）記憶體篇

記憶體問題，腦瓜疼腦瓜疼。腦瓜疼的意思，就是腦袋運算空間太小，撐的疼。本篇是《荒島餘生》系列第三篇，讓人腦瓜疼的記憶體篇。其餘參見： Linux之《荒島餘生》（一）準備篇 Linux之《荒島餘生》（二）CPU篇 小公司請求量小，但喜歡濫用記憶體，開一堆執行緒，大把大把往jvm塞物件，最終問題是記憶體溢位

《設計資料密集型應用/DDIA》精要翻譯（三） ：資料的儲存和獲取之底層資料結構

看了這三章，我最大的收貨並不是說學到了什麼新的知識，而是對以前通過各種渠道所掌握的知識重新進行了梳理和歸納，使它們有種脈絡相通的感覺。 一、驅動你的資料庫的資料結構 這也許是世界上最簡單的資料庫實現： db_set () {

Netty進階基礎篇之NIO 非阻塞通訊（6）

1、Tcp網路非阻塞通訊 //客戶端 @Test public void client() throws IOExcept

【銅】第124篇 一對一視頻錄制（三）及網站註冊 周四

一對一視頻錄制 網站註冊 關鍵詞：一對一視頻錄制,網站註冊一、一對一視頻錄制1.1 參考網址https://www.webrtc-experiment.com/RecordRTC/視頻錄制下載網址：https://github.com/muaz-khan/RecordRTC1.2 網頁錄制本地：ht

MVC之排球比賽計分程序 ——（三）model類的設計與實現

比賽 用戶 count class 包括 result 控制 類的設計 可能 實體類是現實實體在計算機中的表示。它貫穿於整個架構，負擔著在各層次及模塊間傳遞數據的職責。一般來說，實體類可以分為“貧血實體類”和“充血實體類”，前者僅僅保存實體的屬性，而後者還包含一些實體間的關

Centos 7.0 編譯安裝LAMP（Linxu+apache+mysql+php）之源碼安裝php （三）

lamp apache 源碼編譯lamp php mysql centos 7 編譯安裝lamp PHP簡介： PHP（外文名:PHP: Hypertext Preprocessor，中文名：“超文本預處理器”）是一種通用開源腳本語言。語法吸收了C語言、Java和Perl的特

【Win 10 應用開發】UI Composition 劄記（三）：與 XAML 集成

單獨使用 切換 column gif 頂部 tel border 靜態 ons 除了 DirectX 遊戲開發，我們一般很少單獨使用 UI Composition ，因此，與 XAML 互動並集成是必然結果。這樣能夠把兩者的優勢混合使用，讓UI布局能夠更靈活。 說到與 X

機器學習之支持向量機（三）：核函數和KKT條件的理解

麻煩 ron 現在 調整 所有 核函數 多項式 err ges 註：關於支持向量機系列文章是借鑒大神的神作，加以自己的理解寫成的；若對原作者有損請告知，我會及時處理。轉載請標明來源。 序： 我在支持向量機系列中主要講支持向量機的公式推導，第一部分講到推出拉格朗日對偶函數的對

CAS 之 Https And Database Authentication（三）

character create alt 重置密碼 勘誤 UC man nec varchar CAS 之 Https And Database Authentication（三）