vagrant1984 2009-07-14 09:25
浏览 213
已采纳

mina可能作为服务端,只负责发送数据?

客户端连接上之后,不需要发送信息,而是服务端直接将信息发送至客户端,是否可行?? 另外,怎样将已经处理好的数据加入到mina服务端发送,现在好像只能是messageReceived触发操作
[b]问题补充:[/b]
通过public void sessionOpened(IoSession session) throws Exception方法实现。

怎样将记录传递到open方法呢,我以前试过,但是报错
[b]问题补充:[/b]
[code="java"]
public class ChatProtocolHandler extends IoHandlerAdapter {
private Queue msgQueue = new ConcurrentLinkedQueue();
public void sessionOpened(IoSession session) throws Exception {
while (true) {
int size = msgQueue.size();
for (int i = 0; i < size; i++) {
byte[] b = msgQueue.poll();
if (b == null) continue;
session.write(b);
}
}
}

public void add(byte[] args) {
    msgQueue.add(args);
}

}
[/code]

在其他应用中将数据通过add方法,加入到msgQueue中,但是一两个客户端连接时,cpu就飙高到100了,该怎么处理??

  • 写回答

3条回答 默认 最新

  • numenZQ 2009-07-14 10:30
    关注

    在服务端的Handler继承IoHandlerAdapter,
    http://mina.apache.org/report/trunk/apidocs/

    通过public void sessionOpened(IoSession session) throws Exception方法实现。

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(2条)

报告相同问题?

悬赏问题

  • ¥15 如何在scanpy上做差异基因和通路富集?
  • ¥20 关于#硬件工程#的问题,请各位专家解答!
  • ¥15 关于#matlab#的问题:期望的系统闭环传递函数为G(s)=wn^2/s^2+2¢wn+wn^2阻尼系数¢=0.707,使系统具有较小的超调量
  • ¥15 FLUENT如何实现在堆积颗粒的上表面加载高斯热源
  • ¥30 截图中的mathematics程序转换成matlab
  • ¥15 动力学代码报错,维度不匹配
  • ¥15 Power query添加列问题
  • ¥50 Kubernetes&Fission&Eleasticsearch
  • ¥15 報錯:Person is not mapped,如何解決?
  • ¥15 c++头文件不能识别CDialog