前文提到了Go语言版本的Unix套接字的实践，作为Java选手，自然也必须安排上。有了Go的经验，Java写起来也比较容易。
用于标识计算机上某个特定的网络程序，以整数形式，范围0-65535。也就是1024*64。
基于TCP协议Socket服务端和客户端的通信模型： Socket通信步骤：（简单分为4步） 1.建立服务端ServerSocket和客户端Socket 2.打开连接到Socket的输出输入
Socket通信步骤：（简单分为4步） 1.建立服务端ServerSocket和客户端Socket 2.打开连接到Socket的输出输入流 3.按照协议进行读写操作 4.关闭相对应的资源
BIO（Blocking IO）也就是阻塞IO，当服务端和客户端交互时，如果服务端接收了一个客户端请求，就要为这个客户端一直服务直到结束，否则无法为下一个客户端服务。BIO就属于同步阻塞IO。
今天我们聊一个异常：java.io.IOException: Broken pipe，为什么会报这个异常，这个异常要怎么解决？以及最后偶遇外国小哥~
上期结合程序员小猿用温奶器给孩子热奶的故事，把面试中常聊的“同步、异步与阻塞、非阻塞有啥区别”简单进行普及。
于是就报了 java.net.SocketTimeoutException: connect timed out 的异常。
在介绍SocketIO之前，先说下服务端推送是怎么一回事。所谓服务端推送，就是服务端将数据或者消息实时地推送到客户端上。最常见的场景就是即时通讯，除此之外，视频弹幕、图文直播等功能也用到了服务端推送这项技术。
在Java编程之中，我们通常都会接触到网络编程，那么不可避免地就会接触到Socket通信，下面我将对Socket进行简单的解析，并给出双方通讯的代码实现方案
NIO虽然称为Non-Blocking IO（非阻塞IO），但它支持阻塞IO、非阻塞IO和IO多路复用模式这几种方式的使用。
服务端： package com.chendongj.socket; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; /** * 服务端代码 * @author chendongj * */ public class Server { public void server() { try { ServerSocket ss = new ServerSocket(808
（图片来源：https://www.cnblogs.com/itfly8/p/5844803.html）
关键字：互联网协议，网络分层，socket，TCP/IP协议，jdk源码，多线程，线程池，ExecutorService 本文的主要目的是面向程序员，所以涉及到程序编码上面比较多的是TCP/IP协议以及Socket协议，这里会重点介绍，而在学习这两个协议之前，对于整个互联网的运行原理要了解熟悉，所以会先快速过一遍互联网协议。 互联网协议（Internet Protocol Suite） 首先，根据各种信息的总结，这里我们将互联网协议分为五层，自上而下分别是应用层，传输层，网络层，链接层，实体层。下面我
1. Socket timeout Java socket有如下两种timeout： 建立连接timeout，暂时就叫 connect timeout； 读取数据timeout，暂时就叫so timeout。 1.1 建立连接connect timeout 当不设置该参数时，指客户端请求和服务端建立tcp连接时，会一直阻塞直到连接建立成功，或抛异常。当设置了connectTimeout， 客户端请求和服务端建立连接时，阻塞时间超过connectTimeout时，就会抛出异常java.net.
TCP：Transmission Control Protocol 传输控制协议 ，是一种面向连接的、可靠的、基于字节流的传输层通信协议。
ChannelOutboundHandlerAdapter与ChannelInboundHandlerAdapter都是继承于ChannelHandler，并实现自己的ChannelXxxHandler。用于在消息管道中不同时机下处理处理消息。
前两天的 log4j 漏洞引起了安全圈的震动，虽然是二进制选手，但为了融入大家的过年氛围，还是决定打破舒适圈来研究一下 JNDI 注入漏洞。
顾海洋，携程框架架构研发部技术专家，负责携程分布式服务化领域的工作。目前主要负责 Dubbo 在携程的二次开发和推广工作。
我们所说的网络编程，就是通过网络来进行通信，那么具体来说就是网络连接的不同主机，在具体来说连接的是两个主机之间的进程
TCP通信能实现两台计算机之间的数据交互，通信的两端，要严格区分为客户端（Client）与服务端（Server）。 两端通信时步骤：
Netty是 一个异步事件驱动的网络应用程序框架， 用于快速开发可维护的高性能协议服务器和客户端。
在上一篇文章使用 Kotlin 和Spring Boot 2.0快速开发REST API接口内介绍了如何使用简单代码快速实现REST API的服务端接口，此文简单介绍如何在以上基础上快速实现一个简单的客户端应用。
RMI全称是Remote Method Invocation(远程方法调用)，Java RMI威力体现在它强大的开发分布式网络应用的能力上，是纯Java的网络分布式应用系统的核心解决方案之一。其实它可以被看作是RPC的Java版本。但是传统RPC并不能很好地应用于分布式对象系统。而Java RMI 则支持存储于不同地址空间的程序级对象之间彼此进行通信，实现远程对象之间的无缝远程调用。
Redis当下很流行，也很好用，无论是在业务应用系统，还是在大数据领域都有重要的地位；但Redis也很脆弱，用不好，问题多多。2012年以前都是以memcached为主，之后转到Redis阵营，经历过单实例模式、主从模式、哨兵模式、代理模式，集群模式，真正公司层面用得好的很少，对于Redis掌控都很片面，导致实际项目中问题不少。
会有乱码现象，其实就是因为字符集编码不一致的问题，就好像中国人和外国人谈话一样，互相不懂对方在说啥。字符集编码也是如此，本来就是一段GBK编码的文字，却要用utf-8的编码格式去解码，就当然是鸡同鸭讲会出现乱码啦，这个时候就得使用GBK编码的格式去解码才不会出问题。如果互相都是使用的GBK编码后，那就像中国人和中国人都说普通话一样，就能听懂对方在说什么，这样才不会出现乱码。
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
PS：阻塞就一直等待，这也是NIO出现的原因，一个线程好不容易在操作系统上申请一个宝贵的资源，JVM也为它创建了一个对象，宝贵的内存分给他一部分了，结果他只是去等待，这样不太好，想象也可以想象的到。非万不得不用阻塞IO。
Apollo（阿波罗）是携程框架部门研发的分布式配置中心，能够集中化管理应用不同环境、不同集群的配置，配置修改后能够实时推送到应用端，并且具备规范的权限、流程治理等特性，适用于微服务配置管理场景。
客户端需要的操作，创建socket，明确地址和端口，进行键盘录入，获取需要的数据，然后将录入的数据发送给服务端，为socket输出流，然后进行读取服务端发送回来的大写数据，为socket读取流，最后进行客户端显示器的显示，进行读写操作，关闭资源。
获取Socket对象，new出来，构造参数：String的服务端ip，int的端口号
netty通信就像一个流水channel管道，我们可以在管道的中间插入一些‘挡板’为我们服务。比如字符串的编码解码，在前面我们使用new StringDecoder(Charset.forName("GBK"))进行字符串解码，这样我们在收取数据就不需要手动处理字节码。那么本章节我们使用与之对应的new StringEncoder(Charset.forName("GBK"))进行进行字符串编码，用以实现服务端在发送数据的时候只需要传输字符串内容即可。
转载来源: https://www.cnblogs.com/greyzeng/p/16694353.html
jps是java提供的一个显示当前所有java进程pid的命令，适合在linux/unix平台上简单察看当前java进程的一些简单情况。
在微信或者QQ的聊天中我们经常会用到一些群聊，把你的信息发送给所有用户。那么为了实现群发消息，在netty中我们可以使用ChannelGroup方式进行群发消息。如果为了扩展验证比如你实际聊天有不同的群，那么可以定义ConcurrentHashMap结构来存放ChannelGroup。ChannelGroup中提供了一些基础的方法；添加、异常、查找、清空、发放消息、关闭等。
我们通过写一个从服务端（另外一个进程）获取用户名和密码作为demo来进行源码讲解。
在大多数的java项目中，使用开发者直接使用socket的场景并不多。但是目前众多框架的底层中，都会有socket的身影。此示例一下java原始的socket编程，并通过telnet进行通讯。
在我们使用netty中，需要监测服务是否稳定以及在网络异常链接断开时候可以自动重连。需要实现监听；f.addListener(new MyChannelFutureListener())
零、前言 1.本文不是大讲特讲UDP和TCP的区别，或者其流程，只是基于此作些小测试 2.完成两个计算机、手机、计算机与手机之间的信息数据传输 3.把控制台输出及GUI操作 以及Android展
在netty数据传输过程中可以有很多选择，比如；字符串、json、xml、java对象，但为了保证传输的数据具备；良好的通用性、方便的操作性和传输的高性能，我们可以选择protobuf作为我们的数据传输格式。目前protobuf可以支持；C++、C#、Dart、Go、Java、Python等，也可以在JS里使用。知识点；ProtobufDecoder、ProtobufEncoder、ProtobufVarint32FrameDecoder、ProtobufVarint32LengthFieldPrepender。
根据教学培养计划的要求，在《面向对象框架技术及应用》课程中需开发一个完整的项目，该项目中涵盖的知识点要全面，需要包含《面向对象程序设计》中的主要知识点。根据教学计划和教学进展，以及教学内容，有选择性和针对性的设计了《面向对象框架技术及应用》这门课程的开发项目。
本章节主要介绍服务端在收到数据后，通过writeAndFlush发送ByteBuf字节码向客户端传输信息。因为我们使用客户端模拟器的编码是GBK格式，所以代码中也需要将字节码转换为GBK，否则会乱码。
Netty开发中，客户端与服务端需要保持同样的；半包粘包处理，编码解码处理、收发数据方式，这样才能保证数据通信正常。在前面NettyServer的章节中我们也同样处理了；半包粘包、编码解码等，为此在本章节我们可以把这些知识模块开发到NettyClient中。本章节涉及到的知识点有；LineBasedFrameDecoder、StringDecoder、StringEncoder、ChannelInboundHandlerAdapter等。
Netty在实际应用级开发中，有时候某些特定场景下会需要使用Java对象类型进行传输，但是如果使用Java本身序列化进行传输，那么对性能的损耗比较大。为此我们需要借助protostuff-core的工具包将对象以二进制形式传输并做编码解码处理。与直接使用protobuf二进制传输方式不同，这里不需要定义proto文件，而是需要实现对象类型编码解码器，用以传输自定义Java对象。
最近看到项目有用thrift，值此周日闲着也是闲着，先了解一个大概，后边在项目中再深度感悟吧。这里首先介绍一下thrift是做什么的，一般的我们都知道程序不是简单的自己处理自己的数据，很多大型系统往往需要跨系统进行调用，但是跨系统调用往往有一个问题就是你怎么调用的，聪明的小伙伴也许直接想到了http，但是有没有想过http有什么问题？首先是安全问题啥的，还有就是要不断的json到对象的互相转化什么的。其实都很费时间，如此一来就造成了技术问题导致的响应时间问题。所以对于http来说固然是好，但是否有更好的办法？我们知道网络传输是一层一层的协议的包装。那么显然最快的方式是放到最外层了，省去不必要的链路解析工作。但是我们的tcp/ip肯定是要保留的，因此我们的办法要么就是重新造一个tcp/Ip，要么就是省去最上层的应用层协议，直接怼着tcp来干。这样不就节省了协议解析的时间时间么，对我们的rpc远程调用的本质就是这意思，用http来走的话不是不可以，大如springcloud也都是采用的http来走的，但其实上我们还可以直接走tcp，但是tcp的肯定需要服务端和客户端，因此走tcp的问题就是开发比较费事，那么有没有一套工具让我们开发变快，也就是帮我们自动生成，我们简单的修改一下就可以直接用了，答案是有的，这块比较出名的是facebook开源的thrift。这个thrift就是一个开源的能够生成跨语言rpc调用的客户端和服务端的代码。听起来很厉害，其实本质还是上边说的这些想法的一种实践，主要是thrift能跨语言生成，也就是说我们可以用java去rpc调用python的接口，甚至是C#的接口，这块你是否感觉thrift能够让你的应用跨语言进行rpc调用的功能呢，答案是yes。Thrift解决的痛点问题就是跨语言的rpc调用问题。当然thrift定义了一套规范，这就是thrift协议。
Web service 即web服务，它是一种跨编程语言和跨操作系统平台的远程调用技术即跨平台远程调用技术。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
