TsgcWebSocketHTTPServer › 属性 › QueueOptions
通过内部每连接队列序列化出站消息,以防止线程间的竞争。
property QueueOptions: TsgcWSQueueServer_Options read FQueueOptions write SetQueueOptions;
Text.Level=qmNone,Binary.Level=qmNone,Ping.Level=qmNone
启用后,消息将放入内部队列,并在连接线程的上下文中发送,而非在调用方线程中发送,从而消除多个线程同时写入同一连接时所需的锁定。每种消息类型(Text、Binary、Ping)都是一个子对象,各自拥有自己的 Level 属性,用于指定独立的优先级:qmNone 跳过队列(默认),qmLevel0 最先处理,其次是 qmLevel1,最后是 qmLevel2。例如,将 Text.Level 和 Binary.Level 设为 qmLevel2,将 Ping.Level 设为 qmLevel1,可保证 ping 先于普通流量投递。QueueOptions 仅受默认 IOHandler 支持。当 IOHandlerOptions.IOHandlerType 为 iohIOCP 或 iohEPOLL 时,队列会在服务器启动时被关闭:三个级别都会重置为 qmNone,OnError 事件会报告此情况,消息将在调用方线程上内联写出。在服务器已经开始侦听之后再指定级别,也会在每个新连接上以同样的方式被重置。
oServer := TsgcWebSocketHTTPServer.Create(nil);
oServer.QueueOptions.Text.Level := qmLevel2;
oServer.QueueOptions.Binary.Level := qmLevel2;
oServer.QueueOptions.Ping.Level := qmLevel1;
oServer.Active := true;