Java遊戲伺服器開發之十-訊息處理器INetworkConsumer
有了session我們就可以在任何地方向客戶端傳送資訊
寫好了session，可以寫一個對訊息的處理類(消費者)。


add
INetworkConsumer
NetworkConsumer
update
TcpMessageStringHandler


多加一個INetworkConsumer介面，裡面就一個方法consume
寫一個實現類NetworkConsumer，實現consume方法，然後將handle中的channelRead0中的內容拷貝過來。簡單實現下，在加個@Component註解。


在TcpMessageStringHandler中
注入
@Autowired
private INetworkConsumer consumer;
把channelRead0的內容改成consumer.consume(msg, ctx.channel());


看看具體的程式碼吧：“


INetworkConsumer

/*
 * Copyright (C), 2015-2018
 * FileName: INetworkConsumer
 * Author:   zhao
 * Date:     2018/6/23 21:06
 * Description: 網路訊息處理器
 * History:
 * <author>          <time>          <version>          <desc>
 * 作者姓名           修改時間           版本號              描述
 */
package com.lizhaoblog.base.network.customer;

import io.netty.channel.Channel;

/**
 * 〈一句話功能簡述〉<br>
 * 〈網路訊息處理器〉
 *
 * @author zhao
 * @date 2018/6/23 21:06
 * @since 1.0.0
 */
public interface INetworkConsumer {
  /**
   * 執行具體的指令
   *
   * @param message message 客戶端傳送的訊息
   * @param channel channel 與客戶端連線的管道
   */
  void consume(String message, Channel channel);
}
 

NetworkConsumer

/*
 * Copyright (C), 2015-2018
 * FileName: INetworkConsumer
 * Author:   zhao
 * Date:     2018/6/23 21:06
 * Description: 網路訊息處理器
 * History:
 * <author>          <time>          <version>          <desc>
 * 作者姓名           修改時間           版本號              描述
 */
package com.lizhaoblog.server.core.customer;

import com.lizhaoblog.base.network.customer.INetworkConsumer;
import com.lizhaoblog.base.session.SessionManager;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import io.netty.channel.Channel;

/**
 * 〈一句話功能簡述〉<br>
 * 〈網路訊息處理器,實現類〉
 *
 * @author zhao
 * @date 2018/6/23 21:09
 * @since 1.0.0
 */
@Component
public class NetworkConsumer implements INetworkConsumer {
  private static final Logger logger = LoggerFactory.getLogger(NetworkConsumer.class);

  @Override
  public void consume(String message, Channel channel) {
    logger.info("伺服器收到的資料內容：data=" + message);
    String result = "小李，我是伺服器，我收到你的資訊了。";
    SessionManager.getInstance().sendMessage(channel, result);
  }
}
 

後面就可以在NetworkConsumer實現路由的功能，將訊息轉到各自的處理中了

上面的程式碼在碼雲上 https://gitee.com/lizhaoandroid/JgServer
可以加qq群一起探討Java遊戲伺服器開發的相關知識 676231564