【1】socket服务器

/*** @Description 即时消息服务器* @author xiao tang* @version 1.0.0* @createTime 2022年01月23日*/
public class IMSocketServer {private static int PORT = 13;public static void main(String[] args) {ServerSocket server = null;try {// 开启端口server = new ServerSocket(PORT);System.out.println("服务器已启动");// 与客户端建立socket连接Socket socket = server.accept();System.out.println("客户端请求，创建连接成功");// 写出器PrintWriter writer2Client = new PrintWriter(socket.getOutputStream());writer2Client.write("连接创建成功\r\n");writer2Client.flush();// 客户端读入器Scanner scanner4Client = new Scanner(socket.getInputStream());// 控制台读入器Scanner scanner4Console = new Scanner(System.in);// 等待客户端输入while(true) {// 读取客户端消息并打印String msg4Client = scanner4Client.nextLine();System.out.println("客户端：" + msg4Client);System.out.print("服务端：");// 获取控制台输入数据并发送到客户端String msg4Console = scanner4Console.nextLine();writer2Client.write(msg4Console + "\r\n");writer2Client.flush();}} catch (IOException e) {throw new MyRunTimeException("打开端口socket失败，端口=" + PORT + ", 异常信息=" + e.getMessage());} finally {try {if (server != null) {server.close();}} catch (Exception e) {}}}
}

【2】socket客户端

/*** @Description 即时消息客户端* @author xiao tang* @version 1.0.0* @createTime 2022年01月23日*/
public class IMSocketClient {private static int PORT = 13;public static void main(String[] args) {try (Socket socket = new Socket()) {// 与服务器端建立socket连接socket.connect(new InetSocketAddress("localhost", PORT), 3000);// 新建读取器，写出器Scanner scanner4Server = new Scanner(socket.getInputStream());PrintWriter printWriter = new PrintWriter(socket.getOutputStream());// 控制台读入器Scanner scanner4Console = new Scanner(System.in);System.out.println("连接成功，等待服务器响应");// 等待服务器控制台输入while(true) {// 读取服务器响应并打印String msg4Server = scanner4Server.next();System.out.println("服务器：" + msg4Server);System.out.printf("\n客户端：");// 客户端读取控制台输入，并发送到服务器String msg4Console = scanner4Console.nextLine();printWriter.write(msg4Console + "\r\n");printWriter.flush();}} catch (Exception e) {throw new MyRunTimeException("客户端通讯失败, 异常信息=" + e.getMessage());}}
}

【3】通讯效果

【4】注意事项

1.发送消息的时候，一定要加上回车和换行符（\r\n），不然 scanner.nextLine() 无法识别到一行的结束，就会一直阻塞；

java socket实现简单即时通讯相关推荐

java socket 模拟im 即时通讯
自己想了一下怎么实现,就写了,没有深究是否合理.更多处理没有写下去,例如收件人不在线,应该保存在数据库,等下一次连接的时候刷新map,再把数据发送过去,图片发送也没有做,也没有用json格式 sock ...
Java集成环信即时通讯（SpringBoot）
Java集成环信即时通讯(SpringBoot) 前言:链接: 环信官网友情链接. 官网注册一个社区版账号,社区版限制注册100个用户. 企业版资费如下还有硬性要求,账号余额9000以上准备完成得 ...
java Socket实现简单在线聊天（二）
出处:http://blog.csdn.net/tuzongxun 接<java Socket实现简单在线聊天(一)>,在单客户端连接的基础上,这里第二步需要实现多客户端的连接,也就需要使 ...
基于socket的可发送表情简单即时通讯
前言这段时间做的东西比较杂,但是对学习来说还是很有帮助的,这次做的基于socket的即时通讯也是为了更加了解IM,本来是打算使用openfire或者apollo服务器来实现的,但是中途时间上的问题, ...
推荐：一款Java开源的Springboot 即时通讯 IM 聊天系统
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章 # 开篇电商平台最不能缺的就是即时通讯,例如通知类下发,客服聊天 ...
基于Bmob的简单即时通讯
前言: 关于即时通讯,项目中要是需要一个收发消息的功能.从开始到写完即时通讯这块儿,花了大约3天时间.但真的想吐槽下bmobIM的服务器,有短板时间都在等待连接:disconnect或者java.ut ...
python怎么连接socket_python socket连接实现即时通讯
最近闲暇无事,好多人问即时通讯怎么做的,尤其是对于当下大火的python更是如此,大多数人都知道一个xmpp或者xampp框架,于是开了简书,大致说明一下不明白tcp/udp协议底层原理的,自行百度 ...
一款Java开源的SpringBoot即时通讯IM 聊天系统
开篇电商平台最不能缺的就是即时通讯,例如通知类下发,客服聊天等.今天,就来给大家分享一个开源的即时通讯系统.如对文章不感兴趣可直接跳至文章末尾,有获取源码链接的方法. 但文章内容是需要你简单的过一 ...
Java Socket实现简单的即时通信
一.项目简述这是一个即时通信软件的简单实现,通过自定义协议实现登录.退出等控制命令,即时通信软件需要有服务器端与客户端. 二.自定义协议 1.Protocol协议实体类,封装了消息类型以及发送消息. ...

java socket实现简单即时通讯

【1】socket服务器

【2】socket客户端

【3】通讯效果

【4】注意事项

java socket实现简单即时通讯相关推荐

最新文章

热门文章