SpringBoot 集成Netty实现UDP Server

Stella981
• 阅读 1075

注:ApplicationRunner 接口是在容器启动成功后的最后一步回调(类似开机自启动)。

UDPServer

package com.vmware.vCenterEvent.netty;

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioDatagramChannel;
import lombok.extern.log4j.Log4j2;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;

@Log4j2
@Component
public class UdpServer implements ApplicationRunner {

    private final Bootstrap bootstrap;

    private final NioEventLoopGroup group;

    private Channel channel;

    private void Start() throws InterruptedException {
        try {
            channel = bootstrap.bind("0.0.0.0", 8888).sync().channel();
            System.out.println("UdpServer start success");
            channel.closeFuture().await();
        } finally {
            group.shutdownGracefully();
        }
    }

    private static final class NettyUdpServerHolder {
        static final NettyUdpServer INSTANCE = new NettyUdpServer();
    }

    public static NettyUdpServer getInstance() {
        return NettyUdpServerHolder.INSTANCE;
    }

    private NettyUdpServer() {
        group = new NioEventLoopGroup();
        bootstrap = new Bootstrap();
        bootstrap.group(group)
                .channel(NioDatagramChannel.class)
                .option(ChannelOption.SO_BROADCAST, true)
                .option(ChannelOption.SO_RCVBUF, 1024 * 1024 * 100)
                .handler(new ChannelInitializer<Channel>() {
                    @Override
                    protected void initChannel(Channel channel) throws Exception {
                        ChannelPipeline pipeline = channel.pipeline();
                        pipeline.addLast(new NettyUdpServerHandler());
                    }
                });
    }

    @Override
    public void run(ApplicationArguments args) throws Exception {
        NettyUdpServer.getInstance().Start();
    }
}

UDPServerHandler

import com.vmware.vCenterEvent.domain.Syslog;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.socket.DatagramPacket;
import io.netty.util.CharsetUtil;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

@Log4j2
@Component
public class NettyUdpServerHandler extends SimpleChannelInboundHandler<DatagramPacket> {

    public static NettyUdpServerHandler nettyUdpServerHandler;

    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    public NettyUdpServerHandler(){
    }

    @PostConstruct
    public void init(){
        nettyUdpServerHandler = this;
        nettyUdpServerHandler.jmsMessagingTemplate = this.jmsMessagingTemplate;
    }

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, DatagramPacket msg) {
        // log.info("开始接收数据");
        String msgString = msg.content().toString(CharsetUtil.UTF_8);     // 将接收到数据放入ActiveMQ队列中
        nettyUdpServerHandler.jmsMessagingTemplate.convertAndSend("mq", msgString);
    }

}
点赞
收藏
评论区
推荐文章
待兔 待兔
4个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
Easter79 Easter79
3年前
thinkcmf+jsapi 实现微信支付
首先从小程序端接收订单号、金额等参数,然后后台进行统一下单,把微信支付的订单号返回,在把订单号发送给前台,前台拉起支付,返回参数后更改支付状态。。。回调publicfunctionnotify(){$wechatDb::name('wechat')where('status',1)find();
芝士年糕 芝士年糕
2年前
docker-常用命令
1.帮助启动类命令:systemctlstartdocker启动Dockersystemctlstopdocker停止Dockersystemctlrestartdocker重启Dockersystemctlstatusdocker查看Docker状态systemctlenabledocker开机自启动d
Stella981 Stella981
3年前
CentOS 7设置开机启动服务,添加自定义系统服务
CentOS7设置开机启动服务建立服务文件保存目录设置开机自启动其他命令1.建立服务文件文件路径vim/usr/lib/systemd/system/nginx.service服务文件内容1.ngin
Stella981 Stella981
3年前
Centos6 使用yum快速搭建LAMP环境
1、安装Apache\root@localhost~\yumyinstallhttpd\开机自启动\root@localhost~\chkconfighttpdon\启动httpd服务\root@localhost~\servicehttpdstart\安装apache
Stella981 Stella981
3年前
SpringBoot连接常见设置
SpringBoot集成了Servlet容器,因此我们可以方便的启动一个容器,并访问其中的接口。那么如何控制Servlet容器中的线程池呢?可以通过如下配置进行控制server:tomcat:appcectcount:1minspacethreads:1maxthreads:
Stella981 Stella981
3年前
Android So动态加载 优雅实现与原理分析
背景:漫品Android客户端集成适配转换功能(基于目标识别(So库35M)和人脸识别库(5M)),导致apk体积50M左右,为优化客户端体验,决定实现So文件动态加载.!(https://oscimg.oschina.net/oscnet/00d1ff90e4b34869664fef59e3ec3fdd20b.png)点击上方“蓝字”关注我
Stella981 Stella981
3年前
JavaScript回调函数的高手指南
摘要:本文将会解释回调函数的概念,同时帮你区分两种回调:同步和异步。回调函数是每个前端程序员都应该知道的概念之一。回调可用于数组、计时器函数、promise、事件处理中。本文将会解释回调函数的概念,同时帮你区分两种回调:同步和异步。1.回调函数首先写一个向人打招呼的函数。只需要创建一个接受name参数的函数gree
Easter79 Easter79
3年前
SpringBoot连接常见设置
SpringBoot集成了Servlet容器,因此我们可以方便的启动一个容器,并访问其中的接口。那么如何控制Servlet容器中的线程池呢?可以通过如下配置进行控制server:tomcat:appcectcount:1minspacethreads:1maxthreads:
Stella981 Stella981
3年前
RabbitMQ实现即时通讯居然如此简单!连后端代码都省得写了?
摘要有时候我们的项目中会用到即时通讯功能,比如电商系统中的客服聊天功能,还有在支付过程中,当用户支付成功后,第三方支付服务会回调我们的回调接口,此时我们需要通知前端支付成功。最近发现RabbitMQ可以很方便的实现即时通讯功能,如果你没有特殊的业务需求,甚至可以不写后端代码,今天给大家讲讲如何使用RabbitMQ来实现即时通讯!MQ