TsgcWebSocketServer › 属性 › QueueOptions

QueueOptions 属性

通过内部每连接队列序列化出站消息，以防止线程间的竞争。

语法

property QueueOptions: TsgcWSQueueServer_Options read FQueueOptions write SetQueueOptions;

默认值

Text.Level=qmNone, Binary.Level=qmNone, Ping.Level=qmNone, MaxQueueSize=0, OverflowPolicy=qopDropOldest

备注

启用后，消息将放入内部队列，并在连接线程的上下文中发送，而非在调用方线程中发送，从而消除多个线程同时写入同一连接时所需的锁定。每种消息类型（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 事件会报告此情况，消息将在调用方线程上内联写出。在服务器已经开始侦听之后再指定级别，也会在每个新连接上以同样的方式被重置。

MaxQueueSize 限制每个连接队列可容纳的消息数量：零（默认值）表示不设上限，保持以前的行为。达到上限时，OverflowPolicy 决定新消息的处理方式：qopDropOldest（默认值）丢弃队列中最旧的消息以腾出空间，qopDropNewest 丢弃新消息，qopDisconnect 丢弃新消息并关闭连接。每次达到上限时，都会先触发 OnSendBufferFull 事件，使应用程序能够检测慢速消费者或覆盖丢弃行为。

示例

oServer := TsgcWebSocketServer.Create(nil);
oServer.QueueOptions.Text.Level := qmLevel2;
oServer.QueueOptions.Binary.Level := qmLevel2;
oServer.QueueOptions.Ping.Level := qmLevel1;
oServer.Active := true;

返回属性