java Socket实现简单在线聊天（二）

出处：http://blog.csdn.net/tuzongxun

接《java Socket实现简单在线聊天（一）》，在单客户端连接的基础上，这里第二步需要实现多客户端的连接，也就需要使用到线程。每当有一个新的客户端连接上来，服务端便需要新启动一个线程进行处理，从而解决之前的循环读取中造成阻塞的问题。

写线程通常有两种方法，集成Thread或者实现runnable接口，原则上是能实现runnable的情况下就不继承，因为实现接口的方式更加灵活。

客户端代码相较之前没有变化，变得是服务端，因此这里便只贴出服务端代码：

[java] view plain copy

package chat.chat;
import java.io.DataInputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.BindException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
/**
* java使用socket和awt组件以及多线程简单实现在线聊天功能服务端：实现多个客户端连接后不断向服务端发送消息，
* 相对于第一个版本，重点在于使用了多线程。服务端还未实现转发功能，客户端图形窗口中只能看到自己输入的信息，不能看到其他客户端发送的消息
*
* @author tuzongxun123
*
*/
public class ChatServer {
public static void main(String[] args) {
new ChatServer().start();
}
// 是否成功启动服务端
private boolean isStart = false;
// 服务端socket
private ServerSocket ss = null;
// 客户端socket
private Socket socket = null;
public void start() {
try {
// 启动服务器
ss = new ServerSocket(8888);
} catch (BindException e) {
System.out.println("端口已在使用中");
// 关闭程序
System.exit(0);
} catch (Exception e) {
e.printStackTrace();
}
try {
isStart = true;
while (isStart) {
// 启动监听
socket = ss.accept();
System.out.println("one client connect");
// 启动客户端线程
Client client = new Client(socket);
new Thread(client).start();
}
} catch (Exception e) {
e.printStackTrace();
} finally {
// 关闭服务
try {
ss.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* 客户端线程
*
* @author tuzongxun123
*
*/
class Client implements Runnable {
// 客户端socket
private Socket socket = null;
// 客户端输入流
private DataInputStream dataInputStream = null;
private boolean isConnect = false;
public Client(Socket socket) {
this.socket = socket;
try {
isConnect = true;
// 获取客户端输入流
dataInputStream = new DataInputStream(socket.getInputStream());
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void run() {
isConnect = true;
try {
while (isConnect) {
// 读取客户端传递的数据
String message = dataInputStream.readUTF();
System.out.println("客户端说：" + message);
}
} catch (EOFException e) {
System.out.println("client closed!");
} catch (SocketException e) {
System.out.println("Client is Closed!!!!");
} catch (Exception e) {
e.printStackTrace();
} finally {
// 关闭相关资源
try {
dataInputStream.close();
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}

转载于:https://www.cnblogs.com/Simeonwu/p/7601406.html

java Socket实现简单在线聊天（二）相关推荐

在线聊天JAVA后端_java web 在线聊天的基本实现
随着互联网的发展,http的协议有些时候不能满足需求,比如在现聊天的实现.如果使用http协议必须轮训,或者使用长链接.必须要一个request,这样后台才能发送信息到前端. 后台不能主动找客户端通信 ...
java socket多人聊天室_如何运用Java socket实现多人聊天室功能
如何运用Java socket实现多人聊天室功能导语:如何运用Java socket实现多人聊天室功能呢?下面是小编给大家提供的代码实现,大家可以参考阅读,更多详情请关注应届毕业生考试网. 目录结构 ...
java socket多人聊天_如何运用Java socket实现多人聊天室功能
导语:如何运用Java socket实现多人聊天室功能呢?下面是小编给大家提供的代码实现,大家可以参考阅读,更多详情请关注应届毕业生考试网. 目录结构: ChatClient: package com ...
基于Server-Sent Event的简单在线聊天室
一.Web即时通信所谓Web即时通信,就是说我们可以通过一种机制在网页上立即通知用户一件事情的发生,是不需要用户刷新网页的.Web即时通信的用途有很多,比如实时聊天,即时推送等.如当我们在登陆浏览 ...
一个基于 Spring Cloud + Vue + Socket.IO 的在线聊天网站，不来体验一下吗？
前言 2022年8月1日,经过一系列的准备工作,这个充满 BUG 的神奇网站在今天发布上线了.因为网站目前的主要功能是在线聊天,所以暂且就先叫它 EasyChat 吧. EasyChat 是一个可以在 ...
c语言socket调用图灵API,socket通信（四）：socket实现机器人在线聊天
实现思路:客户端(本机)向服务端发送消息:服务端接收消息,并调用图灵机器人API接口,获取回复返回给客户端. 首先需要先去图灵机器人http://www.tuling123.com申请帐号,并创建机器 ...
基于Java语言的Web在线聊天室
在线聊天室能够实现登录,注册,聊天功能,最终效果如下图所示注册页面 <%@ page language="java" contentType="text/htm ...
Java TCP实现高仿版QQ聊天(二)
前言这是在上一篇博客基础上开展的,第一部分我们只实现了本机的聊天,无法将程序放置另外机器上和本机进行聊天.这篇博客我将介绍如何实现不同机器之间实现聊天,达到真正意义上的聊天.不过这篇博客在其他机 ...
Java Socket实现简单的即时通信
一.项目简述这是一个即时通信软件的简单实现,通过自定义协议实现登录.退出等控制命令,即时通信软件需要有服务器端与客户端. 二.自定义协议 1.Protocol协议实体类,封装了消息类型以及发送消息. ...

java Socket实现简单在线聊天（二）

java Socket实现简单在线聊天（二）相关推荐

最新文章

热门文章