文档章节

NETTY实战

东门非树
 东门非树
发布于 2014/11/13 10:35
字数 132
阅读 341
收藏 0

//TCP监听

public void run(){
  try {
   this.logger.info("监听TCP端口:" + String.valueOf(this.port));
   b.group(bossGroup, workerGroup)
   .channel(NioServerSocketChannel.class)
   .option(ChannelOption.SO_BACKLOG, 1000)
   .handler(new LoggingHandler(LogLevel.INFO))
   .childHandler(new ChannelInitializer<SocketChannel>(){
    @Override
    protected void initChannel(SocketChannel ch)
      throws Exception {
     ch.pipeline().addLast(new TCPChannelHandlerAdapter(port, logger));
    }
   });   
   b.bind(port).sync().channel().closeFuture().sync();   
  } catch (Exception e) {
   // TODO: handle exception
   e.printStackTrace();
  }
  finally{
   bossGroup.shutdownGracefully();
   workerGroup.shutdownGracefully();
  }

  }

 

 

//UDP监听

public void run()
 {
  //EventLoopGroup group = new NioEventLoopGroup();
        try {
            this.logger.info("监听UDP端口:" + String.valueOf(this.port));
            b.group(bossGroup)
             .channel(NioDatagramChannel.class)
             .option(ChannelOption.SO_BACKLOG, 1000)
             .option(ChannelOption.SO_BROADCAST, true)
             .handler(new UDPChannelHandlerAdapter(port,this.server, this.udpchannels));
            //System.out.println("UDP:"+port+" Server is starting……"); 
            b.bind(port).sync().channel().closeFuture().await();
          
        }
        catch (Exception e) {
         e.printStackTrace();
  }
        finally {
            bossGroup.shutdownGracefully();
        }

 }

© 著作权归作者所有

共有 人打赏支持
东门非树
粉丝 0
博文 11
码字总数 4040
作品 0
南京
加载中

评论(4)

东门非树
东门非树

引用来自“风声云起”的评论

博主,udp发送消息呢?
public class UdpClientSocket { private byte[] buffer = new byte[1024]; private DatagramSocket ds = null; public UdpClientSocket() throws Exception { ds = new DatagramSocket(); } public final void setSoTimeout(final int timeout) throws Exception { ds.setSoTimeout(timeout); } public final int getSoTimeout() throws Exception { return ds.getSoTimeout(); } public final DatagramSocket getSocket() { return ds; } public final String receive(final String lhost, final int lport) throws Exception { DatagramPacket dp = new DatagramPacket(buffer, buffer.length); ds.receive(dp); String info = new String(dp.getData(), 0, dp.getLength()); return info; } public final void close() { try { ds.close(); } catch (Exception ex) { ex.printStackTrace(); } } }
东门非树
东门非树

引用来自“风声云起”的评论

博主,udp发送消息呢?
public final DatagramPacket send(final String host, final int port, final byte[] bytes) throws IOException { DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress .getByName(host), port); ds.send(dp); return dp; }
东门非树
东门非树

引用来自“风声云起”的评论

博主,udp发送消息呢?
public static void main(String[] args) throws Exception { UdpClientSocket client = new UdpClientSocket(); String serverHost = "58.213.150.66"; //58.213.150.66 //String serverHost = "10.1.2.133"; int serverPort = 25002; for(int i=2;i>1;i++){ System.out.println("BDJY,863121020017075,20171118143757,118.698815,32.161784,Net+GPS,69,1,,\n" + ("BDJY,863121020017075,20171118143757,118.698815,32.161784,Net+GPS,69,1,,\\n").getBytes().toString()); client.send(serverHost, serverPort, ("BDJY,863121020017075,20171118143757,118.698815,32.161784,Net+GPS,69,1,,\\n").getBytes()); System.out.println("发送数据:" + client.getSocket()); } //String info = client.receive(serverHost, serverPort); //System.out.println("服务端回应数据:" + info); } }
风声云起
风声云起
博主,udp发送消息呢?
《深入探索Netty原理及源码分析》文集小结

写在2017年末尾,翻看文集的第一篇文章已经是三个月前的事了,也没想过这文集会写那么久,这么慢。。。 Netty文集中的文章主要都是我学习过程的笔记,写博客的主要目的是为了通过输出来倒逼输...

tomas家的小拨浪鼓
2017/12/30
0
0
书籍推荐:《Netty权威指南》

《Netty权威指南》是异步非阻塞通信领域的经典之作,基于最新版本Netty 5.0编写,是国内首本深入介绍Netty原理和架构的技术书籍,也是作者多年实战经验的总结和浓缩。在理论方面,讲解了Net...

ddddd8
2017/12/05
0
0
百度、阿里、腾讯、京东、大型互联网分布式架构必备技能

分布式架构 迎接高并发大数据的挑战,从深度到广度完善知识体系,成为下一个互联网高薪人才。 理论结合实战,透彻理解分布式架构及其解决方案。 面向人群 1、工作1-5年需要突破瓶颈; 2、传统...

Java高级架构
2017/12/21
0
0
Netty+MUI从零打造一个仿微信的高性能聊天项目,兼容iPhone/iPad/安卓

要说到微信,我相信是个人都应该知道,几乎人人都会安装这款社交APP吧,它已经成为了我们生活中不可缺少的一份子。 我记得我上大学那会刚接触Java,做的第一个小项目就是基于J2SE的聊天室,使...

风间影月
07/30
0
0
学习Netty时有关ChannelFuture的一些疑问

在使用netty的ServerBootstrap启动服务器的时候,如下图会在红线处使用sync()方法进行阻塞 而在sync()方法的内部,通过查看源代码,发现实现如下图,在await()中对ChannelFuture对象进行了加...

听说_2017
2017/06/06
392
0

没有更多内容

加载失败,请刷新页面

加载更多

一步步编写自己的PHP爬取代理IP项目(二)

这一章节我们正式开展我们的爬虫项目,首先我们先要知道哪个网站能获取到免费代理IP,目前比较火的有西刺代理,快代理等,这里我们拿西刺代理作为例子。 这里就是一个个免费的IP地址以及各自...

NateHuang
24分钟前
1
0
11-利用思维导图梳理JavaSE-Java的反射机制

11-利用思维导图梳理JavaSE-Java的反射机制 主要内容 1.反射与Class类 1.1.反射概念 1.2.Class类 1.3.实例化Class类 1.4.反射的作用 1.5.Class对象的作用 2.反射的深入应用 2.1.调用无参的成...

飞鱼说编程
30分钟前
1
0
How to serve the world from home computer?

最近在开发web应用,很想知道,通过公网来访问,效果会不会好。今天在做家务的时候,突然想到,如果我自己写一个ip转发的工具,不就可以实现了吗?但是转过头一想,这么大众的想法,怎么会没...

pearma
46分钟前
1
0
今天在码云遇到一个很有意思的人 for Per.js

今天在码云遇到一个很有意思的人,他在我的Per.js项目下面评论了一句,大意为“你试试这句代码,看看速度到底是你快还是Vue快”【当然,这个评论被我手残不小心删掉了...】。 然后我就试了,...

Skyogo
今天
50
0
Java -------- 首字母相关排序总结

Java 字符串数组首字母排序 字符串数组按首字母排序:(区分大小写) String[] strings = new String[]{"ba","aa","CC","Ba","DD","ee","dd"}; Arrays.sort(strings); for (int i ...

切切歆语
今天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部