亚洲色成人网站www永久,亚洲欧美人成视频一区在线,亚洲国产成人高清在线观看,亚洲精品久久久久久动漫,亚洲国产精品久久电影欧美

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>
請問web可以在視頻監(jiān)控的視頻,上繪制多邊形嗎,視頻控件用的vlc的object

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>> 各位同行,大家好,最近在研究UDP 組播 ts流,需要在android客戶端接收UDP ts流。 這兩天也下載了大家比較熟悉的VLC進行模擬UDP組播 ts的發(fā)送和接收 參考： http://www.videolan.org/
具體配置：參考附件
http://pan.baidu.com/s/1ve49S
并且VLC也提供了一個android版本
后期在大牛人努力下給編譯并且生成了apk文件 但是里面沒有支持UDP 組播流
大家也可以下載看看
源文件：
http://pan.baidu.com/s/1w00cX
apk:
http://pan.baidu.com/s/1rGIgL
通過在PC上采用VLC可以模擬UDP ts流的發(fā)送和接收,但是目前想在android上進行接收
這點還不太懂,麻煩有熟悉的朋友可以提供一下解決思路,在此不勝感激.
大家也可以一起就此討論一下,謝謝！

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>
這個是red5播放aaa.flv文件
但是我用vlc播放,彈出如下錯誤：

vlc播放red5里oflademo自帶的視頻就可以播放如下：

有沒有大神可以告訴我這是為什么,謝謝！

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>
請看眾包鏈接,其核心難題就是libVLC通過內(nèi)存讀取視頻流進行播放。
https://zb.oschina.net/project/47ba87e26bc64ccc

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>> 我最近在做一個項目,用iphone 連接一個監(jiān)控設(shè)備,iphone界面顯示設(shè)備的畫面,需要實時性,所以用了vlc 封裝好的rtsp串流輸出,但是客戶那邊說我這個延遲有1~2s,用戶體驗不是很好,要我優(yōu)化這個延遲問題,我上網(wǎng)查閱大量資料,而且,vlc官方給的Demo不是完全開源的,就是說我們可以看到.h文件的聲明,看不到代碼是怎么實現(xiàn)的,所以不知道是怎么做的,所以在此請教有做過這方面的、有遇到相關(guān)問題并且解決了的,能否指導(dǎo)指導(dǎo)我,大家共同學(xué)習(xí),共同進步,謝謝各位了！

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>
通過rocketmq控制臺創(chuàng)建topic可以填寫不同讀寫隊列的個數(shù)。
消費者組的消費者數(shù)量和讀隊列有對應(yīng)關(guān)系。一個讀隊列只對應(yīng)消費者組的一個消費者。
多個讀隊列可以對應(yīng)一個消費者。
也就是讀隊列越多可以供連接的讀消費者就越多。那是不是寫反過來寫隊列越多,可以供寫的生產(chǎn)者越多？
關(guān)于嚴格按照消息順序讀寫,如果讀寫隊列不一致,如寫隊列是按照用戶的規(guī)則存放消息（eg:key%隊列個數(shù)）,讀消息的時候還會有分區(qū)隊列消息順序嗎

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>
針對rocketmq的配置優(yōu)化,希望各位大佬能提供下幫助

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>
最近遇到一個新項目,用到了RocketMQ, 在Consume端接收Producter發(fā)出的日志消息,并進行入庫操作。項目自己的日志配置使用log4j2,DAO層用的mybatis。上線發(fā)現(xiàn)mybatis的Mapper操作數(shù)據(jù)庫的sql全部被打印在控制臺上,等級是debug,但是log4j2的配置默認是info。這是因為rocketMQ采用了自身的日志而沒有使用系統(tǒng)自定義的么？
哪位大佬遇到過,求教。。。

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>
1.場景
實現(xiàn)調(diào)用鏈路傳遞,使用aop攔截rocketmqtemplate的sendMessageInTransaction并注入traceId
2.環(huán)境 org.apache.rocketmq rocketmq-spring-boot-starter 2.0.3 org.springframework.boot spring-boot-dependencies 2.1.7.RELEASE pom import org.springframework.cloud spring-cloud-dependencies Greenwich.SR2 pom import
3.代碼 @EnableWebAppAutoConfig @SpringBootApplication @EnableCircuitBreaker @EnableAspectJAutoProxy(proxyTargetClass = true) @EnableFeignClients(basePackages = "com.taco.springcloud") @MapperScan(basePackages = "com.taco.springcloud.**.dao") public class TacoOrderApplication { public static void main(String[] args) { SpringApplication.run(TacoOrderApplication.class, args); } } @Slf4j @Aspect @Component public class RocketMQTraceAspect { @Pointcut("execution(* org.apache.rocketmq.spring.core.RocketMQTemplate.sendMessageInTransaction(..))") public void sendInTransaction() { } @Pointcut("execution(public * org.apache.rocketmq.client.producer.DefaultMQProducer.send(" + "org.apache.rocketmq.common.message.Message,..))") public void sendMessage() { } @Before(value = "sendInTransaction() || sendMessage()") public void onSendMessage(JoinPoint joinPoint) { //TODO: 攔截sendInTransaction有問題,待解決,目前通過定義RocketMQTemplate子類,修改子類方法實現(xiàn) Object[] args = joinPoint.getArgs(); if(ArrayUtils.isEmpty(args)) { return; } for (Object arg : args) { if(arg instanceof Message) { setTraceId2MQ((Message) arg); } if(arg instanceof Collection) { Collection collection = (Collection) arg; for (Object o : collection) { if(o instanceof Message) { setTraceId2MQ((Message) o); continue; } break; } } } } private void setTraceId2MQ(Message msg) { msg.putUserProperty(CommonConstants.TRACE_ROUTE_HEADER, MDC.get(CommonConstants.LOG_TRACE_ROUTE_NAME)); }

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>
在使用MQ的過程中,出現(xiàn)了消費者消費消息延遲的情況,比如我推送消息,一些是直接能被消費者消費的,一些則處于未被消費的狀態(tài),也就是延遲了。
這個時候如果重新發(fā)送該消息,有兩種情況,一種是直接發(fā)送成功,
一種是出現(xiàn)異常,
此時的配置是一臺服務(wù)器上部署的rocketmq,配置信息如下：
# 請教下各位大佬,有沒有碰到過這類情況,或者是怎么解決的。跪謝....

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>
12月15日,2019年 OSC源創(chuàng)會年終盛典在深圳科興科學(xué)園國際會議中心成功舉辦,本次年終盛典 活動詳情 請查看, PPT下載 請點擊, 視頻回看 請點擊。
作為開源中國官方最盛大的技術(shù)沙龍,本次年終盛典為期 1 天,上午為主會場,下午設(shè)置架構(gòu)、大前端、綜合技術(shù)、開源治理、騰訊開源共 5 個分會場。
大會邀請 30+ 國內(nèi)知名技術(shù)大牛、50+ 優(yōu)秀開源軟件作者,聚集了近千名開發(fā)精英,以“ 劍指源碼,尖峰對話 ”為主題,共同探討 2019 年的技術(shù)結(jié)晶與 2020 年的技術(shù)趨勢。
現(xiàn)在,讓我們一起來回顧此次年終盛典的精彩瞬間吧！
活動還未開始,眼看簽到處的隊伍越排越長長長長長…沖出會議中心大廳,沖出照片邊界…
簽到完畢,逛逛展臺,玩玩游戲,領(lǐng)領(lǐng)禮物,美滋滋～
一回頭,展區(qū)已經(jīng)人從眾！得趕緊去會場占座啦！
沒想到會場早已座無虛席,熱火朝天。
演講還沒開始,先跟周圍的開源同好聊聊天吧～ 來年終盛典除了收割技術(shù)干貨外,還適合偶遇志同道合的開發(fā)好友,結(jié)識同樣熱愛開源的小伙伴。


一眨眼,主持人小姐姐走上舞臺,年終盛典正式開始～
2019 年,是開源中國成立第 11 年。11 年里,本著分享和交流開源技術(shù)的初衷,開源中國一直專注在開源領(lǐng)域。開源中國 CEO 馬越先生首先為大家介紹了《開源中國 2019 回顧》
如馬越先生所說,2019 年的開源屆精彩紛呈,越來越多的優(yōu)秀開源項目涌現(xiàn)。 GVP（ Gitee 最有價值開源項目） 經(jīng)過 2 年多時間,已有兩百多個項目入選。
活動當天我們非常榮幸的邀請到了在深圳的 GVP 項目作者來到現(xiàn)場,并由開源中國 CEO 馬越先生為到場的 GVP 作者授牌。
GVP 授牌儀式結(jié)束,年終盛典的分享繼續(xù)～
對任何一家互聯(lián)網(wǎng)公司來說,代碼都是非常珍貴的資產(chǎn)。華為云高級產(chǎn)品總監(jiān),開源社理事、執(zhí)行長 莊表偉,和大家分享了《代碼的未來》。
如莊老師所說,從過去到未來,代碼的含義會變化。而編程語言同樣也發(fā)生著改變,比如最好的語言 PHP ：）
為什么歷經(jīng) 20 年的 PHP 編程技術(shù)仍然具有吸引力？云原生時代的 PHP 會如何變化？Swoole、 PHP-X 創(chuàng)始人,學(xué)而思網(wǎng)校首席架構(gòu)師 韓天峰,為大家?guī)怼?020 年如何正確使用 PHP》。
受益于開源,PHP 越來越強大。開源大大推動了許多技術(shù)的普及和發(fā)展,其中就包括 k8s。
接下來,CNCF China Director Keith Chan 帶來了 CNCF 和 k8s 的故事分享——《The story of CNCF, why k8s is so successful》。
正所謂既要仰望星空,也要腳踏實地。對于本土開源的支持,是開源中國一以貫之的堅持。
為了更好地展示國內(nèi)開源現(xiàn)狀,探討國內(nèi)開源趨勢,激勵國內(nèi)開源人才,促進國內(nèi)開源生態(tài)完善,開源中國每年會在年底舉辦一年一度的最受歡迎中國開源軟件評選活動,并在年終盛典主會場,由開源中國 創(chuàng)始人 紅薯進行頒獎。
通過專門設(shè)立的組委會對開源軟件的市場影響力的評估與提名,以及專家評審團的投票,組委會最終票選出了三個特別獎項,分別是：
汲取了騰訊內(nèi)部多年微服務(wù)架構(gòu)實踐經(jīng)驗的 “2019 年微服務(wù)開源先鋒” —— Tars ；
多次入選國內(nèi)外權(quán)威榜單的 “年度金融企業(yè)級開源數(shù)據(jù)庫創(chuàng)新先鋒” —— SequoiaDB ；
多次領(lǐng)跑云計算技術(shù)的 “2019 年度云計算增長先鋒” —— ZStack。


在今天,大前端早已不再是一個陌生的詞匯,而是移動開發(fā)與 Web 前端的發(fā)展趨勢。在不久的未來,大前端概念或?qū)⒁I(lǐng)新的移動開發(fā)技術(shù)棧,大前端會場的 5 位講師與大家一起探討了大前端趨勢下的終端開發(fā)、工程化等實踐。
第一個主題是由 滴滴出行 順風(fēng)車技術(shù)部 H5 組前端負責(zé)人,chameleon框架的作者——許國棟老師帶來的《大前端技術(shù)演進》,許國棟老師從前端技術(shù)發(fā)展軌跡講起,為大家介紹了大前端的趨勢以及新技術(shù)探索。
第二個主題是由 阿里巴巴無線技術(shù)專家 余玠老師 帶來的《閑魚 Flutter 工程化之混合開發(fā)框架》,余玠老師介紹了閑魚基于自身需求和經(jīng)驗開發(fā)混合框架——flutterboost 的原理與應(yīng)用。
第三個主題是由 阿里高級前端工程師 周繼誠老師帶來的《NodeJS 流量回放 - NodeJS 自動化測試實踐》,周繼誠老師帶領(lǐng)大家從利用真實流量角度去思考如何零成本構(gòu)建一套適合 NodeJS 的測試體系,讓線上的流量真實的重現(xiàn)在代碼驗證環(huán)境。
第四個主題是 天貓 D2C 前端智能化團隊工程師 林陽（南紀）帶來的《數(shù)據(jù)驅(qū)動框架：JavaScript 函數(shù)的“心電感應(yīng)”效應(yīng)》,林陽老師圍繞 React Hooks 性能不足的特性,分享一款全新的數(shù)據(jù)驅(qū)動框架。
第五個主題是 京東高級工程師,Taro 框架核心開發(fā) 陳嘉健 老師帶來的《小程序跨端方案進化之路》,陳嘉健老師認為多端框架不該限制于 React 或 Vue 語法中,應(yīng)該讓更多熟悉不同語法的開發(fā)者也享受到多端框架帶來的便利,并介紹了下一代的小程序跨端架構(gòu)將如何變革。


技術(shù)不斷發(fā)展,各種系統(tǒng)架構(gòu)也在不斷演進。架構(gòu)會場的 5 位講師與大家一起探討了包含中臺實踐、云計算平臺的架構(gòu)、大型分布式系統(tǒng)架構(gòu)、容器化實踐、監(jiān)控架構(gòu)設(shè)計等主題。
架構(gòu)會場的第一個分享是由 京東數(shù)科 高級 DBA & Apache ShardingSphere PPMC ——潘娟老師帶來的《Apache ShardingSphere 分布式數(shù)據(jù)庫中間件平臺架構(gòu)的進化論》,為聽眾提供了完善的分布式數(shù)據(jù)庫中間件解決方案。
第二個分享是由 螞蟻金服 Mesh 化落地負責(zé)人 —— 卓與老師帶來《螞蟻金服 Service Mesh 超大規(guī)模實踐》,卓與老師在年終盛典上介紹了 SOFA Mesh 在螞蟻金服的落地情況以及 SOFA Mesh 在開源上的規(guī)劃與思考。
第三個分享是由 溪塔科技 首席架構(gòu)師 ——寧志偉老師帶來的《開源企業(yè)級區(qū)塊鏈內(nèi)核 CITA 在商業(yè)化實踐中的架構(gòu)改進》,寧志偉老師詳細介紹了 CITA 走向商業(yè)化,對共識協(xié)議 BFT、區(qū)塊鏈虛擬機 VM 等架構(gòu)改進經(jīng)歷。
第四個分享是由 阿里巴巴 技術(shù)專家 ——杜恒老師帶來的《Apache RocketMQ 架構(gòu)演進之道 》,杜恒老師介紹了 RocketMQ 的核心架構(gòu),線上踩過的坑,RocketMQ 5.0 架構(gòu)演進以及對分布式消息領(lǐng)域的展望。
第五個分享是由 PingCAP TiDB 優(yōu)化器與執(zhí)行引擎技術(shù)負責(zé)人——張建老師帶來的《TiDB 的架構(gòu)設(shè)計與演進 —— HTAP 之路》,張建老師和大家詳細探討 TiDB 在 HTAP 方向的架構(gòu)演進歷程,以及他對其設(shè)計的思考。

開源世界包羅萬象,各種技術(shù)與服務(wù)層出不窮,僅有的幾個專場并不能涵蓋所有內(nèi)容。綜合技術(shù)會場包含從編程語言到數(shù)據(jù)庫,從開發(fā)框架到技術(shù)實戰(zhàn)到等多個方向的主題,旨在打破壁壘,發(fā)現(xiàn)技術(shù)真正價值。
第一位演講是由 百度智能云物聯(lián)網(wǎng)部首席架構(gòu)師,LFEdge技術(shù)指導(dǎo)委員會成員——李樂丁老師帶來的《云原生在邊緣計算領(lǐng)域的發(fā)展和應(yīng)用》,李樂丁老師介紹了邊緣計算要解決的問題、系統(tǒng)架構(gòu),以及云原生模式如何應(yīng)用于邊緣,邊云融合的模式,BAETYL 邊云融合的應(yīng)用場景。
第二位演講是由深圳支流科技創(chuàng)始人,Apache APISIX PPMC——王院生老師帶來的《從 Apache APISIX 看 API 網(wǎng)關(guān)的演進 》,王院生老師從技術(shù)的角度來回顧網(wǎng)關(guān)的演進,介紹了如何進行 API 網(wǎng)關(guān)的選型,以及 Apache APISIX 自身的經(jīng)驗。
第三位演講是由開源生態(tài)發(fā)展專家、openEuler首席技術(shù)布道師——朱星老師帶來的《openEuler 基于 ARM 平臺的性能優(yōu)化技術(shù)》,朱星老師介紹了 openEuler 在 ARM 平臺上的虛擬化、容器特性,以及 openEuler 基于 ARM 的性能優(yōu)化技術(shù)和 openEuler 開源操作系統(tǒng)社區(qū)。
第四位演講是由 又拍云運維總監(jiān) 邵海楊老師帶來的《開源技術(shù)及容器化在又拍云數(shù)據(jù)中心的實踐》,邵海楊老師剖析了技術(shù)選型、實施經(jīng)驗以及運維在這場軟件革命中的反省和自我進化,并帶領(lǐng)大家一起思考如何擁抱更好的未來。
第五位演講是由 華為主任工程師,方舟開源社區(qū)經(jīng)理 劉果 老師帶來的《方舟開源歷程及社區(qū)近況》,劉果老師介紹了方舟編譯器的誕生背景及技術(shù)特點,在正式開源前做了哪些準備,以及開源后的社區(qū)項目近況（包括社區(qū)最新Toy Runtime子項目介紹等）。
第六位演講是由 招商銀行總行信息技術(shù)部 DevOps 推廣負責(zé)人 陳展文老師帶來的《支持招行 DevOps 實踐落地和推廣的工具鏈》,陳展文老師回顧了招行近 4 年來的工程技術(shù)和管理模式等 DevOps 實踐,以及 DevOps 的實踐落地的工具鏈。

關(guān)于開源,在開源技術(shù)之外,還應(yīng)該了解其本質(zhì)與理念。開源治理會場的 5 位老師圍繞：如何參與開源、企業(yè)開源治理、中國開源現(xiàn)狀分析、開源協(xié)議選用及風(fēng)險、自由軟件未來等幾個方面,帶領(lǐng)大家一起全方位認識開源。
第一位演講是由 開源中國 創(chuàng)始人 紅薯 帶來的《中國開源生態(tài)研究》,紅薯老師回顧了本土開源生態(tài)發(fā)展及技術(shù)社區(qū)成長路徑,并對比分析本土開源項目及開源社區(qū)的發(fā)展情況,探討技術(shù)社區(qū)如何推動本土開源生態(tài)良性成長。
第二位演講是由 阿里巴巴 Messaging 開放技術(shù)負責(zé)人 馮嘉 老師帶來的《關(guān)于開源你不能不知道的幾件事》,馮嘉老師圍繞開源的理由,開源團度與社區(qū)的構(gòu)建,開源與云的關(guān)系等多個問題背后的思考,帶領(lǐng)大家全方位認識開源。
第三位演講是由百度工程師,開源社區(qū)資深從業(yè)者,Apache Committer——譚中意老師帶來的《內(nèi)部開源的 WHAT / WHY / HOW》,譚中意老師通過幾個企業(yè)的實踐來介紹什么是內(nèi)部開源,內(nèi)部開源有什么好處,該如何實施內(nèi)部開源。
第四位演講是由騰訊開源聯(lián)盟主席,Apache Member ——堵俊平老師帶來的《開源軟件 License 與騰訊開源實踐》,堵俊平老師和大家討論軟件許可證（License) 的概念,以及全球主流開源 License(GPL, Apache v2 等）的內(nèi)涵,外延與適應(yīng)場景,包括在騰訊內(nèi)部的落地情況。
四位老師精彩分享后進入了「大咖聊開源」圓桌討論環(huán)節(jié),
本次圓桌由 TARS 開源項目負責(zé)人,騰訊開源管理委員——單致豪老師出品；鴻蒙OS 開源主管,華為開源專家組組長——歐建深老師作為特邀嘉賓加入,與四位嘉賓共同探討國際開源運作與國內(nèi)開源現(xiàn)狀。


騰訊開源已經(jīng)走過 8 年,至今開源 91 個項目,加入 Linux、Apache 等 9 大開源基金會,成為最高級別會員,并捐贈 3 大優(yōu)秀開源項目（TARS,TSeer和Angel）。騰訊會場的 5 位老師分享了騰訊在微服務(wù)、運維、中間件、大前端領(lǐng)域的優(yōu)秀開源項目。
第一位演講是由 騰訊高級工程師 汪禮超老師帶來的《騰訊物聯(lián)網(wǎng)操作系統(tǒng) TencentOS tiny 項目開源協(xié)同的探索與實踐》, 汪禮超老師介紹了TencentOS tiny 背景及簡介,目標規(guī)劃以及項目生態(tài)推廣及策略。
第二位演講是由 騰訊高級工程師, TarsGo 早期核心成員及維護者——利開園老師帶來的《TARS 核心能力與應(yīng)用實踐》,利開園老師介紹了 Tars 生態(tài)下 GO 語言版本的核心功能和設(shè)計方案, 并分享基于 TarsGO 能力在多環(huán)境設(shè)計/無損變更/CI集成的實踐經(jīng)驗。
第三位演講是由 騰訊高級工程師,藍鯨配置平臺技術(shù)負責(zé)人——李曉鵬老師帶來的《藍鯨配置平臺架構(gòu)實踐與開源生態(tài)》,李曉鵬老師分享了 bk-cmdb 開源的背景及簡介、主要特性和架構(gòu)設(shè)計,以及藍鯨智云的整體開源生態(tài)。
第四位演講是由 騰訊高級工程師,TubeMQ 項目負責(zé)人——張國成老師帶來的《TubeMQ 的 Apache 之路》,張國成老師本次交流主要介紹 TubeMQ 特點,與其他 MQ 的差異,以及為什么我們要自研,為什么要開源 TubeMQ,當前的項目進展等。
第五位演講是由 騰訊高級工程師,OMI 開源框架作者——張磊老師帶來的《深入騰訊 OMI 跨框架架構(gòu)設(shè)計》,張磊老師通過介紹 OMI 背后的設(shè)計思路,和大家一起分享開發(fā)者如何順應(yīng)前端發(fā)展的趨勢？怎么設(shè)計不過時的前端框架？怎么既能賦能現(xiàn)有前端生態(tài)又可自成體系,打輔助又打主力？


【主辦方】
【特約合作伙伴】
【合作伙伴】
【合作媒體/社區(qū)】
【特別支持】
【獨家照片直播服務(wù)商】

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>
rocketmq的事務(wù), 假如銀行轉(zhuǎn)賬操作,銀行A和銀行B要執(zhí)行分布式事務(wù) ,銀行A執(zhí)行賬戶減錢操作成功了,半消息commint,銀行B獲取到消息后執(zhí)行DB操作給賬戶加錢,失敗了的話,銀行A如何回滾呢？

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>
背景先聲明下,同樣的一段發(fā)送對象信息的代碼,使用
使用docker啟動,nameserver、broker還有rocketmq的控制臺,顯示如下
< dependency > < groupId > org.apache.rocketmq < artifactId > rocketmq-spring-boot-starter < version > 2.0.3
依賴對應(yīng)的最新的依賴包,
配置 rocketmq.name-server = 192.168.11.162:9876 rocketmq.producer.group = my-group1
發(fā)送代碼 rocketMQTemplate.getProducer().setVipChannelEnabled(false); OrderPaidEvent orderPaidEvent = new OrderPaidEvent( "T_001" , new BigDecimal( "88.00" )); orderPaidEvent.setOrderNo( "111111" ); rocketMQTemplate .convertAndSend( "BenchmarkTest" , orderPaidEvent);
發(fā)送的對象聲明： public class OrderPaidEvent implements Serializable { private static final long serialVersionUID = - 5834139880019751262L ; private String orderNo ; private String orderName ; private BigDecimal price ; public OrderPaidEvent(String orderName, BigDecimal price) { this . orderName = orderName; this . price = price; } ……省略getter和setter }
網(wǎng)頁請求報錯信息 Thu Oct 10 21:32:39 CST 2019 There was an unexpected error (type=Internal Server Error, status=500). Send [17] times, still failed, cost [2413]ms, Topic: BenchmarkTest, BrokersSent: [broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a] See http://rocketmq.apache.org/docs/faq/ for further details.; nested exception is org.apache.rocketmq.client.exception.MQClientException: Send [17] times, still failed, cost [2413]ms, Topic: BenchmarkTest, BrokersSent: [broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a] See http://rocketmq.apache.org/docs/faq/ for further details.
控制臺報錯,主要是在windows10系統(tǒng)下,才會報錯,而windows 7正常。
RemotingConnectException: connect to <192.168.11.162 :10911> failed 2019-10-10 21:32:39.620 ERROR 11100 --- [nio-8888-exec-1] o.a.r.spring.core.RocketMQTemplate : syncSend failed. destination:BenchmarkTest, message:GenericMessage [payload={"orderNo":"111111","orderName":"T_001","price":88.00}, headers={contentType=text/plain, id=406cb0b0-6d38-6124-9928-d8cd0212718c, timestamp=1570714357207}] 2019-10-10 21:32:39.640 ERROR 11100 --- [nio-8888-exec-1] o.a.c.c.C.[.[.[/].[dispatcherServlet] : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.messaging.MessagingException: Send [17] times, still failed, cost [2413]ms, Topic: BenchmarkTest, BrokersSent: [broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a] See http://rocketmq.apache.org/docs/faq/ for further details.; nested exception is org.apache.rocketmq.client.exception.MQClientException: Send [17] times, still failed, cost [2413]ms, Topic: BenchmarkTest, BrokersSent: [broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a, broker-a] See http://rocketmq.apache.org/docs/faq/ for further details.] with root cause org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.11.162 :10911> failed at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:392) ~[rocketmq-remoting-4.5.1.jar:4.5.1] at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:359) ~[rocketmq-client-4.5.1.jar:4.5.1] at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:343) ~[rocketmq-client-4.5.1.jar:4.5.1] at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:297) ~[rocketmq-client-4.5.1.jar:4.5.1] at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:831) ~[rocketmq-client-4.5.1.jar:4.5.1] at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:557) ~[rocketmq-client-4.5.1.jar:4.5.1] at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1310) ~[rocketmq-client-4.5.1.jar:4.5.1] at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:358) ~[rocketmq-client-4.5.1.jar:4.5.1] at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:188) ~[rocketmq-spring-boot-2.0.3.jar:2.0.3] at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:126) ~[rocketmq-spring-boot-2.0.3.jar:2.0.3] at org.apache.rocketmq.spring.core.RocketMQTemplate.syncSend(RocketMQTemplate.java:114) ~[rocketmq-spring-boot-2.0.3.jar:2.0.3] at org.apache.rocketmq.spring.core.RocketMQTemplate.doSend(RocketMQTemplate.java:514) ~[rocketmq-spring-boot-2.0.3.jar:2.0.3] at org.apache.rocketmq.spring.core.RocketMQTemplate.doSend(RocketMQTemplate.java:53) ~[rocketmq-spring-boot-2.0.3.jar:2.0.3] at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.messaging.core.AbstractMessageSendingTemplate.convertAndSend(AbstractMessageSendingTemplate.java:151) ~[spring-messaging-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.messaging.core.AbstractMessageSendingTemplate.convertAndSend(AbstractMessageSendingTemplate.java:129) ~[spring-messaging-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.messaging.core.AbstractMessageSendingTemplate.convertAndSend(AbstractMessageSendingTemplate.java:122) ~[spring-messaging-5.1.9.RELEASE.jar:5.1.9.RELEASE] at com.jlt.rocketmq.producer.MessageProduce.send(MessageProduce.java:77) ~[classes/:na] at com.jlt.rocketmq.ProducerController.send(ProducerController.java:21) ~[classes/:na] at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:na] at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:na] at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:na] at java.base/java.lang.reflect.Method.invoke(Method.java:566) ~[na:na] at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190) ~[spring-web-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138) ~[spring-web-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104) ~[spring-webmvc-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:892) ~[spring-webmvc-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:797) ~[spring-webmvc-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) ~[spring-webmvc-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1039) ~[spring-webmvc-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:942) ~[spring-webmvc-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1005) ~[spring-webmvc-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:897) ~[spring-webmvc-5.1.9.RELEASE.jar:5.1.9.RELEASE] at javax.servlet.http.HttpServlet.service(HttpServlet.java:634) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:882) ~[spring-webmvc-5.1.9.RELEASE.jar:5.1.9.RELEASE] at javax.servlet.http.HttpServlet.service(HttpServlet.java:741) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53) ~[tomcat-embed-websocket-9.0.17.jar:9.0.17] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99) ~[spring-web-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118) ~[spring-web-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:92) ~[spring-web-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118) ~[spring-web-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:93) ~[spring-web-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118) ~[spring-web-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:200) ~[spring-web-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118) ~[spring-web-5.1.9.RELEASE.jar:5.1.9.RELEASE] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:200) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:490) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:408) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:834) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1415) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[na:na] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[na:na] at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) ~[tomcat-embed-core-9.0.17.jar:9.0.17] at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>
@linkgo 你好,想跟你請教個問題：RocketMQ 使用netty 作為協(xié)議層的輔助處理,看官網(wǎng)上寫的已經(jīng)支持mqtt,然而并未發(fā)現(xiàn)對應(yīng)的mqttclient 包。而使用eclipse的paho mqtt 包也無法直連rocketmq,是否需要自己在rocketmq上擴展netty組件來匹配mqtt 協(xié)議？

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>>

圖一是延遲消息投遞的時間,但是當時沒有開消費者,后期去消費,可以一直消費成功,差值和消費時間也不會更新,這是為什么

HDC調(diào)試需求開發(fā)（15萬預(yù)算）,能者速來！>>> rocketmq部署在阿里云上,老是自動停掉,為什么?。?/div>