⑴ SRS RTMP 發布和播放代碼解析
主程序啟動後，會根據config判斷是控制台模式還是後台運行模式，之後進入run_hybrid_server啟動各種服務,rtmp,http,https,rtc等等服務；
SrsServerAdapter 各種伺服器的適配，rtmp，http，https等，RtcServerAdapter 是webrtc的服務，此篇我們就分析rtmp服務，所以進入SrsServerAdapter後，就會進行各種伺服器的監聽，調用到，後調用
SrsServer::listen() -> SrsBufferListener::listen -> new SrsTcpListener(this, ip, port)
rtmp使用的是tcp，所以就開始監聽tcp了
srs_tcp_listen創建socket並監聽
之後new SrsSTCoroutine("tcp", this)創建協程，調用start會調用SrsTcpListener::cycle()；
具體流程是
協程裡面處理accept等待客戶端的連接，客戶端連接請求後，開始回調on_tcp_client，即調用 SrsBufferListener::on_tcp_client()
調用 SrsServer::accept_client
調用fd_to_resource，根據type創建不同的ISrsStartableConneciton，這里rtmp是SrsListenerRtmpStream，所以返回new SrsRtmpConn 而後調用 SrsRtmpConn::start
class SrsRtmpConn : virtual public ISrsCoroutineHandler
所以調用到SrsRtmpConn::cycle(),裡面調用SrsRtmpConn::do_cycle()
開始握手，建立rtmp連接，進入SrsRtmpConn::service_cycle()
建立連接後，設置rtmp
set_window_ack_size
set_peer_bandwidth
set_chunk_size
調用 SrsRtmpConn::stream_service_cycle()
首先進行rtmp->identify_client 客戶端的身份識別
然後再根據不同的客戶端類型type進入不同的分支
SrsRtmpConnPlay 客戶端播流。
SrsRtmpConnFMLEPublish Rtmp推流到伺服器。
SrsRtmpConnHaivisionPublish 應該是海康威視推流到伺服器
SrsRtmpConnFlashPublish Flash推流到伺服器。
我們先看推流 SrsRtmpConnFMLEPublish
首先 start_fmle_publish 創建流
然後進入 publishing
SrsPublishRecvThread rtrd(rtmp, req, srs_netfd_fileno(stfd), 0, this, source, _srs_context->get_id());
err = do_publishing(source, &rtrd);
SrsPublishRecvThread 有
SrsRecvThread trd;
SrsRtmpServer* rtmp;
class SrsRecvThread : public ISrsCoroutineHandler
所以rtrd->start後，會調用SrsRecvThread::cycle()再調用do_cycle()
rtmp->recv_message讀取數據->SrsProtocol::recv_message ->
pumper->consume 調回 SrsRtmpConn::handle_publish_message(SrsSource* source, SrsCommonMessage* msg)
然後調用 process_publish_message
如果是edge邊緣伺服器，直接推流回源到源伺服器
處理audio數據
處理video數據
我們先看處理video數據
SrsCommonMessage* shared_video 轉換為 SrsSharedPtrMessage msg;
mix_correct是混合單增演算法，解決音頻和視頻混合單增的問題
這里沒有設置，就直接走on_video_imp
首先判斷是不是sequence header, 如果是，判斷跟之前的有沒有一樣，一樣，那就只緩存一次，根據源碼可知，音視頻的metadata只發一次，如果有新的拉流端需求，怎樣更新呢？
緩存h264 sequence header, hls分發，dvs分發，forwarders推流等，之後就客戶端消費者分發，如果有客戶端請求播放，那就會有consumer了，就可以進入consumer->enqueue
每個SrsConsumer消費者擁有獨立的SrsMessageQueue* queue隊列。內部隊列實現實際上是SrsFastVector msgs
SrsMessageQueue有數量大小限制，當隊列滿的時候刪除丟棄舊的messages：
隊列大小限制queue_size設置為配置文件中的"queue_length"。如果沒設置則默認#define SRS_PERF_PLAY_QUEUE 30。
max_queue_size = (int)(queue_size * 1000);
推流到此就結束了，而後播放端請求拉流，前面的基本一致，從
srs_error_t SrsRtmpConn::stream_service_cycle()
{
srs_error_t err = srs_success;
}
會走 SrsRtmpConnPlay分支
SrsRtmpConn::do_playing
SrsConsumer::mp_packets
SrsMessageQueue::mp_packets
即前面的SrsMessageQueue* queue裡面取數據了
SrsRtmpServer::send_and_free_messages
⑵ Android：深入剖析圖片載入庫Glide緩存功能(源碼分析）
Glide 需要緩存的 圖片資源 分為兩類：
Glide 的緩存機制使得 Glide 具備非常好的圖片緩存效果，從而使得具備較高的圖片載入效率。
下面，我將根據 Glide 緩存流程中的每個步驟 進行源碼分析。
至此， Glide 的圖片緩存 Key 生成完畢。
至此，創建好了緩存對象 LruResourceCache
即：
源碼分析如下：
若上述兩個方法都沒獲取到緩存圖片時（即內存緩存里沒有該圖片的緩存），就開啟新線程載入圖片。
若無法從 內存緩存 里 獲得緩存的圖片， Glide 就會採用第2級緩存：磁碟緩存 去獲取緩存圖片
寫入 內存緩存分為：寫入 弱引用緩存 & LruCache 演算法的緩存
寫入 LruCache 演算法 內存緩存的原理：包含圖片資源 resource 的 EngineResource 對象的一個引用機制：
所以：
至此，實現了：
至此， Glide 的圖片緩存流程解析完畢。
Android圖片載入的那些事：為什麼你的Glide 緩存沒有起作用？
不定期分享關於 安卓開發 的干貨，追求 短、平、快 ，但 卻不缺深度 。
⑶ 直播系統源碼開發，究竟是怎樣的一個過程
首先一個基本的直播間源碼一般包含三個大模塊：主播端、播放端以及直播間服務端。
一、首先是主播端，它是組成視頻流的根源，由一系列步驟構成：
1、根據移動端的設備來採集數據。
2、將收集的這種視頻開展一系列的前期處理，例如圖片水印、美膚和動畫特效ps濾鏡等處理。
3、將處理後的視頻數據轉化成可收看可傳送的視頻流；
4、傳輸拉流，將要壓縮後的視頻流根據網路通道傳送出來解壓後播放。
二、其次是播放端，播放端的作用有兩個層面
1、飢族掘第一個層面是至關重要的要求，它牽涉到一些十分重要的指標，例如秒開，在許多直播間源碼開發的情景之中都要保留好的體驗爛核度，隨後是針對一些關鍵內容的版權法。為了更好地做到更強的實際效果，大家還必須相互配合伺服器端做智能解析，這在一些情景下也是至關重要的要求。
2、另一層面是業務流程層面。也即業務流程層面的作用，針對一個社交媒體直播間商品而言，在播放端，觀眾們期待可以即時地見到主播端推過來的視頻流，而且和穗銀主播及其別的觀眾們產生一定的互動交流，包括一些像關注、閑聊和視頻彈幕那樣的功能，還有禮物打賞的變現。
三、最後是直播間服務端，展示的最關鍵功能是搜集主播端視頻拉流，並將其推送給用戶端。
1、除開這一關鍵作用，直播間源碼的開發也有許多運營的要求，例如身份驗證，視頻連線和即時轉換格式，全自動鑒黃，多屏顯示合一，及其雲空間視頻錄制儲存等作用。
2、此外，針對一個主播端發布的視頻，中間必須歷經一些階段才可以傳送到播放端，因而對中間商的品質開展監管，及其依據這種監管來開展智能化生產調度，也是十分關鍵的訴求。
3、事實上不論是主播端還是播放端，她們的要求都不只是視頻拍攝和播放視頻那麼簡易。在這個關鍵要求被解決以後，也有許多重要要求必須被考慮。直播間源碼的開發中除開這三大控制模塊以外，還必須完成一個業務流程伺服器端來開展拉流和播放操縱，這就是直播間搭建的幾大模塊。
⑷ Gson源碼解析
Gson 是一個 Java 庫，可用於將 Java 對象轉換為其 JSON 表示形式。它還可用於將 JSON 字元串轉換為等效的 Java 對象。
地址 https://github.com/google/gson
TypeAdapter是Gson的核心，它的設計是一個 適配器模式
因為 Json 數據介面和 Type 的介面兩者是無法兼容，因此 TypeAdapter 就是來實現兼容，把 json 數據讀到 Type 中，把 Type 中的數據寫入到 Json 里。
Gson會為每一種類型創建一個TypeAdapter，同樣的，每一個Type都對應唯一一個TypeAdapter
而所有Type(類型)，在Gson中又可以分為基本類型和復合類型（非基本類型）
在 Gson 中封裝了不同類型的讀寫的業務組裝類是各個 TypeAdapter(適配器)
從緩棚姿喊存獲取 TypeAdapter 對象，存在者直接返回
通過ThreadLocal緩存TypeAdapter對象，不同的線程使用緩存來解析的時候互不影響。
如果不存在緩存，那麼從factories列表鏈野里查找，factories是在創建Gson對象時初始化，添加了很多用於創建TypeAdapter對象的TypeAdapterFactory。
在Gson中，Java對象與JSON字元串之間的轉換是通過字元流來進行操作的。JsonReader繼承於Reader用來讀取字元，JsonWriter繼承於Writer用來寫入字元。
進行數據的寫入 用於反序列化操作
該類是一個抽象冊廳類，代表著json串的某一個元素。這個元素可以是一個Json(JsonObject)、可以是一個數組(JsonArray)、可以是一個Java的基本類(JsonPrimitive)、當然也可以為null(JsonNull);JsonObject,JsonArray,JsonPrimitive，JsonNull都是JsonElement這個抽象類的子類。JsonElement提供了一系列的方法來判斷當前的JsonElement。
各個JsonElement的關系可以用如下圖表示：
JsonObject對象可以看成 name/values的集合，而這寫values就是一個個JsonElement,他們的結構可以
用如下圖表示：
Expected BEGIN_ARRAY but was STRING at line 1 column 27
這種錯誤一般都是原來是一個欄位需要是數組類型，但是事實上給的是」」,導致的
解決辦法
⑸ 直播源碼，直播系統如何開發搭建與運營
直播的火爆讓各行各業對直播這塊新市場垂涎不已，而進軍直播市場的第一步——直播系統源碼卻讓企業頭疼不已，那麼直播系統源碼如何進行開發呢？一、媒體模塊：1、採集：通過SDK介面，直接從用戶設備採集視頻、音頻等數據，視頻采樣數據一般採用RGB或YUV格式、音頻采樣數據一般採用PCM格式。2、預處理：對採集到的數據通過SDK層面介面進行潤化處理，主要是圖像方面的處理，如美顏、水印、濾鏡等，GPU優化提速，平衡手機功耗及效果。3、編碼：對採集到的數據進行壓縮編碼，比較常用的視頻編碼為H.264，音頻為AAC，在解析度、幀數、碼率等參數設計上找到最佳平衡點，使之匹配推流所需協議，提高上傳效率。4、推拉流：推流就是將壓縮後的音視頻變為流數據，上傳至伺服器。拉流即通過播放端獲取碼流，從服務端拉取支持以RTMP、HTTP-FLV及HLS等協議的音視頻流。5、解碼：對拉流獲取封裝的視頻數據進行高性能解碼，讓直播更流暢。6、播放：解碼後的音頻數據即可在播放端進行播放，支持包括MP4、FLV、M3U8等多樣視頻播放格式。
二、服務模塊
1、聊天系統：包括聊天室功能、彈幕、私聊
2、禮物系統：禮物的收發，禮物的圖形
3、支付系統：充值、提現、收益兌換
4、運行系統：提供直播方案
5、安全系統：實名認證、截圖、自動鑒黃、錄制、回播、禁播6、統計系統：點擊量、收益、流量統計
三、管理模塊
1、前端：移動端、PC端頁面效果展示設計，維護
2、後台：管理運營，資料庫管理
我們都知道，搭建一個完整的直播平台過程包括：採集、處理、編碼、推流、分發、解碼和播放，搭建直播平台是需要藉助三方賬號的支持的，比如伺服器、推拉流、簡訊服務等，搭建直播平台都也是如此，除了本身的系統功能外，想用直播系統源碼搭建平台，還需要一些三方的協助：
1、 CDN，提供視頻加速和視頻分發服務，一般視頻cdn可以使用騰訊的直播cdn加速服務，也可以使用ucloud的視頻cnd加速服務，具體費用咨詢對應廠商客服。只要是支持rtmp直播協議的就可以。
2、 美顏SDK，實現美顏功能
3、 支付賬號，支付寶支付和微信支付的支付賬號
4、 雲存儲，大量的錄播視頻、短視頻、直播間實時互動消息，需要動態存儲和靜態存儲的支持。
5、登錄和分享的賬號，微信和qq的登錄和分享
6、 蘋果公司開發者賬號，分發和蘋果上架使用。
眾多的三方介面接入也是直播系統源碼平台後期能夠正常運營的先決條件，好在大部分直播系統源碼服務商都可以提供協助接入服務免去了很多後顧之憂，因此搭建運營直播系統源碼平台不僅僅要選對直播系統源碼，還要選擇正確的服務商。
⑹ 直播源代理源碼如何使用
直播源代理源碼使用方法如下：
一、首先是主播端，即推流端。
主要涉及到音視頻的採集技術，這方面建議採用大廠商的直播SDK，比如騰訊直播SDK，阿里雲直播SDK，七牛SDK等效果都非常不錯。
二、中間環節是服務端，也即後台。
主要作用就是對直播間、主播、禮物、充值等進行管理。
三、最後就是推流端，即拉流端，用戶觀看端。
這個也可以採用現成的SDK來完成（如第一條的）。
技術難點主要集中於美顏技術，音視頻混流技術，其他都比較簡單，按照步驟文檔一步一步來就行
⑺ 視頻直播類app源碼
一、手機直播系統源碼開發實現視頻直播主要有以下四步：
1）前端採集編碼設備：提供直播信號源的採集和編碼壓縮功能，並將信號推送到直播流媒體伺服器上。
2）直播流媒體伺服器：負責直播流的發布和轉播分發功能。
3）WEB伺服器：實現直播節目在終端上的展現。
4）終端設備：包括PC和移動終端。編碼和協議是實現直播的重要環節：1）網路協議：主要有3種a.RTSP（RealTimeStreamingProtocol）是用來控制聲音或影像的多媒體串流協議,由RealNetworks和Netscape共同提出的；b.RTMP(RealTimeMessagingProtocol):實時消息傳送協議是Adobe公司為Flash播放器和伺服器之間音頻、視頻和數據傳輸開發的開放協議；c.HLS(HTTPLiveStreaming):是蘋果公司(AppleInc.)實現的基於HTTP的流媒體傳輸協議；2）視頻編碼:Mpeg4,H264等3）音頻編碼:Mp3,AAC等4）視頻解析度:標清通常指的是640×480（或768×480）；高清指的是1280×720；全高清指的是1920×1080；超高清3840×2160。
二、直播系統源碼搭建伺服器部署重點
直播系統源碼有哪幾塊組成，視頻直播的過程一般可以分為採集、前處理、編碼、傳輸、解碼、渲染這幾個環節，經過這幾個環節之後，我們就可以通過PC端或者移閉橘動端進行視頻直播的觀看。直播系統在搭建時會用到多個業務伺服器，共同完成直播系統的業務邏輯流程。通常在伺服器部署時會採用動靜分離分布式部署方式，保障了直播平台的穩定運行。主要用到以下的業務伺服器。
1）消息伺服器：主要用於消息推送，給用戶推送房間聊天消息、私信消息。
2）業務伺服器：手機直播的業務部分、好友關系、直播管理、貨幣系統、禮物系統等。
3）視頻伺服器：視頻直播、點播、轉碼、存儲和點播等。
4）IM即時聊天：使用Node.js服務自主搭建部署聊天伺服器。
5）視頻流（流媒體伺服器）：建議採用第三方CDN，開通賬號即可使用。關於CDN方面的內容，我們會在以後的內容中做重點介紹。
6）業務伺服器：伍態顫網站邏輯基於php-tlinkphp、thinkcmf、mysql、redis。MYSQL服務提供靜態數據的存儲，REDIS服務提供數據的緩存、存儲動態數據。
以上便是對直播系統源碼如何實現視頻直播以及搭建伺服器的簡單介紹。搭建直播開發平台之前就是找到一款優質的直播系統源碼，直播系統源碼開發原理比其他軟體更加復雜，而且相對於技術以及其他方面都會有一定的要求。直播系統源碼的穩定性和安全性決定了後期搭建出的直播平台的流暢度、高並發承載及用戶的產品體驗，所以選擇直播源碼的時候一定不要為了貪圖價格便宜，而腔敗選擇安全性低，系統功能不會正常更新，bug一堆的源碼。直播系統源碼的開發需要經過推流端(採集、前處理)、服務端處理(編碼、轉碼、錄制、截圖、鑒黃)、播放器(拉流、解碼、渲染和互動系統)。望採納，謝謝
⑻ 一文解密Kafka，Kafka源碼設計與實現原理剖析，真正的通俗易懂
Apache Kafka （簡稱Kafka ）最早是由Linkedln開源出來的分布式消息系統，現在是Apache旗下的一個子項目，並且已經成為開冊、領域應用最廣泛的消息系統之 Kafka社區也非常活躍，從 版本開始， Kafka 的標語已經從「一個高吞吐量、分布式的消息系統」改為「一個分布式的流平台」
關於Kafka，我打算從入門開始講起，一直到它的底層實現邏輯個原理以及源碼，建議大家花點耐心，從頭開始看，相信會對你有所收獲。
作為 個流式數據平台，最重要的是要具備下面 個特點
消息系統：
消息系統 也叫作消息隊列）主要有兩種消息模型：隊列和發布訂Kafka使用消費組（ consumer group ）統 上面兩種消息模型 Kafka使用隊列模型時，它可以將處理 作為平均分配給消費組中的消費者成員
下面我們會從 個角度分析Kafka 的幾個基本概念，並嘗試解決下面 個問題
消息由生產者發布到 fk 集群後，會被消費者消費 消息的消費模型有兩種：推送模型（ pu和拉取模型（ pull 基於推送模型的消息系統，由消息代理記錄消費者的消費狀態 消息代理在將消息推送到消費者後 標記這條消息為已消費
但這種方式無法很好地保證消息的處理語義 比如，消息代理把消息發送出去後，當消費進程掛掉或者由於網路原因沒有收到這條消息時，就有可能造成消息丟失（因為消息代理已經 這條消息標記為自己消費了，但實際上這條消息並沒有被實際處理） 如果要保證消息的處理語義，消息代理發送完消息後，要設置狀態為「已發送」，只有收到消費者的確認請求後才更新為「已消費」，這就需要在消息代理中記錄所有消息的消費狀態，這種做法也是不可取的
Kafka每個主題的多個分區日誌分布式地存儲在Kafka集群上，同時為了故障容錯，每個分區都會以副本的方式復制到多個消息代理節點上 其中一個節點會作為主副本（ Leader ），其 節點作為備份副本（ Follower ，也叫作從副本）
主副本會負責所有的客戶端讀寫操作，備份副本僅僅從主副本同步數據 當主副本 IH 現在故障時，備份副本中的 副本會被選擇為新的主副本 因為每個分區的副本中只有主副本接受讀寫，所以每個服務端都會作為某些分區的主副本，以及另外一些分區的備份副本這樣Kafka集群的所有服務端整體上對客戶端是負載均衡的
消息系統通常由生產者「pro ucer 消費者（ co sumer ）和消息代理（ broke 大部分組成，生產者會將消息寫入消息代理，消費者會從消息代理中讀取消息 對於消息代理而言，生產者和消費者都屬於客戶端：生產者和消費者會發送客戶端請求給服務端，服務端的處理分別是存儲消息和獲取消息，最後服務端返回響應結果給客戶端
新的生產者應用程序使用 af aP oce 對象代表 個生產者客戶端進程 生產者要發送消息，並不是直接發送給 務端 ，而是先在客戶端 消息放入隊列 然後 一個 息發送線程從隊列中消息，以 鹽的方式發送消息給服務端 Kafka的記 集器（ Reco dACCUl'lUlato ）負責緩存生產者客戶端產生的消息，發送線程（ Sende ）負責讀取 集器的批 過網路發送給服務端為了保證客戶端 絡請求 快速 應， Kafka 用選擇器（ Selecto 絡連接 讀寫 理，使網路連接（ Netwo kCl i.ent ）處理客戶端 絡請求
追加消息到記錄收集器時按照分區進行分組，並放到batches集合中，每個分區的隊列都保存了將發送到這個分區對應節點上的 記錄，客戶端的發送線程可 只使用 Sende 線程迭 batches的每個分區，獲取分區對應的主劇本節點，取出分區對應的 列中的批記錄就可以發送消息了
消息發送線程有兩種消息發送方式 按照分區直接發送 按照分區的目標節點發迭 假設有兩台伺服器， 題有 個分區，那麼每台伺服器就有 個分區 ，消息發送線程迭代batches的每個分 接往分區的主副本節點發送消息，總共會有 個請求 所示，我 先按照分區的主副本節點進行分組， 屬於同 個節點的所有分區放在一起，總共只有兩個請求做法可以大大減少網路的開銷
消息系統由生產者 存儲系統和消費者組成 章分析了生產者發送消息給服務端的過程，本章分析消費者從服務端存儲系統讀取生產者寫入消息的過程 首先我 來了解消費者的 些基礎知識
作為分布式的消息系統， Kafka支持多個生產者和多個消費者，生產者可以將消息發布到集群中不同節點的不同分區上；「肖費者也可以消費集群中多個節點的多個分區上的消息 寫消息時，多個生產者可以 到同 個分區 讀消息時，如果多個消費者同時讀取 個分區，為了保證將日誌文件的不同數據分配給不同的消費者，需要採用加鎖 同步等方式，在分區級別的日誌文件上做些控制
相反，如果約定「同 個分區只可被 個消費者處理」，就不需要加鎖同步了，從而可提升消費者的處理能力 而且這也並不違反消息的處理語義：原先需要多個消費者處理，現在交給一個消費者處理也是可以的 3- 給出了 種最簡單的消息系統部署模式，生產者的數據源多種多樣，它們都統寫人Kafka集群 處理消息時有多個消費者分擔任務 ，這些消費者的處理邏輯都相同， 每個消費者處理的分區都不會重復
因為分區要被重新分配，分區的所有者都會發生變 ，所以在還沒有重新分配分區之前 所有消費者都要停止已有的拉取錢程 同時，分區分配給消費者都會在ZK中記錄所有者信息，所以也要先刪ZK上的節點數據 只有和分區相關的 所有者 拉取線程都釋放了，才可以開始分配分區
如果說在重新分配分區前沒有釋放這些信息，再平衡後就可能造成同 個分區被多個消費者所有的情況 比如分區Pl 原先歸消費者 所有，如果沒有釋放拉取錢程和ZK節點，再平衡後分區Pl 被分配給消費者 了，這樣消費者 和消費者 就共享了分區Pl ，而這顯然不符合 fka 中關於「一個分區只能被分配給 個消費者」的限制條件 執行再平衡操作的步驟如下
如果是協調者節點發生故障，服務端會有自己的故障容錯機制，選出管理消費組所有消費者的新協調者節，點消費者客戶端沒有權利做這個工作，它能做的只是等待一段時間，查詢服務端是否已經選出了新的協調節點如果消費者查到現在已經有管理協調者的協調節點，就會連接這個新協調節，哉由於這個協調節點是服務端新選出來的，所以每個消費者都應該重新連接協調節點
消費者重新加入消費組，在分配到分區的前後，都會對消費者的拉取工作產生影響 消費者發送「加入組請求」之前要停止拉取消息，在收到「加入組響應」中的分區之後要重新開始拉取消息時，為了能夠讓客戶端應用程序感知消費者管理的分區發生變化，在加入組前後，客戶端還可以設置自定義的「消費者再平衡監聽器」，以便對分區的變化做出合適的處理