12345678910111213141516171819202122232425262728293031323334353637383940 |
- package wei.yigulu.iec104.nettyconfig;
- import io.netty.channel.socket.SocketChannel;
- import lombok.EqualsAndHashCode;
- import lombok.experimental.Accessors;
- import wei.yigulu.netty.AbstractTcpSlaverBuilder;
- import wei.yigulu.netty.ProtocolChannelInitializer;
- /**
- * 104的子站 是向主站提供数据的 主站发送总召唤 子站响应主站的召唤
- * 向主站上送数据
- *
- * @author 修唯xiuwei
- * @version 3.0
- */
- @EqualsAndHashCode(callSuper = true)
- @Accessors(chain = true)
- public class Iec104SlaverBuilder extends AbstractTcpSlaverBuilder {
- public Iec104SlaverBuilder(int port) {
- super(port);
- }
- @Override
- protected ProtocolChannelInitializer getOrCreateChannelInitializer() {
- return new ProtocolChannelInitializer<SocketChannel>(this) {
- @Override
- protected void initChannel(SocketChannel ch) throws Exception {
- ch.pipeline().addLast(new AllCustomDelimiterHandler());
- ch.pipeline().addLast(new Slave104Handle((Iec104SlaverBuilder) builder));
- }
- };
- }
- }
|