我是 Scala Akka 的新手。假設我正在培養一個Configuration兒童演員,object Configuration { def apply(): Behavior[ConfigurationMessage] = Behaviors....
2022-09-16 more我有兩臺服務器:服務器 1:10.7.44.49 服務器 2:10.7.44.71以及在這些服務器上運行的兩個 actorSystem:akka://[email protected]:5555akka://[email protected]:555...
2022-09-08 more我已經開始使用 Akka。請澄清以下問題;我看到創建了大約 8 個默認調度程式執行緒。該數字在哪里定義?我看到在我的設定中創建了兩種型別的調度程式,即 default...
2022-09-06 more我正在關注 RockTheJVM (Daniel Cioc?rlan) 的應用程式示例:https ://blog.rockthejvm.com/akka-cassandra-project/為了實作 API Rest,它使用 Akka Http。要...
2022-06-20 more我目前正在努力閱讀我的演員的狀態,所以在這種情況下,我只想從我的 State 類中獲取歷史引數 - 例如在呼叫端點時列印它。我已經成功地做到了?之前的操作員,但我...
2022-06-06 more我寫了一個小應用程式,但是有一個問題是我的應用程式沒有等待我的演員停止,而是在他們的動作完成之前停止他們。我試圖使最小的 ActorSystem 看起來像這樣:obj...
2022-05-20 more我創建了我的 Akka 應用程式的 jar 檔案。當我通過命令運行 jar 檔案時java -jar 檔案.jar然后我看到了這個錯誤。什么可能是錯誤的,我該如何解決這個問題?[E...
2022-04-28 more我想在 Akka 流中構建一個圖,其中源是 Kafka 主題(topic_a),接收器是 topic_b(總是),并且根據訊息的資料,還有 topic_c(輸出訊息將不同于輸出訊息發送到 topic_b)。...
2022-04-21 more我正在嘗試讓“詢問”為 Akka Typed 作業。我已經在網上跟蹤了示例,并且我認為我幾乎復制了它們顯示的內容,但是當我嘗試評估“詢問”的回應時出現編譯器錯誤...
2022-04-06 more我有一個a將值發送到 sink的 source b。現在我想要另一個c發出值的源,每次 b 接收到一個事件。我的想法是使用另一個d可以用作通知器的接收器,但是我需要從接...
2022-03-31 more是否可以處理來自單個參與者的多種訊息型別。例如,假設有一個叫做TradingStrategy交易股票的演員。它接收從另一個 Actor 輸入的定價資料。當它決定進行交易...
2022-03-31 more從 Akka(型別化)Actor 內部處理 Futures 的正確方法是什么?例如,假設有一個 ActorOrderActor接收命令來下訂單……它通過對外部服務進行 http 呼叫來實作。由于...
2022-03-31 more我在我的應用程式中啟用了 tls 以使用 HTTPS 而不是 HTTP。現在我想寫它的單元測驗。 path("Ping") { complete("Pong") } Get("/Ping") ~> routes...
2022-03-31 more如何在 Actor 物件中使用可變 Map 來根據訊息存盤值?我的代碼object TestActor { final case class Command() private val mmap: mutable.Map[Int,Map[...
2022-03-16 more我是 Akka Actors 的新手,我正在學習 Ask 模式。我正在查看alvin alexander的以下示例:class TestActor extends Actor { def receive = { case AskNameM...
2022-03-09 more我正在研究一些涉及關閉空閑演員的邏輯。然而,這些參與者是池參與者,這意味著ReceiveTimeout訊息將發送給池中的所有參與者。我遇到的問題是,如果池中有 5 個...
2022-03-09 more我一直在努力獲得一個簡潔的實用函式,用于從 Scala 中的編碼 URL 中決議合理的引數。盡管有很多閱讀和嘗試使用圖書館工具,但我沒有任何特別有用的東西。這是...
2022-03-05 more在我的任務中,父演員創建一些子演員并向他們發送訊息def apply(): Behavior[CreateBranch] = { Behaviors.receive { (context, message) => val...
2022-03-01 more我正在嘗試使用 Scala 開發 Akka 應用程式,我想使用 Lightbend 遙測記錄應用程式行為:Cinnamon Grafana Prometheus。我按照本教程https://developer.light...
2022-02-16 more我正在嘗試按照檔案中的說明設定一個簡單的 akka-grpc 服務器。migrationResult match { case Left(exception) => system.log.error(exception, "Exception while migrati...
2022-01-03 more我未能實作Sink.seq,當需要實作時,我因此例外而失敗akka.stream.SubscriptionWithCancelException$StageWasCompleted$:這是github上的完整源代碼:https : //github.com/Christ...
2021-12-28 more我是 mongo db 的新手,我正在嘗試將檔案向量從外部源(云資料庫)插入到 MongoDb 中。我想添加檔案在 mongodb 中加載的時間戳以及我插入的檔案。我不想稍后通過添加時間欄位來更...
2021-12-28 more例子 import akka.actor.typed.scaladsl.AskPattern._ object MyActor { sealed trait Command case class MyCommand(replyTo: ActorRef[Try[String]])...
2021-12-26 more我是 Akka HTTP 的新手,我想從 JSON 回應中洗掉不必要的欄位,只獲取必要的欄位。例如,我使用
uj5u.com熱心網友回復:對于決議,json您需要使用一些庫。在akka-http檔案中,他們使用s...
我有一些類似于以下的代碼:object Test extends App { val SomeComplicatedFlow: Flow[Int, Int, NotUsed] = Flow.fromGraph(GraphDSL.create() { implicit builder =>...
2021-11-28 more本文分析Program.cs 中Main()函式中代碼的運行順序分析asp.net core程式的啟動,重點不是剖析原始碼,而是理清程式開始時執行的順序。到呼叫了哪些實體,哪些法方。asp.net core 3.1 的程式入口在專案Program.cs檔案里,如下。ususing System; us ......
uj5u.com 2020-09-09 22:07:49 more最近被websocket的一個問題困擾了很久,有一個需求是在web網站中搭建websocket服務。客戶端通過網頁與服務器建立連接,然后服務器根據ip給客戶端網頁發送資訊。 其實,這個需求并不難,只是剛開始對websocket的內容不太了解。上網搜索了一下,有通過asp.net core 實作的、有 ......
uj5u.com 2020-09-09 22:08:02 moreMagicodes.IE在Docker中使用 更新歷史 2019.02.13 【Nuget】版本更新到2.0.2 【匯入】修復單列匯入的Bug,單元測驗“OneColumnImporter_Test”。問題見(https://github.com/dotnetcore/Magicodes.IE/is ......
uj5u.com 2020-09-09 22:08:05 more如果你用過Asp.net webform, 說明你也算是.NET 開發的老兵了。WEBform應該是2011 2013左右,當時還用visual studio 2005、 visual studio 2008。后來基本都用的是MVC。 如果是新開發的專案,估計沒人會用webform技術。但是有些舊版 ......
uj5u.com 2020-09-09 22:08:50 more今天在iis服務器配置asp.net網站,遇到一個問題,記錄一下: 問題:由于擴展配置問題而無法提供您請求的頁面。如果該頁面是腳本,請添加處理程式。如果應下載檔案,請添加 MIME 映射。 WindowServer2012服務器,添加角色安裝完.netframework和iis之后,運行aspx頁面 ......
uj5u.com 2020-09-09 22:10:00 more帶著問題去思考,大家好! 問題1:HTTP請求和回傳相應的HTTP回應資訊之間發生了什么? 1:首先是最底層,托管層,位于WebAPI和底層HTTP堆疊之間 2:其次是 訊息處理程式管道層,這里比如日志和快取。OWIN的參考是將訊息處理程式管道的一些功能下移到堆疊下端的OWIN中間件了。 3:控制器處理 ......
uj5u.com 2020-09-09 22:11:13 more微信門戶應用管理系統,采用基于 MVC + Bootstrap + Ajax + Enterprise Library的技術路線,界面層采用Boostrap + Metronic組合的前端框架,資料訪問層支持Oracle、SQLServer、MySQL、PostgreSQL等資料庫。框架以MVC5,... ......
uj5u.com 2020-09-09 22:15:18 more帶著問題去思考,大家好!它是什么?它包含什么?它能干什么? 訊息 HTTP編程模型的核心就是訊息抽象,表示為:HttPRequestMessage,HttpResponseMessage.用于客戶端和服務端之間交換請求和回應訊息。 HttpMethod類包含了一組靜態屬性: private stat ......
uj5u.com 2020-09-09 22:15:23 more一、跨域 NuGet參考Microsoft.AspNet.WebApi.Cors WebApiConfig.cs中配置: // Web API 配置和服務 config.EnableCors(new EnableCorsAttribute("*", "*", "*")); 二、清除默認回傳XML格式 ......
uj5u.com 2020-09-09 22:15:48 moreTLDR: 視頻分割一直是重標注的一個task,這篇CVPR 2023文章研究了完全不需要標注的視頻物體分割。僅使用ResNet,RCF模型在DAVIS16/STv2/FBMS59上提升了7/9/5%。文章里還提出了不需要標注的調參方法。代碼已公開可用。 Paper title: Bootstrap ......
uj5u.com 2023-07-13 08:55:13 moreChatGPT 是一種強大的自然語言處理模型。在作業中,我們可以借助其卓越的自然語言生成能力,快速檢索代碼資訊,使程式員們能更加專注于業務邏輯的實作和優化。然而,由于它的知識庫僅覆寫至 2021 年 9 月前的資訊,一些新的技術檔案無法被查詢到,例如我們公司前端經常使用的開源框架 TDesign。本... ......
uj5u.com 2023-07-13 08:54:46 moreChatGPT 是一種強大的自然語言處理模型。在作業中,我們可以借助其卓越的自然語言生成能力,快速檢索代碼資訊,使程式員們能更加專注于業務邏輯的實作和優化。然而,由于它的知識庫僅覆寫至 2021 年 9 月前的資訊,一些新的技術檔案無法被查詢到,例如我們公司前端經常使用的開源框架 TDesign。本... ......
uj5u.com 2023-07-13 08:48:40 more學習數字信號處理演算法時整理的學習筆記。本篇介紹 VSB 殘留邊帶調幅信號的調制與解調,內附全套 MATLAB 代碼。 ......
uj5u.com 2023-07-13 08:46:20 more一、簡介: Eureka是由Netflix公司開源的一款提供服務注冊和發現的產品。因此,在添加依賴時,會有NetFlix。 該組件管理各種的服務功能:注冊、 發現、熔斷、負載、降級等。 Eureka采用的是基于C/S的設計架構。 Eureka由兩部分組成(Server/Client):Eureka服 ......
uj5u.com 2023-07-13 08:46:06 more# Python中實作定時任務 在專案中,我們可能遇到有定時任務的需求。 - 其一:每隔一個時間段就執行任務。 比如:壓測中每隔45分鐘調整溫箱的溫度。 - 其二:定時執行任務。 例如每天早上 8 點定時推送早報。 今天,我跟大家分享下 Python 定時任務的實作方法。 ## 固定時間間隔執行任務 ......
uj5u.com 2023-07-13 08:45:57 more# Python中實作定時任務 在專案中,我們可能遇到有定時任務的需求。 - 其一:每隔一個時間段就執行任務。 比如:壓測中每隔45分鐘調整溫箱的溫度。 - 其二:定時執行任務。 例如每天早上 8 點定時推送早報。 今天,我跟大家分享下 Python 定時任務的實作方法。 ## 固定時間間隔執行任務 ......
uj5u.com 2023-07-13 08:45:20 more一、簡介: Eureka是由Netflix公司開源的一款提供服務注冊和發現的產品。因此,在添加依賴時,會有NetFlix。 該組件管理各種的服務功能:注冊、 發現、熔斷、負載、降級等。 Eureka采用的是基于C/S的設計架構。 Eureka由兩部分組成(Server/Client):Eureka服 ......
uj5u.com 2023-07-13 08:39:42 more<a href="https://www.cnblogs.com/pandefu/" target="_blank"><img width="48" height="48" class="pfs" src="https://pic.cnblogs.com/face/1630815/20190315181946.png" alt="" /><...
uj5u.com 2023-07-13 08:37:03 more## 引言 在C#中,讓執行緒同步有兩種方式: - 鎖(lock、Monitor) - 信號量(EventWaitHandle、Semaphore、Mutex) 執行緒鎖的原理,就是鎖住一個資源,使得應用程式在此刻只有一個執行緒訪問該資源。通俗地講,就是讓多執行緒變成單執行緒。在C#中,可以將被鎖定的資源理解 ......
uj5u.com 2023-07-13 08:36:31 more