课堂练习：
服务器端和客户端通信：
服务器端
package day16;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerSocketDemo {
public static void main(String[] args) {
try {
ServerSocket ss=new ServerSocket(1234);
System.out.println("服务启动");
while(true){
Socket socket=ss.accept();
System.out.println("连接进来了");
/*InetAddress ssadd=socket.getInetAddress();
String hostname=ssadd.getHostName();
String addr=ssadd.getHostAddress();
byte[] bytes=ssadd.getAddress();
System.out.println("socket.getInetAddress()= "+ssadd+"; ssadd.getHostName()= "+hostname+"; sadd.getHostAddress()= "+bytes);
int port=socket.getPort();
System.out.println("正在接受 "+ssadd+": 的请求");*/
InputStream is=socket.getInputStream();
OutputStream os= socket.getOutputStream();
//读取
BufferedReader br=new BufferedReader(new InputStreamReader(is,"gbk"));
//写入
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(os,"gbk"));
String line=null;
while((line=br.readLine())!=null){
System.out.println("服务端收到数据 "+line);
String send="Hello "+line+"\r\n";
bw.write(send);
bw.flush();
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
客户端：
package day16;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
public class ClientSocketDemo {
public static void main(String[] args) {
try {
Socket socket=new Socket("localhost", 1234);
System.out.println("SOCKET");
//输入
InputStream is=socket.getInputStream();
//输出
OutputStream os= socket.getOutputStream();
//读取
BufferedReader br=new BufferedReader(new InputStreamReader(is,"gbk"));
//写入
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(os,"gbk"));
//写入数据
bw.write("abc! \r\n");
bw.flush();
System.out.println("客户端收到数据 "+br.readLine());
bw.close();
/*while((line=br.readLine())!=null){
System.out.println("客户端收到数据 "+line);
bw.write("abc!");
}*/
} catch (Exception e) {
}
}
}
运行结果：
/** * 服务器端： * 服务启动 * 连接进来了 * 服务端收到数据 abc! * * * 客户端： * 客户端收到数据 Hello abc! */
2.QQ服务端GUI界面
3.在分线程中完成ServerSocket推送消息给所有客户端。
List<OutputStream> ... = ;
代码部分（MessageReceiverThread.java）
package day16.QQ_simpleDemo;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
/**
* 消息接收线程
* @author a5967
*
*/
public class MessageReceiverThread extends Thread{
private QQGUI qqGUI;
private Socket sock;
private List<OutputStream> oslist=new ArrayList<OutputStream>();
private MessageServer server;
public MessageReceiverThread(QQGUI qqGUI,Socket sock){
this.qqGUI=qqGUI;
this.sock=sock;
}
public void run(){
while(true){
try {
BufferedReader br=new BufferedReader(new InputStreamReader(sock.getInputStream(), "gbk"));
String line=null;
while((line=br.readLine())!=null){
server=new MessageServer(qqGUI);
//更新推送的输出流
server.UpdatOutputStreamList(sock);
//更新聊天区域
qqGUI.updateHistory(SocketUtil.getAddr(sock),line);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
代码部分（MessageServer.java）
package day16.QQ_simpleDemo;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.UnsupportedEncodingException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
public class MessageServer {
private QQGUI qqGUI;
//客户端集合
private List<String> clients=new ArrayList<String>();
//输出流所有含有输出流线程的对象
private static List<OutputStream> oslist=new ArrayList<OutputStream>();
public MessageServer(QQGUI qqGUI) {
this.qqGUI=qqGUI;
}
public QQGUI getQqGUI() {
return qqGUI;
}
public void setQqGUI(QQGUI qqGUI) {
this.qqGUI = qqGUI;
}
//启动消息服务器
public void start(int port){
try {
ServerSocket ss=new ServerSocket(port);
System.out.println("服务器启动");
//远程的地址
InetAddress rmaddress;
//远程端口
int rmport=0;
while(true){
final Socket sock=ss.accept();
//更新OutpurStream集合
new MessageReceiverThread(this.qqGUI,sock).start();
rmaddress=sock.getInetAddress();
rmport=sock.getPort();
//添加最新的联系人
clients.add(rmaddress.getHostName()+" : "+rmport);
//刷新列表
qqGUI.addcontact(clients);
}
} catch (Exception e) {
}
}
/**
* 推送消息
* @param string
*/
public void pushMessage() {
try {
BufferedWriter bw=null;
int a=oslist.size();
if(oslist.size()>0){
for(OutputStream clientos:oslist){
bw=new BufferedWriter(new OutputStreamWriter(clientos,"gbk"));
bw.write("有新人进入聊天室 \r\n");
bw.flush();
System.out.println("服务端推送数据数据结束");
}
}
}
catch (Exception e) {
e.printStackTrace();
}
}
/**
* 更新OutputStream集合
* @param sock
*/
public void UpdatOutputStreamList(Socket sock) {
OutputStream os;
try {
os = sock.getOutputStream();
oslist.add(os);
} catch (IOException e) {
e.printStackTrace();
}
}
}
运行结果：
/** * 部分运行结果 * 服务器部分： * 服务器启动 * 服务开始推发送数据 * 服务端推送数据数据结束 * 服务端推发数据完成 * 服务开始推发送数据 * 服务端推送数据数据结束 * 服务端推发数据完成 * 。。。 * * 客户端部分(三个客户端为例) * 客户端1 第1个连接进入的客户端 * 您已成功进入聊天室 * 客户端收到数据 有新人进入聊天室 * 客户端收到数据 有新人进入聊天室 * * 客户端2 第2个连接进入的客户端 * 您已成功进入聊天室 * 客户端收到数据 有新人进入聊天室 * * 客户端3 第3个连接进入的客户端 * 您已成功进入聊天室 */
4.推送联系人列表给所有客户端。
部分代码：
/**
* 推送最新的信息人列表给各个客户端
* @param newclientlist
*/
public void pushNewContactList(List<String> newclientlist) {
try {
BufferedWriter bw=null;
int a=oslist.size();
if(oslist.size()>0){
for(OutputStream clientos:oslist){
bw=new BufferedWriter(new OutputStreamWriter(clientos,"gbk"));
bw.write("当前联系人有\r\n");
for(String contact:newclientlist){
bw.write(contact+"\r\n");
bw.flush();
}
System.out.println("服务端推送当前联系人列表数据结束");
}
}
}
catch (Exception e) {
e.printStackTrace();
}
}
/**
* 部分运行结果
* 服务器启动
* 服务开始推发送数据
* 服务端推送数据数据结束
* 服务端推发数据完成
* 服务端推送当前联系人列表数据结束
* 。。。
*
*
* 客户端部分(三个客户端为例)
* 客户端1 第1个连接进入的客户端
* 您已成功进入聊天室
* 客户端收到数据 当前联系人有
* 客户端收到数据 127.0.0.1 : 50709
* 客户端收到数据 有新人进入聊天室
* 客户端收到数据 当前联系人有
* 客户端收到数据 127.0.0.1 : 50712
* 客户端收到数据 127.0.0.1 : 50709
* 客户端收到数据 有新人进入聊天室
* 客户端收到数据 当前联系人有
* 客户端收到数据 127.0.0.1 : 50712
* 客户端收到数据 127.0.0.1 : 50713
* 客户端收到数据 127.0.0.1 : 50709
*
* 客户端2 第2个连接进入的客户端
* 您已成功进入聊天室
*客户端收到数据 当前联系人有
*客户端收到数据 127.0.0.1 : 50825
*客户端收到数据 127.0.0.1 : 50827
*客户端收到数据 有新人进入聊天室
*客户端收到数据 当前联系人有
*客户端收到数据 127.0.0.1 : 50825
*客户端收到数据 127.0.0.1 : 50827
*客户端收到数据 127.0.0.1 : 50828
*
* 客户端3 第3个连接进入的客户端
* 您已成功进入聊天室
*客户端收到数据 当前联系人有
*客户端收到数据 127.0.0.1 : 50825
*客户端收到数据 127.0.0.1 : 50827
*客户端收到数据 127.0.0.1 : 50828
*/
时间： 2024-10-06 12:30:13