MessageHandler.java 1.0 KB

1234567891011121314151617181920212223242526272829303132333435
  1. package cn.sagacloud.server;
  2. import cn.sagacloud.pojo.ChannelHandlerContextWrapper;
  3. import cn.sagacloud.pojo.Command;
  4. import cn.sagacloud.proto.MessageProto;
  5. import cn.sagacloud.utils.CommonUtil;
  6. import io.netty.channel.ChannelHandlerContext;
  7. import org.checkerframework.checker.formatter.FormatUtil;
  8. public class MessageHandler {
  9. public static void handle(MessageProto.Message message, ChannelHandlerContextWrapper ctx) {
  10. Command cmd;
  11. try {
  12. cmd = Command.valueOf(message.getCmd());
  13. }catch (Exception ex){
  14. return;
  15. }
  16. switch (cmd){
  17. case AcceptTask:
  18. ctx.acceptTask(message.getTaskId());
  19. break;
  20. case RefuseTask:
  21. ctx.setLastRejectTime(CommonUtil.getTime());
  22. break;
  23. case ClientInfo:
  24. break;
  25. case TaskSuccess:
  26. break;
  27. case CommandError:
  28. break;
  29. case DownloadError:
  30. break;
  31. }
  32. }
  33. }