java Socket简单聊天实现 —— 实现服务器端向客户端广播内容
2017-03-01 16:16
405 查看
重构聊天室案例,使服务端可以将用户的信息转发给所有客户端,并在每个客户端控制台上显示。通信过程如表-2所示:
服务器端:定义一个集合类型的属性,用于存储所有客户端的输出流。在Server的内部类中run方法的最开始处将客户端的输出流存入该集合,之后,每当客户端发送信息后就遍历集合,将信息写入集合中所有的输出流中(相当于将信息转发给所有的客户端)。
package TCPUDP;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
public class Server {
private ServerSocket serverSocket;
//所有客户端输出流
private List<PrintWriter> allOut;
public Server(){
try{
serverSocket = new ServerSocket(8088);
allOut = new ArrayList<PrintWriter>();
}catch(Exception e){
e.printStackTrace();
}
}
/*
* 线程体:用于并发处理不同客户端的交互
*
*/
class ClientHandler implements Runnable{
private Socket socket;
//构造函数设置为public
public ClientHandler(Socket socket){
this.socket = socket;
}
@Override
public void run() {
PrintWriter pw = null;
try {
OutputStream os = socket.getOutputStream();
OutputStreamWriter osw = new OutputStreamWriter(os, "UTF-8");
pw = new PrintWriter(osw, true);
//存入共享集合
allOut.add(pw);
InputStream is = socket.getInputStream();
InputStreamReader isr = new InputStreamReader(is, "UTF-8");
BufferedReader br = new BufferedReader(isr);
String message = null;
while((message = br.readLine()) != null){
for(PrintWriter o: allOut){
o.println(message);
}
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
//当客户端断线时,要将输出流从集合中删除
allOut.remove(pw);
if(socket != null){
try{
socket.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
}
}
public void start(){
try{
//循环监听客户端的连接
while(true){
System.out.println("等待客户端连接。。。");
Socket socket = serverSocket.accept();
System.out.println("客户端已连接!");
ClientHandler handler = new ClientHandler(socket);
//启动一个线程来完成针对该客户端的交互
new Thread(handler).start();
}
}catch(Exception e){
e.printStackTrace();
}
}
public static void main(String[] args) {
// TODO Auto-generated method stub
Server server = new Server();
server.start();
}
}
客户端:在客户端中定义一个内部类,并定义线程要执行的任务,这里循环读取服务端发送过来的信息,并打印到控制台。最后,在Client的start方法中启动一个该任务对应的线程,来处理服务器和该客户端之间的通信。
package TCPUDP;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
public class Client {
private Socket socket;
public Client(){
try {
socket = new Socket("localhost", 8088);
} catch (Exception e) {
e.printStackTrace();
}
}
private class ServerHandler implements Runnable{
@Override
public void run() {
// TODO Auto-generated method stub
try{
InputStream is = socket.getInputStream();
InputStreamReader isr = new InputStreamReader(is, "UTF-8");
BufferedReader br = new BufferedReader(isr);
while(true){
System.out.println(br.readLine());
}
}catch(Exception e){
e.printStackTrace();
}
}
}
public void start(){
try{
ServerHandler handler = new ServerHandler();
Thread t = new Thread(handler);
t.setDaemon(true);
t.start();
OutputStream out = socket.getOutputStream();
OutputStreamWriter osw = new OutputStreamWriter(out, "UTF-8");
PrintWriter pw = new PrintWriter(osw, true);
//创建Scanner读取用户输入内容
Scanner scanner = new Scanner(System.in);
while(true){
pw.println(scanner.nextLine());
}
}catch(Exception e){
e.printStackTrace();
}finally{
if(socket != null){
try{
socket.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
}
public static void main(String[] args) {
// TODO Auto-generated method stub
Client client = new Client();
client.start();
}
}
服务器端:定义一个集合类型的属性,用于存储所有客户端的输出流。在Server的内部类中run方法的最开始处将客户端的输出流存入该集合,之后,每当客户端发送信息后就遍历集合,将信息写入集合中所有的输出流中(相当于将信息转发给所有的客户端)。
package TCPUDP;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
public class Server {
private ServerSocket serverSocket;
//所有客户端输出流
private List<PrintWriter> allOut;
public Server(){
try{
serverSocket = new ServerSocket(8088);
allOut = new ArrayList<PrintWriter>();
}catch(Exception e){
e.printStackTrace();
}
}
/*
* 线程体:用于并发处理不同客户端的交互
*
*/
class ClientHandler implements Runnable{
private Socket socket;
//构造函数设置为public
public ClientHandler(Socket socket){
this.socket = socket;
}
@Override
public void run() {
PrintWriter pw = null;
try {
OutputStream os = socket.getOutputStream();
OutputStreamWriter osw = new OutputStreamWriter(os, "UTF-8");
pw = new PrintWriter(osw, true);
//存入共享集合
allOut.add(pw);
InputStream is = socket.getInputStream();
InputStreamReader isr = new InputStreamReader(is, "UTF-8");
BufferedReader br = new BufferedReader(isr);
String message = null;
while((message = br.readLine()) != null){
for(PrintWriter o: allOut){
o.println(message);
}
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
//当客户端断线时,要将输出流从集合中删除
allOut.remove(pw);
if(socket != null){
try{
socket.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
}
}
public void start(){
try{
//循环监听客户端的连接
while(true){
System.out.println("等待客户端连接。。。");
Socket socket = serverSocket.accept();
System.out.println("客户端已连接!");
ClientHandler handler = new ClientHandler(socket);
//启动一个线程来完成针对该客户端的交互
new Thread(handler).start();
}
}catch(Exception e){
e.printStackTrace();
}
}
public static void main(String[] args) {
// TODO Auto-generated method stub
Server server = new Server();
server.start();
}
}
客户端:在客户端中定义一个内部类,并定义线程要执行的任务,这里循环读取服务端发送过来的信息,并打印到控制台。最后,在Client的start方法中启动一个该任务对应的线程,来处理服务器和该客户端之间的通信。
package TCPUDP;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
public class Client {
private Socket socket;
public Client(){
try {
socket = new Socket("localhost", 8088);
} catch (Exception e) {
e.printStackTrace();
}
}
private class ServerHandler implements Runnable{
@Override
public void run() {
// TODO Auto-generated method stub
try{
InputStream is = socket.getInputStream();
InputStreamReader isr = new InputStreamReader(is, "UTF-8");
BufferedReader br = new BufferedReader(isr);
while(true){
System.out.println(br.readLine());
}
}catch(Exception e){
e.printStackTrace();
}
}
}
public void start(){
try{
ServerHandler handler = new ServerHandler();
Thread t = new Thread(handler);
t.setDaemon(true);
t.start();
OutputStream out = socket.getOutputStream();
OutputStreamWriter osw = new OutputStreamWriter(out, "UTF-8");
PrintWriter pw = new PrintWriter(osw, true);
//创建Scanner读取用户输入内容
Scanner scanner = new Scanner(System.in);
while(true){
pw.println(scanner.nextLine());
}
}catch(Exception e){
e.printStackTrace();
}finally{
if(socket != null){
try{
socket.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
}
public static void main(String[] args) {
// TODO Auto-generated method stub
Client client = new Client();
client.start();
}
}
相关文章推荐
- 简单socket服务(二)实现多客户端向服务器发送数据
- IM聊天进阶(三)IM>openfire>mina>mina搭建服务端和客户端 实现简单点对点聊天
- java Socket实现简单在线聊天(三)
- WCF服务通过TCP实时监控客户端状态,并可以向客户端广播推送消息,实现双向通信
- 一个Java实现的简单的多个客户端聊天程序(未测试)
- 简单socket服务(三)实现多客户端向服务器发送数据并保证服务器接收到数据
- Java Socket编程实现简单的问候服务
- java Socket实现简单在线聊天(二)
- java Socket实现简单在线聊天(一)
- Java Socket简单实现客户端与服务端通信
- Android客户端简单的聊天程序实现
- Java Socket编程 - 简单的问候服务实现
- 简单迭代服务器端/客户端:模仿飞Q聊天功能,实现IM通信
- java Socket实现简单在线聊天(三)
- android客户端简单的聊天程序实现
- Nodejs实现的一个简单udp广播服务器、客户端
- android 客户端简单的聊天程序实现
- Android-服务与广播实现简单电话录音
- Java Socket编程 - 简单的问候服务实现
- java实现了简单的Echo服务程序分服务器和客户端