Socket 实现聊天功能

需要提前了解知识点
java.net.Socket 解析
java.net.ServerSocket 解析

使用socket实现一个端对端聊天系统。

消息的格式为：消息长度（int）+消息内容

通过消息长度来进行socket分包，防止读取出现半包、粘包等问题。

服务端代码

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;/*** @author jijs* @date 2017-08-14*/
public class ChatServer {public static void main(String[] args) throws Exception {start();}public static void start() throws Exception {try (ServerSocket ss = new ServerSocket(9000);Socket s = ss.accept();InputStream is = s.getInputStream();OutputStream os = s.getOutputStream();) {//开启一个线程，实时读取对方发过来的消息new Thread(ChatUtil.receive(is)).start();//从控制台输入消息，并发送ChatUtil.send(os);} catch (IOException e) {e.printStackTrace();}}}

客户端代码

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;/*** @author jijs* @date 2017-08-14*/
public class ChatClient {public static void main(String[] args) throws Exception {start();}public static void start() {try (Socket s = new Socket("127.0.0.1", 9000);InputStream is = s.getInputStream();OutputStream os = s.getOutputStream();) {//开启一个线程，实时读取对方发过来的消息new Thread(ChatUtil.receive(is)).start();//从控制台输入消息，并发送ChatUtil.send(os);} catch (IOException e) {e.printStackTrace();}}}

聊天工具类

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Scanner;/*** @author jijs* @date 2017-08-14*/
public class ChatUtil {/*** 读取对方发过来的消息* @param is* @return*/public static Runnable receive(final InputStream is) {return new Runnable() {public void run() {while (true) {try {// 当前消息总字节长度int returnLen = ChatUtil.readLen(is);byte[] b = new byte[returnLen];int readSize = 0; // 每次读取的字节数int count = 0; // 总读取的字节数while (count < returnLen && (readSize = is.read(b)) != -1) {count += readSize;}String str = new String(b, 0, readSize);System.out.println("接收:" + str);} catch (IOException e) {e.printStackTrace();break;}}}};}/*** 从控制台接收用户输入，发送消息给对方* @param os*/public static void send(final OutputStream os) {Scanner scan = new Scanner(System.in);while (true) {try {String s = scan.nextLine();byte[] data = s.getBytes();int len = data.length;os.write(ChatUtil.int2byte(len));os.write(data);os.flush();} catch (IOException e) {e.printStackTrace();break;}}scan.close();}/*** 读取消息长度* 消息格式为：消息长度+消息内容* @param is* @return* @throws IOException*/public static int readLen(InputStream is) throws IOException {int b1 = is.read();int b2 = is.read();int b3 = is.read();int b4 = is.read();int len = (b1 << 24) + (b2 << 16) + (b3 << 8) + b4;return len;}/*** int 转 byte[] 数组* @param len* @return*/public static byte[] int2byte(int len) {byte[] b = new byte[4];b[0] = (byte) (len >> 24);b[1] = (byte) (len >> 16 & 0XFF);b[2] = (byte) (len >> 8 & 0XFF);b[3] = (byte) (len & 0XFF);return b;}
}

客户端控制台：

服务端控制台：

本人简书blog地址：http://www.jianshu.com/u/1f0067e24ff8
点击这里快速进入简书

GIT地址：http://git.oschina.net/brucekankan/
点击这里快速进入GIT

Socket 实现聊天功能相关推荐

用socket实现聊天
socket是什么? 1.socket是协议和你应用程序的一个接口,你通过它来实现通信,是用来做通信的一套API 2.socket就是插座的意思,把2个东西通过电线插在插座上,就可以通信了 3.各种通 ...
简单java socket_基于Java Socket实现一个简易在线聊天功能（一）
最近做了一个项目,其中有一个在线网页交流的需求,好久没写代码了,手都生疏了,于是先写demo练练手,分享到脚本之家平台,以此做个记录,方便自己和大家使用. 先给大家说下实现步骤分这样几大步: 1.使用 ...
python实现淘宝客服自动回复语_Python+Socket实现基于TCP协议的客户与服务端中文自动回复聊天功能示例...
本文实例讲述了Python+Socket实现基于TCP协议的客户与服务端中文自动回复聊天功能.分享给大家供大家参考,具体如下: [吐槽] 网上的代码害死人,看着都写的言之凿凿,可运行就是有问题. 有些 ...
Socket编程一实现简易的聊天功能以及文件传输
干程序是一件枯燥重复的事,每当感到内心浮躁的时候,我就会找小说来看.我从小就喜爱看武侠小说,一直有着武侠梦.从金庸,古龙,梁羽生系列到凤歌(昆仑),孙晓(英雄志)以及萧鼎的(诛仙)让我领略着不一样的江 ...
Socket通信，实现简单的双人聊天功能
Socket通信 1.简单介绍学习Socket也只是通过一个小例子学习的,关于Socket原理目前只是了解到是基于TCP协议,关于TCP与UDP协议区别可以去百度详情查一下他们的区别之处,大体上是传 ...
Netty 4.x Netty 实现聊天功能
Netty 实现聊天功能 Netty 是一个 Java NIO 客户端服务器框架,使用它可以快速简单地开发网络应用程序,比如服务器和客户端的协议.Netty 大大简化了网络程序的开发过程比如 TCP ...
Socket.IO聊天室~简单实用
小编心语:大家过完圣诞准备迎元旦吧~小编在这里预祝大家元旦快乐!!这一次要分享的东西小编也不是很懂啊,总之小编把它拿出来是觉地比较稀奇,而且程序也没有那么难,是一个比较简单的程序,大家可以多多试试~ ...
python实现简易聊天需要登录_python编写简易聊天室实现局域网内聊天功能
本文实例为大家分享了python实现局域网内聊天功能的具体代码,供大家参考,具体内容如下功能: 可以向局域网内开启接收信息功能的ip进行发送信息,我们可以写两段端口不同的代码来实现在一台电脑上与自己 ...
网络编程C/S模型怎样才能实现真正的聊天功能
学完socket编成后,就迫不及待地写一个简单的聊天程序,好在同学面前装装逼,毕竟外行看热闹.然而在自己的电脑上运行是毫无差错,发送接收都没有问题,然而将客户端的exe文件打包后发送给其他电脑上运行时 ...

Socket 实现聊天功能

服务端代码

客户端代码

聊天工具类

Socket 实现聊天功能相关推荐

最新文章

热门文章