服务器之家：专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|VB|R语言|JavaScript|易语言|vb.net|

服务器之家 - 编程语言 - Java教程 - Spring Boot集成netty实现客户端服务端交互示例详解

Spring Boot集成netty实现客户端服务端交互示例详解

2021-06-25 14:15琴_酒 Java教程

这篇文章主要给大家介绍了关于Spring Boot集成netty实现客户端服务端交互的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

前言

netty 是一个高性能的 nio 网络框架，本文主要给大家介绍了关于springboot集成netty实现客户端服务端交互的相关内容，下面来一起看看详细的介绍吧

看了好几天的netty实战,慢慢摸索,虽然还没有摸着很多门道,但今天还是把之前想加入到项目里的

一些想法实现了,算是有点信心了吧(讲真netty对初学者还真的不是很友好......)

首先,当然是在springboot项目里添加netty的依赖了,注意不要用netty5的依赖,因为已经废弃了

?
1
2
3
4
5
6
<!--netty-->
<dependency>
 <groupid>io.netty</groupid>
 <artifactid>netty-all</artifactid>
 <version>4.1.32.final</version>
</dependency>

将端口和ip写入application.yml文件里,我这里是我云服务器的内网ip,如果是本机测试,用127.0.0.1就ok

?
1
2
3
netty:
 port: 7000
 url: 172.16.0.7

在这之后,开始写netty的服务器,这里服务端的逻辑就是将客户端发来的信息返回回去

因为采用依赖注入的方法实例化netty,所以加上@component注释

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
package com.safelocate.app.nettyserver;
 
import io.netty.bootstrap.serverbootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.nioeventloopgroup;
import io.netty.channel.socket.nio.nioserversocketchannel;
import org.apache.log4j.logger;
import org.springframework.stereotype.component;
 
import java.net.inetsocketaddress;
 
@component
public class nettyserver {
 //logger
 private static final logger logger = logger.getlogger(nettyserver.class);
 public void start(inetsocketaddress address){
 eventloopgroup bossgroup = new nioeventloopgroup(1);
 eventloopgroup workergroup = new nioeventloopgroup();
 try {
  serverbootstrap bootstrap = new serverbootstrap()
   .group(bossgroup,workergroup)
   .channel(nioserversocketchannel.class)
   .localaddress(address)
   .childhandler(new serverchannelinitializer())
   .option(channeloption.so_backlog, 128)
   .childoption(channeloption.so_keepalive, true);
  // 绑定端口，开始接收进来的连接
  channelfuture future = bootstrap.bind(address).sync();
  logger.info("server start listen at " + address.getport());
  future.channel().closefuture().sync();
 } catch (exception e) {
  e.printstacktrace();
  bossgroup.shutdowngracefully();
  workergroup.shutdowngracefully();
 }
 }
 
}

当然,这里的serverchannelinitializer是我自己定义的类,这个类是继承channelinitializer<socketchannel>的,里面设置出站和入站的编码器和解码器

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
package com.safelocate.app.nettyserver;
 
import io.netty.channel.channelinitializer;
import io.netty.channel.socket.socketchannel;
import io.netty.handler.codec.string.stringdecoder;
import io.netty.handler.codec.string.stringencoder;
import io.netty.util.charsetutil;
public class serverchannelinitializer extends channelinitializer<socketchannel> {
 @override
 protected void initchannel(socketchannel channel) throws exception {
 channel.pipeline().addlast("decoder",new stringdecoder(charsetutil.utf_8));
 channel.pipeline().addlast("encoder",new stringencoder(charsetutil.utf_8));
 channel.pipeline().addlast(new serverhandler());
 }
}

最好注意被别decoder和encoder写成了一样的,不然会出问题(我之前就是不小心都写成了stringdecoder...)

在这之后就是设置serverhandler来处理一些简单的逻辑了

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
package com.safelocate.app.nettyserver;
 
import io.netty.channel.channelhandlercontext;
import io.netty.channel.channelinboundhandleradapter;
import io.netty.channel.simplechannelinboundhandler;
 
import java.io.ioexception;
import java.io.outputstream;
import java.io.printwriter;
import java.net.inetaddress;
import java.net.socket;
 
public class serverhandler extends channelinboundhandleradapter {
 @override
 public void channelactive(channelhandlercontext ctx) {
 system.out.println("channelactive----->");
 }
 
 
 @override
 public void channelread(channelhandlercontext ctx, object msg) throws exception {
 system.out.println("server channelread......");
 system.out.println(ctx.channel().remoteaddress()+"----->server :"+ msg.tostring());
 //将客户端的信息直接返回写入ctx
 ctx.write("server say :"+msg);
 //刷新缓存区
 ctx.flush();
 }
 
 @override
 public void exceptioncaught(channelhandlercontext ctx, throwable cause) throws exception {
 cause.printstacktrace();
 ctx.close();
 }
}

准备工作到这里,现在要做到就是去启动这个程序

将appapplication实现commandlinerunner这个接口,这个接口可以用来再启动springboot时同时启动其他功能,比如配置,数据库连接等等

然后重写run方法,在run方法里启动netty服务器,server类用@autowired直接实例化

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
package com.safelocate.app;
 
import com.safelocate.app.nettyserver.nettyserver;
import io.netty.channel.channelfuture;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.beans.factory.annotation.value;
import org.springframework.boot.commandlinerunner;
import org.springframework.boot.springapplication;
import org.springframework.boot.autoconfigure.springbootapplication;
 
import java.net.inetaddress;
import java.net.inetsocketaddress;
@springbootapplication
public class appapplication implements commandlinerunner {
 
 @value("${netty.port}")
 private int port;
 
 @value("${netty.url}")
 private string url;
 
 @autowired
 private nettyserver server;
 
 public static void main(string[] args) {
 springapplication.run(appapplication.class, args);
 }
 @override
 public void run(string... args) throws exception {
 inetsocketaddress address = new inetsocketaddress(url,port);
 system.out.println("run .... . ... "+url);
 server.start(address);
 }
}

ok,到这里服务端已经写完,本地我也已经测试完,现在需要打包部署服务器,当然这个程序只为练手...

控制台输入mvn clean package -d skiptests 然后将jar包上传服务器,在这之后,需要在腾讯云/阿里云那边配置好安全组,将之前yml文件里设定的端口的入站

规则设置好,不然访问会被拒绝

之后java -jar命令运行,如果需保持后台一直运行 就用nohup命令,可以看到程序已经跑起来了,等待客户端连接交互

Spring Boot集成netty实现客户端服务端交互示例详解

之后就是写客户端了,客户端其实是依葫芦画瓢,跟上面类似

handler

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
package client;
 
import io.netty.channel.channelhandlercontext;
import io.netty.channel.channelinboundhandleradapter;
 
public class clienthandler extends channelinboundhandleradapter {
 @override
 public void channelactive(channelhandlercontext ctx) {
 system.out.println("clienthandler active");
 }
 
 @override
 public void channelread(channelhandlercontext ctx, object msg) {
 system.out.println("--------");
 system.out.println("clienthandler read message:"+msg);
 }
 
 
 @override
 public void exceptioncaught(channelhandlercontext ctx, throwable cause) {
 cause.printstacktrace();
 ctx.close();
 }
 
}

channelinitializer

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
package client;
 
import io.netty.channel.channelinitializer;
import io.netty.channel.channelpipeline;
import io.netty.channel.socket.socketchannel;
import io.netty.handler.codec.string.stringdecoder;
import io.netty.handler.codec.string.stringencoder;
import io.netty.util.charsetutil;
 
public class clientchannelinitializer extends channelinitializer<socketchannel> {
 protected void initchannel(socketchannel channel) throws exception {
 channelpipeline p = channel.pipeline();
 p.addlast("decoder", new stringdecoder(charsetutil.utf_8));
 p.addlast("encoder", new stringencoder(charsetutil.utf_8));
 p.addlast(new clienthandler());
 }
}

主函数所在类,即客户端

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
package client;
 
import io.netty.bootstrap.bootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.nioeventloopgroup;
import io.netty.channel.socket.socketchannel;
import io.netty.channel.socket.nio.niosocketchannel;
import io.netty.handler.codec.string.stringdecoder;
import io.netty.handler.codec.string.stringencoder;
 
public class client {
 static final string host = system.getproperty("host", "服务器的ip地址");
 static final int port = integer.parseint(system.getproperty("port", "7000"));
 static final int size = integer.parseint(system.getproperty("size", "256"));
 
 public static void main(string[] args) throws exception {
 sendmessage("hhhh");
 }
 public static void sendmessage(string content) throws interruptedexception{
 // configure the client.
 eventloopgroup group = new nioeventloopgroup();
 try {
  bootstrap b = new bootstrap();
  b.group(group)
   .channel(niosocketchannel.class)
   .option(channeloption.tcp_nodelay, true)
   .handler(new channelinitializer<socketchannel>() {
   @override
   public void initchannel(socketchannel ch) throws exception {
    channelpipeline p = ch.pipeline();
    p.addlast("decoder", new stringdecoder());
    p.addlast("encoder", new stringencoder());
    p.addlast(new clienthandler());
   }
   });
 
  channelfuture future = b.connect(host, port).sync();
  future.channel().writeandflush(content);
  future.channel().closefuture().sync();
 } finally {
  group.shutdowngracefully();
 }
 }
 
}

启动客户端,这里就是简单发送一条"hhhh",可以看到客户端已经收到服务器发来的信息

 


Spring Boot集成netty实现客户端服务端交互示例详解

 

然后再看服务端,也有相应的信息打印

Spring Boot集成netty实现客户端服务端交互示例详解

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对服务器之家的支持。

原文链接：https://www.cnblogs.com/Yintianhao/p/10181245.html

  • spring boot
  • Netty

    • 延伸 · 阅读

    精彩推荐
    最近更新
    编辑推荐
    阅读排行
    热门标签
    501 　 406 　 415 　 1433 　 2000 　 401 　 330 　 GOF23 　 new 　 newInstance 　 Hibernate 　 volatile 　 集合 　 spring 　 consul 　 critical 　 嵌套循环 　 注册服务 　 堆栈类 　 supplyAsync 　 遍历 　 设计模式 　 观察者模式 　 小数 　 JAVA8 　 写入文件 　 回车 　 制表符 　 排列组合 　 Java 　
    © 2019-2023 服务器之家(www.zzvips.com) 版权所有关于我们联系我们版权申明网站地图