Iec104SlaverBuilder.java 1011 B

12345678910111213141516171819202122232425262728293031323334353637383940
  1. package wei.yigulu.iec104.nettyconfig;
  2. import io.netty.channel.socket.SocketChannel;
  3. import lombok.EqualsAndHashCode;
  4. import lombok.experimental.Accessors;
  5. import wei.yigulu.netty.AbstractTcpSlaverBuilder;
  6. import wei.yigulu.netty.ProtocolChannelInitializer;
  7. /**
  8. * 104的子站 是向主站提供数据的 主站发送总召唤 子站响应主站的召唤
  9. * 向主站上送数据
  10. *
  11. * @author 修唯xiuwei
  12. * @version 3.0
  13. */
  14. @EqualsAndHashCode(callSuper = true)
  15. @Accessors(chain = true)
  16. public class Iec104SlaverBuilder extends AbstractTcpSlaverBuilder {
  17. public Iec104SlaverBuilder(int port) {
  18. super(port);
  19. }
  20. @Override
  21. protected ProtocolChannelInitializer getOrCreateChannelInitializer() {
  22. return new ProtocolChannelInitializer<SocketChannel>(this) {
  23. @Override
  24. protected void initChannel(SocketChannel ch) throws Exception {
  25. ch.pipeline().addLast(new AllCustomDelimiterHandler());
  26. ch.pipeline().addLast(new Slave104Handle((Iec104SlaverBuilder) builder));
  27. }
  28. };
  29. }
  30. }