spring boot集成WebSocket實時輸出

spring boot集成WebSocket實時輸出日志到web頁面

言碎語

今天來做個有趣的東西，就是實時將系統日志輸出的前端web頁面，因為是實時輸出，所有第一時間就想到了使用webSocket,而且在spring boot中，使用websocket超級方便，閱讀本文，你會接觸到以下關鍵詞相關技術，WebSocket（stopmp服務端），stomp協議，sockjs.min.js，stomp.min.js（stomp客戶端），本文使用到的其實就是使用spring boot自帶的webSocket模塊提供stomp的服務端，前端使用stomp.min.js做stomp的客戶端，使用sockjs來鏈接，前端訂閱后端日志端點的消息，后端實時推送，達到日志實時輸出到web頁面的目的，效果如下圖

首先了解下stomp？

STOMP即Simple (or Streaming) Text Orientated Messaging Protocol，簡單(流)文本定向消息協議，它提供了一個可互操作的連接格式，允許STOMP客戶端與任意STOMP消息代理（Broker）進行交互。STOMP協議由于設計簡單，易于開發客戶端，因此在多種語言和多種平臺上得到廣泛地應用。

STOMP協議的前身是TTMP協議（一個簡單的基于文本的協議），專為消息中間件設計。

STOMP是一個非常簡單和容易實現的協議，其設計靈感源自于HTTP的簡單性。盡管STOMP協議在服務器端的實現可能有一定的難度，但客戶端的實現卻很容易。例如，可以使用Telnet登錄到任何的STOMP代理，并與STOMP代理進行交互。

下面是具體的步驟，主要是日志信息的獲取和日志信息的推送，不多說，上代碼

一.引入spring boot websocket依賴

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

二.新增日志消息實體

/**
* Created by kl on 2017/10/9.
* Content :日志消息實體，注意，這里為了減少篇幅，省略了get,set代碼
*/
public class LoggerMessage{
private String body;
private String timestamp;
private String threadName;
private String className;
private String level;
public LoggerMessage(String body, String timestamp, String threadName, String className, String level) {
this.body=body;
this.timestamp=timestamp;
this.threadName=threadName;
this.className=className;
this.level=level;
}
public LoggerMessage() {
}
}

三. 創建一個阻塞隊列，作為日志系統輸出的日志的一個臨時載體

public class LoggerQueue {
//隊列大小
public static final int QUEUE_MAX_SIZE=10000;
private static LoggerQueue alarmMessageQueue=new LoggerQueue();
//阻塞隊列
private BlockingQueueblockingQueue=new LinkedBlockingQueue<>(QUEUE_MAX_SIZE);
private LoggerQueue() {
}
public static LoggerQueue getInstance() {
return alarmMessageQueue;
}
/**
* 消息入隊
* @param log
* @return
*/
public boolean push(LoggerMessage log) {
return this.blockingQueue.add(log);//隊列滿了就拋出異常，不阻塞
}
/**
* 消息出隊
* @return
*/
public LoggerMessage poll() {
LoggerMessage result=null;
try {
result=this.blockingQueue.take();
} catch (InterruptedException e) {
e.printStackTrace();
}
return result;
}
}

四.獲取logback的日志，塞入日志隊列中

1.定義Logfilter攔截輸出日志

public class LogFilter extends Filter{
@Override
public FilterReply decide(ILoggingEvent event) {
LoggerMessage loggerMessage=new LoggerMessage(
event.getMessage()
, DateFormat.getDateTimeInstance().format(new Date(event.getTimeStamp())),
event.getThreadName(),
event.getLoggerName(),
event.getLevel().levelStr
);
LoggerQueue.getInstance().push(loggerMessage);
return FilterReply.ACCEPT;
}
}

2.配置logback.xml,添加我們自定義的filter

<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true">
<include resource="org/springframework/boot/logging/logback/defaults.xml" />
<property name="LOG_FILE"
value="${LOG_FILE:-${LOG_PATH:-${LOG_TEMP:-${java.io.tmpdir:-/tmp}}/}spring.log}" />
<include resource="org/springframework/boot/logging/logback/file-appender.xml" />
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${CONSOLE_LOG_PATTERN}</pattern>
<charset>utf8</charset>
</encoder>
<filter class="com.example.websocket.LogFilter"></filter>
</appender>
<root level="INFO">
<appender-ref ref="FILE" />
<appender-ref ref="CONSOLE" />
</root>
</configuration>

五.配置WebSocket消息代理端點，即stomp服務端

@Configuration
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer{
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/websocket")
.setAllowedOrigins("http://localhost:8976")
.withSockJS();
}
}

注意：為了連接安全，setAllowedOrigins設置的允許連接的源地址，如果在非這個配置的地址下發起連接會報403，進一步還可以使用addInterceptors設置攔截器，來做相關的鑒權操作

六.啟動類，開啟webSocket消息代理功能，并推送日志信息

@SpringBootApplication
@EnableScheduling
@EnableWebSocketMessageBroker
public class WebsocketApplication {
private Logger logger=LoggerFactory.getLogger(WebsocketApplication.class);
public static void main(String[] args) {
SpringApplication.run(WebsocketApplication.class, args);
}
@Autowired
private SimpMessagingTemplate messagingTemplate;
int info=1;
@Scheduled(fixedRate=1000)
public void outputLogger(){
logger.info("測試日志輸出"+info++);
}
/**
* 推送日志到/topic/pullLogger
*/
@PostConstruct
public void pushLogger(){
ExecutorService executorService=Executors.newFixedThreadPool(2);
Runnable runnable=new Runnable() {
@Override
public void run() {
while (true) {
try {
LoggerMessage log=LoggerQueue.getInstance().poll();
if(log!=null){
if(messagingTemplate!=null)
messagingTemplate.convertAndSend("/topic/pullLogger",log);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
};
executorService.submit(runnable);
executorService.submit(runnable);
}
}

七.html頁面，連接stomp服務端，訂閱/topic/pullLogger的消息，展示日志信息

<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title>WebSocket Logger</title>
<script src="https://cdn.bootcss.com/jquery/2.1.4/jquery.js"></script>
<script src="https://cdn.bootcss.com/sockjs-client/1.1.4/sockjs.min.js"></script>
<script src="https://cdn.bootcss.com/stomp.js/2.3.3/stomp.min.js"></script>
</head>
<body>
<button onclick="openSocket()">開啟日志</button><button onclick="closeSocket()">關閉日志</button>
<div id="log-container" style="height: 450px; overflow-y: scroll; background: #333; color: #aaa; padding: 10px;">
<div></div>
</div>
</body>
<script>
var stompClient=null;
$(document).ready(function() {openSocket();});
function openSocket() {
if(stompClient==null){
var socket=new SockJS('http://localhost:8084/websocket?token=kl');
stompClient=Stomp.over(socket);
stompClient.connect({token:"kl"}, function(frame) {
stompClient.subscribe('/topic/pullLogger', function(event) {
var content=JSON.parse(event.body);
$("#log-container div").append(content.timestamp +" "+ content.level+" --- ["+ content.threadName+"] "+ content.className+" :"+content.body).append("<br/>");
$("#log-container").scrollTop($("#log-container div").height() - $("#log-container").height());
},{
token:"kltoen"
});
});
}
}
function closeSocket() {
if (stompClient !=null) {
stompClient.disconnect();
stompClient=null;
}
}
</script>
</body>
</html>

相關技術官網參考地址：

stomp.js客戶端：http://jmesnil.net/stomp-websocket/doc/

scok.js客戶端：https://github.com/sockjs/sockjs-client

spring webSocket：https://docs.spring.io/spring/docs/

源：前端工匠作者：浪里行舟君

前言

HTTP/2 相比于 HTTP/1.1，可以說是大幅度提高了網頁的性能，只需要升級到該協議就可以減少很多之前需要做的性能優化工作，當然兼容問題以及如何優雅降級應該是國內還不普遍使用的原因之一。

雖然 HTTP/2 提高了網頁的性能，但是并不代表它已經是完美的了，HTTP/3 就是為了解決 HTTP/2 所存在的一些問題而被推出來的。

一、HTTP/1.1發明以來發生了哪些變化？

如果仔細觀察打開那些最流行的網站首頁所需要下載的資源的話，會發現一個非常明顯的趨勢。近年來加載網站首頁需要的下載的數據量在逐漸增加，并已經超過了2100K。但在這里我們更應該關心的是：平均每個頁面為了完成顯示與渲染所需要下載的資源數已經超過了100個。

正如下圖所示，從2011年以來,傳輸數據大小與平均請求資源數量不斷持續增長，并沒有減緩的跡象。該圖表中綠色直線展示了傳輸數據大小的增長，紅色直線展示了平均請求資源數量的增長。

HTTP/1.1自從1997年發布以來，我們已經使用HTTP/1.x 相當長一段時間了，但是隨著近十年互聯網的爆炸式發展，從當初網頁內容以文本為主,到現在以富媒體（如圖片、聲音、視頻）為主,而且對頁面內容實時性高要求的應用越來越多(比如聊天、視頻直播),于是當時協議規定的某些特性，已經無法滿足現代網絡的需求了。

二、HTTP/1.1的缺陷

1.高延遲--帶來頁面加載速度的降低

雖然近幾年來網絡帶寬增長非常快，然而我們卻并沒有看到網絡延遲有對應程度的降低。網絡延遲問題主要由于隊頭阻塞(Head-Of-Line Blocking),導致帶寬無法被充分利用。

隊頭阻塞是指當順序發送的請求序列中的一個請求因為某種原因被阻塞時，在后面排隊的所有請求也一并被阻塞，會導致客戶端遲遲收不到數據。針對隊頭阻塞,人們嘗試過以下辦法來解決:

將同一頁面的資源分散到不同域名下，提升連接上限。 Chrome有個機制，對于同一個域名，默認允許同時建立 6 個 TCP持久連接，使用持久連接時，雖然能公用一個TCP管道，但是在一個管道中同一時刻只能處理一個請求，在當前的請求沒有結束之前，其他的請求只能處于阻塞狀態。另外如果在同一個域名下同時有10個請求發生，那么其中4個請求會進入排隊等待狀態，直至進行中的請求完成。
Spriting合并多張小圖為一張大圖,再用JavaScript或者CSS將小圖重新“切割”出來的技術。
內聯(Inlining)是另外一種防止發送很多小圖請求的技巧，將圖片的原始數據嵌入在CSS文件里面的URL里，減少網絡請求次數。

.icon1 {
 background: url(data:image/png;base64,<data>) 
no
-repeat;
 }
.icon2 {
 background: url(data:image/png;base64,<data>) 
no
-repeat;
 }

拼接(Concatenation)將多個體積較小的JavaScript使用webpack等工具打包成1個體積更大的JavaScript文件,但如果其中1個文件的改動就會導致大量數據被重新下載多個文件。

2.無狀態特性--帶來的巨大HTTP頭部

由于報文Header一般會攜帶"User Agent""Cookie""Accept""Server"等許多固定的頭字段（如下圖），多達幾百字節甚至上千字節，但Body卻經常只有幾十字節（比如GET請求、 204/301/304響應），成了不折不扣的“大頭兒子”。Header里攜帶的內容過大，在一定程度上增加了傳輸的成本。更要命的是，成千上萬的請求響應報文里有很多字段值都是重復的，非常浪費。

3.明文傳輸--帶來的不安全性

HTTP/1.1在傳輸數據時，所有傳輸的內容都是明文，客戶端和服務器端都無法驗證對方的身份，這在一定程度上無法保證數據的安全性。

你有沒有聽說過"免費WiFi陷阱”之類的新聞呢？黑客就是利用了HTTP明文傳輸的缺點，在公共場所架設一個WiFi熱點開始“釣魚”，誘騙網民上網。一旦你連上了這個WiFi熱點，所有的流量都會被截獲保存，里面如果有銀行卡號、網站密碼等敏感信息的話那就危險了，黑客拿到了這些數據就可以冒充你為所欲為。

4.不支持服務器推送消息

三、SPDY 協議與 HTTP/2 簡介

1.SPDY 協議

上面我們提到,由于HTTP/1.x的缺陷，我們會引入雪碧圖、將小圖內聯、使用多個域名等等的方式來提高性能。不過這些優化都繞開了協議，直到2009年，谷歌公開了自行研發的 SPDY 協議，主要解決HTTP/1.1效率不高的問題。谷歌推出SPDY，才算是正式改造HTTP協議本身。降低延遲，壓縮header等等，SPDY的實踐證明了這些優化的效果，也最終帶來HTTP/2的誕生。

HTTP/1.1有兩個主要的缺點：安全不足和性能不高，由于背負著 HTTP/1.x 龐大的歷史包袱,所以協議的修改,兼容性是首要考慮的目標，否則就會破壞互聯網上無數現有的資產。如上圖所示, SPDY位于HTTP之下，TCP和SSL之上，這樣可以輕松兼容老版本的HTTP協議(將HTTP1.x的內容封裝成一種新的frame格式)，同時可以使用已有的SSL功能。

SPDY 協議在Chrome瀏覽器上證明可行以后，就被當作 HTTP/2 的基礎，主要特性都在 HTTP/2 之中得到繼承。

2.HTTP/2 簡介

2015年，HTTP/2 發布。HTTP/2是現行HTTP協議（HTTP/1.x）的替代，但它不是重寫，HTTP方法/狀態碼/語義都與HTTP/1.x一樣。HTTP/2基于SPDY，專注于性能，最大的一個目標是在用戶和網站間只用一個連接（connection）。從目前的情況來看，國內外一些排名靠前的站點基本都實現了HTTP/2的部署，使用HTTP/2能帶來20%~60%的效率提升。

HTTP/2由兩個規范（Specification）組成：

Hypertext Transfer Protocol version 2 - RFC7540
HPACK - Header Compression for HTTP/2 - RFC7541

四、HTTP/2 新特性

1.二進制傳輸

HTTP/2傳輸數據量的大幅減少,主要有兩個原因:以二進制方式傳輸和Header 壓縮。我們先來介紹二進制傳輸,HTTP/2 采用二進制格式傳輸數據，而非HTTP/1.x 里純文本形式的報文，二進制協議解析起來更高效。HTTP/2 將請求和響應數據分割為更小的幀，并且它們采用二進制編碼。

它把TCP協議的部分特性挪到了應用層，把原來的"Header+Body"的消息"打散"為數個小片的二進制"幀"(Frame),用"HEADERS"幀存放頭數據、"DATA"幀存放實體數據。HTP/2數據分幀后"Header+Body"的報文結構就完全消失了，協議看到的只是一個個的"碎片"。

HTTP/2 中，同域名下所有通信都在單個連接上完成，該連接可以承載任意數量的雙向數據流。每個數據流都以消息的形式發送，而消息又由一個或多個幀組成。多個幀之間可以亂序發送，根據幀首部的流標識可以重新組裝。

2.Header 壓縮

HTTP/2并沒有使用傳統的壓縮算法，而是開發了專門的"HPACK”算法，在客戶端和服務器兩端建立“字典”，用索引號表示重復的字符串，還采用哈夫曼編碼來壓縮整數和字符串，可以達到50%~90%的高壓縮率。

具體來說:

在客戶端和服務器端使用“首部表”來跟蹤和存儲之前發送的鍵-值對，對于相同的數據，不再通過每次請求和響應發送；
首部表在HTTP/2的連接存續期內始終存在，由客戶端和服務器共同漸進地更新;
每個新的首部鍵-值對要么被追加到當前表的末尾，要么替換表中之前的值

例如下圖中的兩個請求，請求一發送了所有的頭部字段，第二個請求則只需要發送差異數據，這樣可以減少冗余數據，降低開銷

3.多路復用

在 HTTP/2 中引入了多路復用的技術。多路復用很好的解決了瀏覽器限制同一個域名下的請求數量的問題，同時也接更容易實現全速傳輸，畢竟新開一個 TCP 連接都需要慢慢提升傳輸速度。

大家可以通過該鏈接直觀感受下 HTTP/2 比 HTTP/1 到底快了多少。

在 HTTP/2 中，有了二進制分幀之后，HTTP /2 不再依賴 TCP 鏈接去實現多流并行了，在 HTTP/2中,

同域名下所有通信都在單個連接上完成。
單個連接可以承載任意數量的雙向數據流。
數據流以消息的形式發送，而消息又由一個或多個幀組成，多個幀之間可以亂序發送，因為根據幀首部的流標識可以重新組裝。

這一特性，使性能有了極大提升：

同個域名只需要占用一個 TCP 連接，使用一個連接并行發送多個請求和響應,這樣整個頁面資源的下載過程只需要一次慢啟動，同時也避免了多個TCP連接競爭帶寬所帶來的問題。
并行交錯地發送多個請求/響應，請求/響應之間互不影響。
在HTTP/2中，每個請求都可以帶一個31bit的優先值，0表示最高優先級，數值越大優先級越低。有了這個優先值，客戶端和服務器就可以在處理不同的流時采取不同的策略，以最優的方式發送流、消息和幀。

如上圖所示，多路復用的技術可以只通過一個 TCP 連接就可以傳輸所有的請求數據。

4.Server Push

HTTP2還在一定程度上改變了傳統的“請求-應答”工作模式，服務器不再是完全被動地響應請求，也可以新建“流”主動向客戶端發送消息。比如，在瀏覽器剛請求HTML的時候就提前把可能會用到的JS、CSS文件發給客戶端，減少等待的延遲，這被稱為"服務器推送"（ Server Push，也叫 Cache push）

例如下圖所示,服務端主動把JS和CSS文件推送給客戶端，而不需要客戶端解析HTML時再發送這些請求。

另外需要補充的是,服務端可以主動推送，客戶端也有權利選擇是否接收。如果服務端推送的資源已經被瀏覽器緩存過，瀏覽器可以通過發送RST_STREAM幀來拒收。主動推送也遵守同源策略，換句話說，服務器不能隨便將第三方資源推送給客戶端，而必須是經過雙方確認才行。

5.提高安全性

出于兼容的考慮，HTTP/2延續了HTTP/1的“明文”特點，可以像以前一樣使用明文傳輸數據，不強制使用加密通信，不過格式還是二進制，只是不需要解密。

但由于HTTPS已經是大勢所趨，而且主流的瀏覽器Chrome、Firefox等都公開宣布只支持加密的HTTP/2，所以“事實上”的HTTP/2是加密的。也就是說，互聯網上通常所能見到的HTTP/2都是使用"https”協議名，跑在TLS上面。HTTP/2協議定義了兩個字符串標識符：“h2"表示加密的HTTP/2，“h2c”表示明文的HTTP/2。

六、HTTP/3 新特性

1.HTTP/2 的缺點

雖然 HTTP/2 解決了很多之前舊版本的問題，但是它還是存在一個巨大的問題，主要是底層支撐的 TCP 協議造成的。HTTP/2的缺點主要有以下幾點：

TCP 以及 TCP+TLS建立連接的延時

HTTP/2都是使用TCP協議來傳輸的，而如果使用HTTPS的話，還需要使用TLS協議進行安全傳輸，而使用TLS也需要一個握手過程，這樣就需要有兩個握手延遲過程：

①在建立TCP連接的時候，需要和服務器進行三次握手來確認連接成功，也就是說需要在消耗完1.5個RTT之后才能進行數據傳輸。

②進行TLS連接，TLS有兩個版本——TLS1.2和TLS1.3，每個版本建立連接所花的時間不同，大致是需要1~2個RTT。

總之，在傳輸數據之前，我們需要花掉 3～4 個 RTT。

TCP的隊頭阻塞并沒有徹底解決

上文我們提到在HTTP/2中，多個請求是跑在一個TCP管道中的。但當出現了丟包時，HTTP/2 的表現反倒不如 HTTP/1 了。因為TCP為了保證可靠傳輸，有個特別的“丟包重傳”機制，丟失的包必須要等待重新傳輸確認，HTTP/2出現丟包時，整個 TCP 都要開始等待重傳，那么就會阻塞該TCP連接中的所有請求（如下圖）。而對于 HTTP/1.1 來說，可以開啟多個 TCP 連接，出現這種情況反到只會影響其中一個連接，剩余的 TCP 連接還可以正常傳輸數據。

讀到這里，可能就會有人考慮為什么不直接去修改 TCP 協議？其實這已經是一件不可能完成的任務了。因為 TCP 存在的時間實在太長，已經充斥在各種設備中，并且這個協議是由操作系統實現的，更新起來不大現實。

2.HTTP/3簡介

Google 在推SPDY的時候就已經意識到了這些問題，于是就另起爐灶搞了一個基于 UDP 協議的“QUIC”協議，讓HTTP跑在QUIC上而不是TCP上。而這個“HTTP over QUIC”就是HTTP協議的下一個大版本，HTTP/3。它在HTTP/2的基礎上又實現了質的飛躍，真正“完美”地解決了“隊頭阻塞”問題。

QUIC 雖然基于 UDP，但是在原本的基礎上新增了很多功能，接下來我們重點介紹幾個QUIC新功能。不過HTTP/3目前還處于草案階段，正式發布前可能會有變動，所以本文盡量不涉及那些不穩定的細節。

3.QUIC新功能

上面我們提到QUIC基于UDP，而UDP是“無連接”的，根本就不需要“握手”和“揮手”，所以就比TCP來得快。此外QUIC也實現了可靠傳輸，保證數據一定能夠抵達目的地。它還引入了類似HTTP/2的“流”和“多路復用”，單個“流"是有序的，可能會因為丟包而阻塞，但其他“流”不會受到影響。具體來說QUIC協議有以下特點：

實現了類似TCP的流量控制、傳輸可靠性的功能。

雖然UDP不提供可靠性的傳輸，但QUIC在UDP的基礎之上增加了一層來保證數據可靠性傳輸。它提供了數據包重傳、擁塞控制以及其他一些TCP中存在的特性。

實現了快速握手功能。

由于QUIC是基于UDP的，所以QUIC可以實現使用0-RTT或者1-RTT來建立連接，這意味著QUIC可以用最快的速度來發送和接收數據，這樣可以大大提升首次打開頁面的速度。0RTT 建連可以說是 QUIC 相比 HTTP2 最大的性能優勢。

集成了TLS加密功能。

目前QUIC使用的是TLS1.3，相較于早期版本TLS1.3有更多的優點，其中最重要的一點是減少了握手所花費的RTT個數。

多路復用，徹底解決TCP中隊頭阻塞的問題

和TCP不同，QUIC實現了在同一物理連接上可以有多個獨立的邏輯數據流（如下圖）。實現了數據流的單獨傳輸，就解決了TCP中隊頭阻塞的問題。

七、總結

HTTP/1.1有兩個主要的缺點：安全不足和性能不高。
HTTP/2完全兼容HTTP/1，是“更安全的HTTP、更快的HTTPS"，頭部壓縮、多路復用等技術可以充分利用帶寬，降低延遲，從而大幅度提高上網體驗；
QUIC 基于 UDP 實現，是 HTTP/3 中的底層支撐協議，該協議基于 UDP，又取了 TCP 中的精華，實現了即快又可靠的協議。

參考文章

透視HTTP協議
Web協議詳解與抓包實戰
瀏覽器工作原理與實踐
HTTP2講解
一文讀懂 HTTP/2 特性
科普：QUIC協議原理分析
HTTP2簡介和基于HTTP2的Web優化

近在很多博客上都看到有關于WordPress集成百度實時推送的功能，雖然不知道具體效果如何，但是我想增加這個功能應該總不會是壞事吧，所以就給自己的站點添加試試，以便下次更新Three主題的時候集成進去。

具體操作步驟如下：

1、獲取token值

我們只需要登錄百度站長平臺》網頁抓取》點擊【鏈接提交】，在右邊的頁面中的“鏈接提交”中選擇需要添加百度實時推送功能的站點，然后就可以看到這個站點的token值了。

PS：一個百度站長賬號有多個站點，這幾個站點的token值都是一樣的。

2、修改代碼，添加百度實時推送功能

把以下代碼中的token值（xxxxxxxxxxx）改為我們第一步獲取的token值（其他的不用修改），然后把這些代碼添加到主題目錄下的 functions.php 文件最后一個?>之前即可。

/**
* WordPress發布文章主動推送到百度，加快收錄保護原創【WordPress通用方式】
* 文章地址：http://zhangge.net/5041.html
*/
if(!function_exists('Baidu_Submit')){
function Baidu_Submit($post_ID) {
$WEB_TOKEN='xxxxxxxxxxx'; //這里請換成你的網站的百度主動推送的token值
$WEB_DOMAIN=get_option('home');
//已成功推送的文章不再推送
if(get_post_meta($post_ID,'Baidusubmit',true)==1) return;
$url=get_permalink($post_ID);
$api='http://data.zz.baidu.com/urls?site='.$WEB_DOMAIN.'&token='.$WEB_TOKEN;
$request=new WP_Http;
$result=$request->request( $api , array( 'method'=> 'POST', 'body'=> $url , 'headers'=> 'Content-Type: text/plain') );
$result=json_decode($result['body'],true);
//如果推送成功則在文章新增自定義欄目Baidusubmit，值為1
if (array_key_exists('success',$result)) {
add_post_meta($post_ID, 'Baidusubmit', 1, true);
}
}
add_action('publish_post', 'Baidu_Submit', 0);
}

現在我們發布新文章，文章地址就會被主動推送到百度。被成功推送的文章，將自動出現如下自定義欄目：

為避免代碼重復推送的尷尬，如果你需要更新文章再次推送數據，那么在保存/更新文章之前，刪除或修改這個自定義欄目即可再次被推送。

Ps：雖然，主動推送的各種方法都支持一次推送多條數據，從我個人的經驗來看，對于老文章沒必要再次推送，頻繁推送容易導致百度“翻臉”！

特別說明：

如果按以上步驟正確操作后，在發布新文章時自定義欄目中不會出現我們期望的baidusubmit，說明實時推送給百度不成功，說明所使用的主機的 curl_exec()函數被禁用了。這個時候，我們只需要把以下代碼替換掉第二步的代碼即可。

/**
* WordPress發布文章主動推送到百度，加快收錄保護原創【file_get_contents方式】
* 文章地址：http://zhangge.net/5041.html
*/
if(!function_exists('Baidu_Submit')) {
function Baidu_Submit($post_ID) {
$WEB_TOKEN='xxxxxxxxx'; //這里換成你的網站的百度主動推送的token值
$WEB_DOMAIN=get_option('home');
//已成功推送的文章不再推送
if(get_post_meta($post_ID,'Baidusubmit',true)==1) return;
$url=get_permalink($post_ID);
$api='http://data.zz.baidu.com/urls?site='.$WEB_DOMAIN.'&token='.$WEB_TOKEN;
$data=array (
'http'=> array (
'method'=> 'POST',
'header'=> "Content-Type: text/plain",
"Content-Length: ".strlen($url)."rn",
'content'=> $url
)
);
$data=stream_context_create($data);
$result=file_get_contents($api, false, $data);
$result=json_decode($result,true);
//如果推送成功則在文章新增自定義欄目Baidusubmit，值為1
if (array_key_exists('success',$result)) {
add_post_meta($post_ID, 'Baidusubmit', 1, true);
}
}
add_action('publish_post', 'Baidu_Submit', 0);
}

文中涉及的技術和代碼均來自于張戈博主分享的《WordPress發布文章主動推送到百度，加快收錄保護原創》。

在線咨詢

上一篇：響應式數據信息安全網站模板源碼-青檸資源網qnziy
下一篇：Golang-實現一個簡單的DSL解釋器

您的項目需求

*請認真填寫需求信息，我們會在24小時內與您取得聯系。

整合營銷服務商

spring boot集成WebSocket實時輸出

您的項目需求