锐客网

  1. 首页 > 睿知 > it技术 > >

Java中Socket 实现最简单的客户端与服务端通信

IT知识服务端最简单

【Java中Socket 实现最简单的客户端与服务端通信】亦余心之所善兮，虽九死其犹未悔。这篇文章主要讲述Java中Socket 实现最简单的客户端与服务端通信相关的知识，希望能为你提供帮助。
java中Socket 实现最简单的客户端与服务端通信引言：因为最近项目中要接入某通信协议接口，基于TCP/IP的socket接口。于是就在本地弄一个最简单的Socket 通信仅供学习。话不多说，直接开摆
客户端代码

package test;

import java.io.*;
import java.net.Inet4Address;
import java.net.InetSocketAddress;
import java.net.Socket;
public class Client
//java基础类方法的入口
public static void main(String[] args)throws IOException
Socket socket=new Socket();
//读取流超时的时间设置为3000
socket.setSoTimeout(3000);
//连接本地，端口2000；超时时间3000ms
socket.connect(new InetSocketAddress(Inet4Address.getLocalHost(), 2000),3000);
System.out.println("发起服务器连接---------");
System.out.println("客户端信息："+socket.getLocalAddress()+" P:"+socket.getLocalPort()); //打印本地服务器地址和本地端口号
System.out.println("服务端信息："+socket.getInetAddress()+" P:"+socket.getPort());
try
//发送接收数据
todo(socket);
catch (Exception e)
System.out.println("出现异常关闭啦");

//释放资源
socket.close();
System.out.println("再见，客户端已退出");

//发送数据的方法
privatestatic void todo(Socket client) throws IOException
//构建键盘输入流
InputStream in=System.in;
//把键盘输入流转换为BufferedReader
BufferedReader input=new BufferedReader(new InputStreamReader(in,"UTF-8"));
//得到Socket输出流（Client要发送出去给服务器的信息），并转换为打印流
OutputStream outputStream = client.getOutputStream();
PrintStream socketPrintStream=new PrintStream(outputStream);
//得到Socket输入流（Server回复传入Client的信息）,并转换为BufferedReader
InputStream inputStream = client.getInputStream();
BufferedReader socketBufferedReader=new BufferedReader(new InputStreamReader(inputStream,"UTF-8"));
//判断Server是否想要退出，回复“bye”时是他想要结束对话
boolean flag=true;
do
//键盘读取一行
String str = input.readLine();
//发送到服务器，（通俗就是显示在输入处，在键盘上输入什么，屏幕显示什么）
//String str = "003099999920220614100000M1S1C0x0a";
socketPrintStream.println(str);
//从服务器读取一行，即Server传入回复给Client的信息
String echo = socketBufferedReader.readLine();
if("bye".equalsIgnoreCase(echo))
flag=false;
else
//打印到屏幕上，Server回复什么就显示什么
System.out.println("客户端回复："+echo);

while(flag);
//资源释放，关闭对于socket资源
socketPrintStream.close();
socketBufferedReader.close();


服务端代码
package test;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server
public static void main(String[] args)throws IOException
ServerSocket server=new ServerSocket(2000);
System.out.println("服务器准备就绪----------");
System.out.println("服务器信息："+server.getInetAddress()+" P:"+server.getLocalPort());
//等待多个客户端连接，循环异步线程
for(; ; )
//得到客户端
Socket client = server.accept();
//客户端构建异步线程
ClientHandler clientHandler = new ClientHandler(client);
//启动线程
clientHandler.start();


/**
* 客户端消息处理
*/
//多个客户端需要做异步操作，建立异步处理类
private static class ClientHandler extends Thread//线程
privateSocket socket; //代表当前的一个连接
private boolean flag=true;
ClientHandler(Socket socket)
this.socket=socket;
//构造方法
//一旦Thead启动起来，就会运行run方法，代表线程启动的部分
@Override
public void run()
super.run();
//打印客户端的信息
System.out.println("新客户端发起连接："+socket.getInetAddress()+" P:"+socket.getPort());
//在发送过程中会触发一个IO过程，所以需要捕获异常
try
//得到打印流，用于数据输出，服务器回送数据使用，即在屏幕上显示Server要回复Client的信息
PrintStream socketOutput=new PrintStream(socket.getOutputStream());
//得到输入流，用于接收数据，得到Client回复服务器的信息
BufferedReader sockeInput=new BufferedReader(new InputStreamReader(socket.

    推荐阅读


    上一篇：文件输入输出处理(二)-字节流

    下一篇：Linux curl发送post请求携带form参数（Content-Type: application/x-www-form-urlencoded）