java实现socket通讯

访问端：

 public static void main(String[] args) {
//        initSocket();testSocket();}public static void testSocket() {try {String host = "192.168.3.238";int port = 8801;if (!connectSocket(host, port)) {System.out.println("connect fail");return;}if (!sendData("test data".getBytes(StandardCharsets.UTF_8))) {return;}if (!readData()) {return;}System.out.println("return---" + returnData);} catch (Exception ex) {ex.printStackTrace();}}public static boolean connectSocket(String host, int port) {try {socket = new Socket();SocketAddress address = new InetSocketAddress(host, port);socket.connect(address);return true;} catch (Exception ex) {ex.printStackTrace();return false;}}private static boolean closeSocket() {if (!socket.isClosed()) {try {socket.close();return true;} catch (IOException e) {e.printStackTrace();return false;}}return true;}public static boolean sendData(byte[] data) {try {OutputStream out = socket.getOutputStream();out.write(("send data").getBytes(StandardCharsets.UTF_8));out.flush();} catch (Exception ex) {ex.printStackTrace();return false;}return true;}public static boolean readData() {try {int len = 0;byte[] data = new byte[128];InputStream in = socket.getInputStream();len = in.read(data);String instr = new String(data, 0, len);
//            System.out.println("return message" + instr);returnData = instr;return true;} catch (Exception ex) {ex.printStackTrace();return false;}}

服务端main：

public static void main(String[] args) {byte[] data = new byte[128];int len = 0;ServerSocket socket = null;try {socket = new ServerSocket(8801);System.out.println("socket 套接字创建成功，等待连接...");while (true) {Socket con = socket.accept();SocketListenThread s_thread = new SocketListenThread(con);s_thread.setSocket(con);s_thread.start();}} catch (IOException e) {e.printStackTrace();} finally {if (socket.isClosed()) {System.out.println("socket已经关闭");}}

服务端线程：

public class SocketListenThread extends Thread {/*** socket*/private Socket socket;@Overridepublic void run() {try {sleep(3000);int len = 0;s_in = socket.getInputStream();len = s_in.read(data);String in = new String(data, 0, len);System.out.println("接收消息" + in);if (socket.isClosed()) {System.out.println("socket已经关闭1");}s_ou = socket.getOutputStream();s_ou.write((in + "_a").getBytes(StandardCharsets.UTF_8));s_ou.flush();s_ou.close();} catch (Exception ex) {ex.printStackTrace();}}
}

说明：服务端会一直运行，等待接收访问，访问端每次访问都占用一个新的线程来处理当次访问

对于服务端和访问端，InputStream都为读数据内容，OutputSteam都为发送数据，在发送数据时，不要执行out.close（）；这样会将socket关闭。

每次读出的数据，都需要byte[]来接收，因为开始为128位，所有如果读的内容不足128，后面会出现乱码，需要截取对应的长度的数据，len = in.read(data);len即为数据真实长度，实际开发中可以自己指定长度。

java实现socket通讯相关推荐

socket python 连接 java_linux 下 python 和 java， socket通讯问题。
一个小程序,服务端terminal1里运行一个25*25的地图,给客户端传送24个字节的视野信息. 客户端terminal2里是agent,一个5*5的视野. 老师给的是java版的.客户端和服务端t ...
【JAVA】Socket通讯发送报文
报文头为byte数组格式的报文长度方法外设置静态变量,如下: public static int readSize = 1024*4; 通讯方法,如下: int length = message.g ...
Java与C++Socket通讯注意
2019独角兽企业重金招聘Python工程师标准>>> c++与java进行socket通信时注意事项因为java发送的都是网络字节序(big-endium),而c++是主机字节序 ...
java与 C++ 之间进行 SOCKET 通讯要点简要解析
Endian定义: 在计算机系统体系结构中用来描述在多字节数中各个字节的存储顺序. big-endian也称高位在前.大端在前.是计算机体系结构中一种描述多字节存储顺序的术语,在这种机制中最重要字节 ...
as3 java 交互_求大佬用 Java 实现这段 AS3 的 socket 通讯功能
最近在分析一个直播网站,初步分析后发现是在 swf 中用 socket 通讯返回的 flv 地址. 其中 Actionscript socket 通讯的关键代码如下: this._socket = n ...
Socket网络通讯开发总结之：Java 与 C进行Socket通讯
先交待一下业务应用背景: 服务端:移动交费系统:基于C语言的Unix系统客户端:增值服务系统:基于Java的软件系统通迅协议:采用TCP/IP协议,使用TCP以异步方式接入数据传输:基于Sock ...
socket java 服务器端_Java 简单的Socket通讯的服务器端实现
最近学安卓开发,看到书上这个Socket通讯的实例,按照书上打的时候客户端一直连接不上,可能是网络问题或者虚拟机连接问题,所以就用控制台实现的客户端,这里是服务器端的.话不多说,直接贴代码 impor ...
java socket通讯_Java socket通讯实现过程及问题解决
这篇文章主要介绍了Java socket通讯实现过程及问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下本来是打算验证java socket是 ...
java socket 卡住_Java socket通讯实现过程及问题解决
这篇文章主要介绍了java socket通讯实现过程及问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下本来是打算验证java socket是 ...

java实现socket通讯

java实现socket通讯相关推荐

最新文章

热门文章