請(qǐng)問(wèn) 用mina 給客戶端發(fā)送數(shù)據(jù)，要求分別以1秒，5秒，10秒等不同的頻率發(fā)送不同的數(shù)據(jù)，給每一個(gè)連接的客戶端
package?com.tcp.mina.main;
import?java.util.ArrayList;
import?java.util.Collection;
import?java.util.List;
import?java.util.Map;
import?org.apache.mina.core.IoUtil;
import?org.apache.mina.core.service.IoHandlerAdapter;
import?org.apache.mina.core.session.IdleStatus;
import?org.apache.mina.core.session.IoSession;
import?com.safe.model.Police;
import?com.safe.model.User;
import?com.safe.service.CenterService;
import?com.safe.util.ConstantUtil;
import?com.safe.util.DateUtil;
import?com.tcp.mina.frame.Frame;
import?com.tcp.mina.model.M_p_HandingAlarm;
import?com.tcp.mina.model.M_p_Pant;
import?com.tcp.mina.model.M_p_PeopleInfo;
import?com.tcp.mina.model.M_q_GetPeopleInfo;
import?com.tcp.mina.model.M_q_HandingAlarm;
import?com.tcp.mina.model.M_q_Pant;
import?com.tcp.mina.model.PoliceTask;
import?com.tcp.mina.msgcoder.MsgCoder;
import?com.tcp.mina.thread.AllPoliceCoordsThread;
import?com.tcp.mina.thread.HotPoliceCoordsThread;
import?com.tcp.mina.thread.UserCoordsThread;
import?com.tcp.mina.util.TCPConstant;
public?class?MyServerHandler?extends?IoHandlerAdapter?{
public?static?Map<Long,?IoSession>?allIoSessions;
CenterService?service;
public?MyServerHandler(CenterService?service)?{
super();
this.service?=?service;
}
@Override
public?void?exceptionCaught(IoSession?session,?Throwable?cause)
throws?Exception?{
System.out.println("exceptionCaught");
cause.printStackTrace();
}
@Override
public?void?messageReceived(IoSession?session,?Object?message)
throws?Exception?{
System.out.println("【server】messageReceived:?"?+?message);
Frame?frame?=?null;
if?(message?instanceof?Frame)?{
frame?=?(Frame)?message;
}?else?{
return;
}
int?msgType?=?frame.getMsgType();
switch?(msgType)?{
/**?一?收到心跳?*/
case?TCPConstant.MSGTYPE_Q_PANT:
M_q_Pant?m_q_Pant?=?new?MsgCoder<M_q_Pant>().readFrame(frame,
M_q_Pant.class);
System.out.println("請(qǐng)求消息-心跳請(qǐng)求:"?+?m_q_Pant);
//?響應(yīng)心跳
M_p_Pant?p_Pant?=?new?M_p_Pant();
session.write(new?MsgCoder<M_p_Pant>().readMsg(p_Pant));
break;
/**?二?獲取人物信息請(qǐng)求?*/
case?TCPConstant.MSGTYPE_Q_PEOPLEINFO:
M_q_GetPeopleInfo?q_GetPeopleMsg?=?new?MsgCoder<M_q_GetPeopleInfo>()
.readFrame(frame,?M_q_GetPeopleInfo.class);
int?peopleType?=?q_GetPeopleMsg.getType();
if?(TCPConstant.PEOPLETYPE_POLICE?==?peopleType)?{//?警員
Police?police?=?service.getPoliceByPoliceNo(q_GetPeopleMsg
.getID().trim());
String?birthdayStr?=?DateUtil.fmtDateToStr(police.getDetails()
.getBirthday(),?"yyyy-MM-dd");
Frame?policeFrame?=?new?MsgCoder<M_p_PeopleInfo>()
.readMsg(new?M_p_PeopleInfo(police.getPoliceNo(),
peopleType,?police.getDetails().getName(),
birthdayStr,?police.getDetails().getTel(),
police.getDetails().getAddress(),?police
.getDetails().getShenFenId(),?police
.getDetails().getPhoto()));
session.write(policeFrame);
}?else?if?(TCPConstant.PEOPLETYPE_USER?==?peopleType)?{//?用戶
User?user?=?service.getUserByLoginName(q_GetPeopleMsg.getID()
.trim());
String?birthdayStr?=?DateUtil.fmtDateToStr(user.getDetails()
.getBirthday(),?"yyyy-MM-dd");
Frame?userFrame?=?new?MsgCoder<M_p_PeopleInfo>()
.readMsg(new?M_p_PeopleInfo(user.getLoginName(),
peopleType,?user.getDetails().getName(),
birthdayStr,?user.getDetails().getTel(),?user
.getDetails().getAddress(),?user
.getDetails().getShenFenId(),?user
.getDetails().getPhoto()));
session.write(userFrame);
}
break;
/**?三?處理報(bào)警請(qǐng)求?*/
case?TCPConstant.MSGTYPE_Q_HANDINGALARM:
//?解析請(qǐng)求消息
M_q_HandingAlarm?q_handingMsg?=?new?MsgCoder<M_q_HandingAlarm>()
.readFrame(frame,?M_q_HandingAlarm.class);
//?操作派警
int?alarmId?=?q_handingMsg.getEventID();
int?type?=?q_handingMsg.getType();
if?(type?==?ConstantUtil.ALARM_TYPE_TRUE)?{//?真警則派發(fā)任務(wù)
//?派發(fā)任務(wù)
List<PoliceTask>?policeTasks?=?q_handingMsg.getTask();
List<String>?policeNos?=?new?ArrayList<String>();
String?taskContent?=?"";
for?(PoliceTask?policeTask?:?policeTasks)?{
policeNos.add(policeTask.getPoliceID());
taskContent?=?policeTask.getTaskInfo();
}
service.sendTaskAndNotice(policeNos,?taskContent,?alarmId);
}?else?{//?不是真警?則修改對(duì)應(yīng)類型?1假警?2重復(fù)報(bào)警
//?修改報(bào)警類別
service.updateAlarmStatus(alarmId,?type);
}
/**?響應(yīng)該報(bào)警的最新?tīng)顟B(tài)?*/
//?發(fā)送處理報(bào)警的響應(yīng)消息?1?這里直接返回給所有客戶端，2警員提交任務(wù)時(shí)?發(fā)送給所有客戶端
//?AlarmInfo?alarmInfo=service.getAlarmById();
//?TODO?假數(shù)據(jù)
M_p_HandingAlarm?msg?=?new?M_p_HandingAlarm(alarmId,?2);
Frame?pMsgframe?=?new?MsgCoder<M_p_HandingAlarm>().readMsg(msg);
//?獲取所有正在連接的IoSession
Collection<IoSession>?sessions?=?session.getService()
.getManagedSessions().values();
//?將消息寫(xiě)到所有IoSession
IoUtil.broadcast(pMsgframe,?sessions);
break;
default:
System.out.println("TCP：TCPListenRequest?未知的請(qǐng)求！~");
break;
}
//?session.write(message);
}
@Override
public?void?messageSent(IoSession?session,?Object?message)?throws?Exception?{
System.out.println("【server】messageSent:?"?+?message);
}
@Override
public?void?sessionClosed(IoSession?session)?throws?Exception?{
System.out.println("【server】sessionClosed");
System.out.println("有人關(guān)閉，當(dāng)前客戶數(shù)："?+?allIoSessions.size());
}
@Override
public?void?sessionCreated(IoSession?session)?throws?Exception?{
System.out.println("【server】sessionCreated");
}
@Override
public?void?sessionIdle(IoSession?session,?IdleStatus?status)
throws?Exception?{
System.out.println("【server】sessionIdle");
}
@Override
public?void?sessionOpened(IoSession?session)?throws?Exception?{
System.out.println("【server】sessionOpened?ID:"?+?session.getId());
if?(allIoSessions?==?null)?{
allIoSessions?=?session.getService().getManagedSessions();
}
System.out.println("有人連接，當(dāng)前客戶數(shù)："?+?allIoSessions.size());
new?Thread(new?AllPoliceCoordsThread(session,?service)).start();
new?Thread(new?HotPoliceCoordsThread(session,?service)).start();
new?Thread(new?UserCoordsThread(session,?service)).start();
}
}請(qǐng)看sessionOpened（） 我開(kāi)啟了三個(gè)線程每個(gè)線程里一個(gè)while 循環(huán) sleep1秒。 這樣三個(gè)線程同時(shí)以一定頻率發(fā)送數(shù)據(jù)，結(jié)果報(bào)錯(cuò)了。就算只開(kāi)一個(gè)線程頻率太快了也會(huì)報(bào)錯(cuò)。客戶端讀取的數(shù)據(jù)錯(cuò)亂了。
我想在每一個(gè)客戶端連接以后 給他們以不同的頻率發(fā)送多種數(shù)據(jù)，該怎么實(shí)現(xiàn)呢？
每次都是報(bào)這個(gè)錯(cuò)誤但是 打印的字節(jié)有時(shí)候是不一樣的。
org.apache.mina.filter.codec.ProtocolDecoderException: java.nio.BufferUnderflowException (Hexdump: 06 64 61 57 53 41 00 07 FE FF 00 7B 00 22 00 4E 00 75 00 6D 00 22 00 3A 00 31 00 30 00 2C 00 22 00 70 00 6F 00 6C 00 69 00 63 00 65 00 73 00 22 00 3A 00 5B 00 7B 00 22 00 50 00 6F 00 6C 00 69 00 63 00 65 00 49 00 44 00 22 00 3A 00 22 00 4F 00 4E 00 4C 00 49 00 4E 00 45 00 23 00 31 00 22 00 2C 00 22 00 45 00 76 00 65 00 6E 00 74 00 49 00 44 00 22 00 3A 00 30 00 2C 00 22 00 43 00 6F 00 6F 00 72 00 64 00 69 00 6E 00 61 00 74 00 65 00 58 00 22 00 3A 00 22 00 31 00 32 00 31 00 2E 00 30 00 22 00 2C 00 22 00 43 00 6F 00 6F 00 72 00 64 00 69 00 6E 00 61 00 74 00 65 00 59 00 22 00 3A 00 22 00 33 00 35 00 2E 00 30 00 22 00 7D 00 2C 00 7B 00 22 00 50 00 6F 00 6C 00 69 00 63 00 65 00 49 00 44 00 22 00 3A 00 22 00 4F 00 4E 00 4C 00 49 00 4E 00 45 00 23 00 32 00 22 00 2C 00 22 00 45 00 76 00 65 00 6E 00 74 00 49 00 44 00 22 00 3A 00 30 00 2C 00 22 00 43 00 6F 00 6F 00 72 00 64 00 69 00 6E 00 61 00 74 00 65 00 58 00 22 00 3A 00 22 00 31 00 32 00 31 00 2E 00 30 00 22 00 2C 00 22 00 43 00 6F 00 6F 00 72 00 64 00 69 00 6E 00 61 00 74 00 65 00 59 00 22 00 3A 00 22 00 33 00 35 00 2E 00 30 00 22 00 7D 00 2C 00 7B 00 22 00 50 00 6F 00 6C 00 69 00 63 00 65 00 49 00 44 00 22 00 3A 00 22 00 4F 00 4E 00 4C 00 49 00 4E 00 45 00 23 00 33 00 22 00 2C 00 22 00 45 00 76 00 65 00 6E 00 74 00 49 00 44 00 22 00 3A 00 30 00 2C 00 22 00 43 00 6F 00 6F 00 72 00 64 00 69 00 6E 00 61 00 74 00 65 00 58 00 22 00 3A 00 22 00 31 00 32 00 31 00 2E 00 30 00 22 00 2C 00 22 00 43 00 6F 00 6F 00 72 00 64 00 69 00 6E 00 61 00 74 00 65 00 59 00 22 00 3A 00 22 00 33 00 35 00 2E 00 30 00 22 00 7D 00 2C 00 7B 00 22 00 50 00 6F 00 6C 00 69 00 63 00 65 00 49 00 44 00 22 00 3A 00 22 00 4F 00 4E 00 4C 00 49 00 4E 00 45 00 23 00 34 00 22 00 2C 00 22 00 45 00 76 00 65 00 6E 00 74 00 49 00 44 00 22 00 3A 00 30 00 2C 00 22 00 43 00 6F 00 6F 00 72 00 64 00 69 00 6E 00 61 00 74 00 65 00 58 00 22 00 3A 00 22 00 31 00 32 00 31 00 2E 00 30 00 22 00 2C 00 22 00 43 00 6F 00 6F 00 72 00 64 00 69 00 6E 00 61 00 74 00 65 00 59 00 22 00 3A 00 22 00 33 00 35 00 2E 00 30 00 22 00 7D 00 2C 00 7B 00 22 00 50 00 6F 00 6C 00 69 00 63 00 65 00 49 00 44 00 22 00 3A 00 22 00 4F 00 4E 00 4C 00 49 00 4E 00 45 00 23 00 35 00 22 00 2C 00 22 00 45 00 76 00 65 00 6E 00 74 00 49 00 44 00 22 00 3A 00 30 00 2C 00 22 00 43 00 6F 00 6F 00 72 00 64 00 69 00 6E 00 61 00 74 00 65 00 58 00 22 00 3A 00 22 00 31 00 32 00 31 00 2E 00 30 00 22 00 2C 00 22 00 43 00 6F 00 6F 00 72 00 64 00 69 00 6E 00 61 00 74 00 65 00 59 00 22 00 3A 00 22 00 33 00 35 00 2E 00 30 00 22 00 7D 00 2C 00 7B 00 22 00 50 00 6F 00 6C 00 69 00 63 00 65 00 49 00 44 00 22 00 3A 00 22 00 4F 00 4E 00 4C 00 49 00 4E 00 45 00 23 00 36 00 22 00 2C 00 22 00 45 00 76 00 65 00 6E 00 74 00 49 00 44 00 22 00 3A 00 30 00 2C 00 22 00 43 00 6F 00 6F 00 72 00 64 00 69 00 6E 00 61 00 74 00 65 00 58 00 22 00 3A 00 22 00 31 00 32 00 31 00 2E 00 30 00 22 00 2C 00 22 00 43 00 6F 00 6F 00 72 00 64 00 69 00 6E 00 61 00 74 00 65 00 59 00 22 00 3A 00 22 00 33 00 35 00 2E 00 30 00 22 00 7D 00 2C 00 7B 00 22 00 50 00 6F 00 6C 00 69 00 63 00 65 00 49 00 44 00 22 00 3A)
at org.apache.mina.filter.codec.ProtocolCodecFilter.messageReceived(ProtocolCodecFilter.java:242)
at org.apache.mina.core.filterchain.DefaultIoFilterChain.callNextMessageReceived(DefaultIoFilterChain.java:417)
at org.apache.mina.core.filterchain.DefaultIoFilterChain.access$1200(DefaultIoFilterChain.java:47)
at org.apache.mina.core.filterchain.DefaultIoFilterChain$EntryImpl$1.messageReceived(DefaultIoFilterChain.java:765)
at org.apache.mina.core.filterchain.IoFilterAdapter.messageReceived(IoFilterAdapter.java:109)
at org.apache.mina.core.filterchain.DefaultIoFilterChain.callNextMessageReceived(DefaultIoFilterChain.java:417)
at org.apache.mina.core.filterchain.DefaultIoFilterChain.fireMessageReceived(DefaultIoFilterChain.java:410)
at org.apache.mina.core.polling.AbstractPollingIoProcessor.read(AbstractPollingIoProcessor.java:710)
at org.apache.mina.core.polling.AbstractPollingIoProcessor.process(AbstractPollingIoProcessor.java:664)
at org.apache.mina.core.polling.AbstractPollingIoProcessor.process(AbstractPollingIoProcessor.java:653)
at org.apache.mina.core.polling.AbstractPollingIoProcessor.access$600(AbstractPollingIoProcessor.java:67)
at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:1124)
at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
Caused by: java.nio.BufferUnderflowException
at java.nio.HeapByteBuffer.get(HeapByteBuffer.java:127)
at org.apache.mina.core.buffer.AbstractIoBuffer.get(AbstractIoBuffer.java:615)
at org.apache.mina.core.buffer.AbstractIoBuffer.get(AbstractIoBuffer.java:1321)
at com.tcp.mina.protocalcoder.FrameCumulativeDecoder.doDecode(FrameCumulativeDecoder.java:34)
at org.apache.mina.filter.codec.CumulativeProtocolDecoder.decode(CumulativeProtocolDecoder.java:176)
at org.apache.mina.filter.codec.ProtocolCodecFilter.messageReceived(ProtocolCodecFilter.java:232)
... 15 more
