Netty服务器Demo

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Netty服务器Demo，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6871字，纯文字阅读大概需要10分钟。

内容图文

代码在我自己的gitlab:

http://120.76.219.142/marc/nettyServer

DML类:

package com.wulala;

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.util.Properties;
import java.util.UUID;

public class ExecuteDML {
	private String driver;
	private String url;
	private String user;
	private String password;

	public void initParam(String paramFile) throws Exception {
		Properties props = new Properties();
		props.load(new FileInputStream(paramFile));
		driver = props.getProperty("driverClassName");
		url = props.getProperty("url");
		user = props.getProperty("user");
		password = props.getProperty("password");

	}

	public int insertData(String data) throws Exception {
		Class.forName(driver);
		try (Connection conn = DriverManager.getConnection(url, user, password);
				Statement stmt = conn.createStatement()) {
			return stmt.executeUpdate("INSERT INTO MEMS_REC (ID,X,Y, CREATE_TIME) VALUES (‘"
					+ UUID.randomUUID().toString() + "‘,‘1‘,‘" + data + "‘, now());");
		}
	}

	public int insertWXData(String deviceID, int activate) throws Exception {
		Class.forName(driver);
		try (Connection conn = DriverManager.getConnection(url, user, password);
				Statement stmt = conn.createStatement()) {
			return stmt.executeUpdate("INSERT INTO WANG_XIN (ID,DEVICE_ID,ACTIVATE) VALUES (‘"
					+ UUID.randomUUID().toString() + "‘,‘" + deviceID + "‘," + activate + ");");
		}
	}

	/*public static void main(String[] args) {

		ExecuteDML edml = new ExecuteDML();
		int result=0;
		try {
			edml.initParam("dbconfig.properties");
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

		try {
			result = edml.insertWXData("xxxxasdf", 9999);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		System.out.println("Total " + result + " record been add");
	}
*/
}

Handler类:

package com.wulala;

import java.io.UnsupportedEncodingException;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;

public class TimeServerHandler extends ChannelHandlerAdapter {

	@Override
	public void channelRead(ChannelHandlerContext ctx, Object msg) {
		ByteBuf buf = (ByteBuf) msg;
		byte[] req = new byte[buf.readableBytes()];
		buf.readBytes(req);
		String body = "";
		try {
			body = new String(req, "UTF-8");
		} catch (UnsupportedEncodingException e) {
			e.printStackTrace();
		}
		if (body.length() > 8 && (body.length() < 15)) {
			System.out.println("The time server receive order: " + body);
			ExecuteDML edml = new ExecuteDML();
			String deviceID = body.substring(0, 8);
			int activate = Integer.valueOf(body.substring(8));
			int insertResult = 0;
			System.out.println("devceiID: " + deviceID + " activate: " + activate);
			try {
				edml.initParam("dbconfig.properties");
				insertResult = edml.insertWXData(deviceID, activate);
				// insertResult = edml.insertWXData("xxxxasdf", 1234);
			} catch (Exception e) {
				e.printStackTrace();
			}
			System.out.println("Total " + insertResult + " result been changed");
		}
		// String currentTime = "QUERY TIME ORDER".equalsIgnoreCase(body) ? new
		// java.util.Date(System.currentTimeMillis()).toString() : "BAD ORDER";
		// ByteBuf resp = Unpooled.copiedBuffer(currentTime.getBytes());
		// ctx.write(resp);

	}

	@Override
	public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
		ctx.flush();

	}

	@Override
	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
		ctx.close();

	}

}

MainServer类:

package com.wulala;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;

public class TimeServer {
	public void bind(int port) throws Exception {
		EventLoopGroup bossGroup = new NioEventLoopGroup();
		EventLoopGroup workerGroup = new NioEventLoopGroup();
		try {
			ServerBootstrap b = new ServerBootstrap();
			b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG, 1024)
					.childHandler(new ChildChannelHandler());
			ChannelFuture f = b.bind(port).sync();
			f.channel().closeFuture().sync();
		} finally {
			bossGroup.shutdownGracefully();
			workerGroup.shutdownGracefully();

		}

	}

	private class ChildChannelHandler extends ChannelInitializer<SocketChannel> {
		@Override
		protected void initChannel(SocketChannel arg0) throws Exception {
			arg0.pipeline().addLast(new TimeServerHandler());
		}

	}

	public static void main(String[] args) throws Exception {
		int port = 9998;
		new TimeServer().bind(port); 

	}
}

Client类:

package com.wulala;

import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {
	public static void main(String[] args) throws InterruptedException {
		for (int i = 1; i < 10; i++) {
			SocketClient socketClient = new SocketClient();
			socketClient.i = i;
			socketClient.start();
		}

		// while (true) {

		// Client client = new Client();
		// client.run();
		// Thread.sleep(1000);
		// }

	}

	public void run() {
		Socket client;
		try {
			// client = new Socket("127.0.0.1", 9998);
			client = new Socket("120.25.76.67", 9998);
			// 2.鎵撳紑socket鐨勬祦淇℃伅锛屽噯澶囦笅闈㈢殑鎿嶄綔
			OutputStream os = client.getOutputStream();

			// 3.鍐欎俊鎭?
			os.write(("xxxxasdf123456").getBytes());

			// for (int i = 0; i < 1000000; i++) {
			//
			// System.out.println("waiting...");
			// }
			os.flush();
			os.close();
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

}

class SocketClient extends Thread {

	int i;

	@Override
	public void run() {

		// 1.寤虹珛scoket杩炴帴
		Socket client;
		try {
			client = new Socket("120.25.76.67", 9998);

			// 2.鎵撳紑socket鐨勬祦淇℃伅锛屽噯澶囦笅闈㈢殑鎿嶄綔
			OutputStream os = client.getOutputStream();

			// 3.鍐欎俊鎭?
			os.write(("xxxxasdf" + Thread.currentThread().getId()).getBytes());

			// String filmName = "c://io" + i + ".rmvb";
			//
			// FileOutputStream fileOutputStream = new
			// FileOutputStream(filmName);
			//
			// // 3.1鎺ユ敹鏈嶅姟鍣ㄧ鐨勫弽棣?
			// InputStream is = client.getInputStream();
			// byte b[] = new byte[1024];
			//
			// while (is.read(b) > 0) {
			// fileOutputStream.write(b);
			// }

			// 4.鍏抽棴socket
			// 鍏堝叧闂緭鍑烘祦
			os.flush();
			os.close();

			// 鏈?鍚庡叧闂璼ocket
			client.close();
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

}

具体实现就是Netty负责驱动一个DML的类, 往数据库里面填入一个值.

仅此而已.

测试过并发(100线程个同时访问.)

https://app01.saferkid.net/IntelGeek/record/getLast20DeviceRecordByCustomerId.do

访问这个接口可以看到效果.

这个接口接下来可能会移植到一个静态的网站中去.

原文：http://www.cnblogs.com/Montauk/p/6474943.html

内容总结

以上是互联网集市为您收集整理的Netty服务器Demo全部内容，希望文章能够帮你解决Netty服务器Demo所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1187878.html

来源：【匿名】

【上一篇】netty入门（1）【下一篇】一起学Netty（九）之LengthFieldBasedFrameDecoder

更多 ►

【Netty服务器Demo】教程文章相关的互联网学习教程文章

代码在我自己的gitlab:http://120.76.219.142/marc/nettyServerDML类:package com.wulala;import java.io.FileInputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; import java.util.Properties; import java.util.UUID;public class ExecuteDML {private String driver;private String url;private String user;private String password;public void initParam(String paramFil...

Mina、Netty、Twisted一起学（八）：HTTP服务器【图】

HTTP协议应该是目前使用最多的应用层协议了，用浏览器打开一个网站就是使用HTTP协议进行数据传输。HTTP协议也是基于TCP协议，所以也有服务器和客户端。HTTP客户端一般是浏览器，当然还有可能是其他东西。HTTP服务器，也就是Web服务器，目前已经有很多成熟的产品，例如Apache HTTP Server、Tomcat、Nginx、IIS等。本文的内容不是讲解如何使用以上的HTTP服务器，而是要分别用MINA、Netty、Twisted实现一个简单的HTTP服务器。首先，要...

Netty实现客户端和服务端通信简单例子【代码】

Netty是建立在NIO基础之上，Netty在NIO之上又提供了更高层次的抽象。在Netty里面，Accept连接可以使用单独的线程池去处理，读写操作又是另外的线程池来处理。Accept连接和读写操作也可以使用同一个线程池来进行处理。而请求处理逻辑既可以使用单独的线程池进行处理，也可以跟放在读写线程一块处理。线程池中的每一个线程都是NIO线程。用户可以根据实际情况进行组装，构造出满足系统需求的并发模型。Netty提供了内置的常用编解码器，...

Netty系列之Netty百万级推送服务设计要点【代码】

原文：http://www.infoq.com/cn/articles/netty-million-level-push-service-design-points1. 背景1.1. 话题来源最近很多从事移动互联网和物联网开发的同学给我发邮件或者微博私信我，咨询推送服务相关的问题。问题五花八门，在帮助大家答疑解惑的过程中，我也对问题进行了总结，大概可以归纳为如下几类：Netty是否可以做推送服务器？如果使用Netty开发推送服务，一个服务器最多可以支撑多少个客户端？使用Netty开发推送服务遇到的...

Netty服务端的业务流程分析【代码】

Netty的服务端怎么和java NIO联系起来的，一直很好奇这块内容，这里跟下代码，下篇文章看下Channel相关的知识。finalChannelFuture initAndRegister(){finalChannel channel = channelFactory().newChannel();//try{ init(channel);}catch(Throwable t){ channel.unsafe().closeForcibly();//立即关闭通道且不会触发事件//因为这个通道还没有注册到EventLoop，所以我们需要强制GlobalEventExecutor的使用。r...

100万并发连接服务器笔记之Java Netty处理1M连接会怎么样【代码】【图】

前言每一种该语言在某些极限情况下的表现一般都不太一样，那么我常用的Java语言，在达到100万个并发连接情况下，会怎么样呢，有些好奇，更有些期盼。这次使用经常使用的顺手的 netty NIO框架（netty-3.6.5.Final），封装的很好，接口很全面，就像它现在的域名 netty.io，专注于网络IO。整个过程没有什么技术含量，浅显分析过就更显得有些枯燥无聊，准备好，硬着头皮吧。测试服务器配置运行在VMWare Workstation 9中，64位...

Netty实现服务端客户端长连接通讯及心跳检测

摘要: 通过netty实现服务端与客户端的长连接通讯，及心跳检测通过netty实现服务端与客户端的长连接通讯，及心跳检测。基本思路：netty服务端通过一个Map保存所有连接上来的客户端SocketChannel,客户端的Id作为Map的key。每次服务器端如果要向某个客户端发送消息，只需根据ClientId取出对应的SocketChannel,往里面写入message即可。心跳检测通过IdleEvent事件，定时向服务端放送Ping消息，检测SocketChannel是否终断。...

Netty源码剖析-关闭服务【图】

参考文献：极客时间傅健老师的《Netty源码剖析与实战》Talk is cheap.show me the code!----主线： ----源码：　　先在服务端加个断点和修改下代码：如图：然后启动server和client;然后跳过bossGroup到workerGroup;进入workerGroup的关闭：在此之前呢，先在NioEventLoop里面的关闭处打个断点：然后跟进来看看closeAll(); 这里selectAgain();目的是为了去除canceled的key，接下来的key都是有效的key了。完成之后接着回去 ...

IOS推送http2使用netty服务启动异常【图】

IOS推送http2使用netty服务启动异常现象使用netty开发×××送HTTP2，本机运行正常，部署至linux服务器异常。原因是linux服务器内核版本过低，所使用GLIBC类库版本过低。netty要求GLIBC_2.10，我的服务器最高才GLIBC_2.5。linux查看GLIBC版本命令strings /lib64/libc.so.6 |grep GLIBC_解决办法升级linux内核版本以及GLIBC类库版本。以下附netty服务器异常日志2018-11-18 16:54:30 [ appleJobScheduler_Worker-1:64224 ] - [ DEBUG ]...

Mina、Netty、Twisted一起学：实现简单的TCP服务器

MINA、Netty、Twisted为什么放在一起学习？首先，不妨先看一下他们官方网站对其的介绍：MINA：Apache MINA is a network application framework which helps users develop high performance and high scalability network applications easily. It provides an abstract event-driven asynchronous API over various transports such as TCP/IP and UDP/IP via Java NIO.Netty：Netty is an asynchronous event-driven network ap...

java – Netty：如何减少来自服务器的连续消息之间的延迟？【代码】

我是开发团队的一个使用Netty的套接字服务器.当客户端发送请求,并且服务器发送单个响应时,往返时间非常快. (好)我们最近注意到,如果来自客户端的请求触发来自服务器的两条消息,即使服务器几乎同时将两条消息写入客户端,第一条和第二条消息之间的延迟也会超过200毫秒到达远程客户端.使用本地客户端时,两条消息同时到达.如果远程客户端在来自服务器的第二个消息到达之前发送另一个请求,则立即发送该第二个消息,但是来自新请求的两个消...

Netty源码分析之注册服务端通道（上）

判断是否是本线程目前是在主线程中，所以为falsepublic void execute(Runnable task) {if (task == null) {throw new NullPointerException("task");}boolean inEventLoop = inEventLoop();if (inEventLoop) {addTask(task);} else {startThread();addTask(task);if (isShutdown() && removeTask(task)) {reject();}}if (!addTaskWakesUp && wakesUpForTask(task)) {wakeup(inEventLoop);} } 启动通道绑定的线程private void start...

Netty源码分析之初始化服务端通道

初始化服务端启动程序ServerBootstrap，设置两个线程池，bossGroup监听本地绑定端口，专门用来处理客户端连接请求以及一些服务端的任务，然后在workerGroup给这个客户端Channel分配一个线程进行后续处理，只绑定一个端口的话这个通常可以设置成1，NioEventLoopGroup默认值是处理器核心数的两倍，第二个具体处理与客户端的I/O读写请求以及一些其他任务，b.channel(NioServerSocketChannel.class)设置服务端通讯方式（nio，oio，epol...

Netty源码(九)之服务端读取数据的过程【代码】

前面八篇博客，我们已经介绍了服务端的主Reactor线程的启动流程，以及服务端的工作Reactor线程的启动流程，以及工作的Reactor线程注册感兴趣的事件的过程，今天这篇博客我们主要介绍一下工作线程的读取数据的流程，以及介绍几个常用的的pipeline。就让我们直接进入对应的代码，走来直接看工作线程中的循环流程。具体的代码如下: public final class NioEventLoop extends SingleThreadEventLoop {//事件循环@Overrideprotected voi...

Netty源码(十二)之服务端向客户端写数据的过程【代码】【图】

前面的几篇博客大致的介绍整个Netty核心的代码，以及启动的流程，服务端的读取流程，以及常用的解码器的源码。至此Netty的源码还剩一个服务端向客户端写数据的流程。今天我们就来介绍一下服务端向客户端写的流程。写的方式有以下两种，具体代码如下： ctx.writeAndFlush(""); ctx.channel().writeAndFlush("");这两种方式的区别具体如下图所示：可以看到我们如果执行ctx.writeAndFlush("");方法后，当前的handler后面所有handler都...

NETTY - 最热教程

Netty面试题（2020）尚硅谷2019年Netty教程学习笔记--苟声 Java多线程：Linux多路复用，Java NIO与...当Tomcat遇上Netty java-Netty连接限制《精通并发与Netty》学习笔记（07 - 基...netty简介 Flink1.12源码解读—— Netty通讯模式 Netty 源码解析（二）：Netty 的 Chann...Netty源码解析 -- 对象池Recycler实现原...