锐客网

  1. 首页 > 睿知 > it技术 > >

java实现聊天室的代码 java实现聊天室功能包含全部代码,有界面( 三 )

IT技术thread


BufferedReader in; //输入流
public ChatClient() {
JFrame frame = new JFrame("ChatClient");//窗口
frame.setSize(400, 300); //大小
jta = new JTextArea(); //文本域
jta.setEditable(false); //不可编辑
jtf = new JTextField();//文件条
jtf.addActionListener(new ActionListener() { //添加监听 。
public void actionPerformed(ActionEvent arg0) {
send(); //调用send（）方法
}
});
frame.getContentPane().add(new JScrollPane(jta)); //添加滚动条
frame.getContentPane().add(jtf, "South"); //添加文本条
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); //关闭窗口 。
frame.setVisible(true); //可显示的 。
try {
s = new Socket("127.0.0.1", 9000); //连接服务端 socket("主机名"，端口号);
in = new BufferedReader(new InputStreamReader(s.getInputStream())); //建立输入流
out = new PrintWriter(s.getOutputStream());//输出流
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void receive() { //接受服务端发来别的客户端的信息 。
while (true) {
try {
String text = in.readLine(); //读一行
this.jta.append(text + "\n"); //jta 添加上读入的 。
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return;
}
}
}
public void send() { //发送消息
String text = this.jtf.getText(); //得到你输入的消息
this.jtf.setText(""); //在文本域中显示你输入的消息 。
out.println(text); //打印出 。
out.flush(); //清空
}
}
Server端
import java.net.*;
import java.io.*;
import java.util.*;//引入包
public class ChatServer {
public static void main(String[] args) throws Exception {
ServerSocket ss = new ServerSocket(9000); //建立服务端，端口号为9000
List list = new ArrayList(); //创建个List集合 。
while (true) {
Socket s = ss.accept(); //等待客户端的请求 。
list.add(s); //把每一个client都add到集合中去 。
Thread t = new ServerThread(s, list); //线程 。
t.start(); //启动 。
}
}
}
class ServerThread extends Thread {
Socket s;
【java实现聊天室的代码 java实现聊天室功能包含全部代码,有界面】 List list;
BufferedReader in;
PrintWriter out;
public ServerThread(Socket s, List list) { //构造 。传入socket和list 。
this.s = s;
this.list = list;
try {
in = new BufferedReader(new InputStreamReader(s.getInputStream())); //输入流
out = new PrintWriter(s.getOutputStream()); //输出流
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void run() { //必须实现其run（）方法 。
while (true) {
try {
String str = in.readLine(); //得到client端的message 。
if (str == null) //如果没有消息就返回 。
return;
Iterator it = list.iterator(); //遍历list 。
while (it.hasNext()) { //如果list有下一个
Socket socket = (Socket) (it.next()); //因为list中都是存的socket
PrintWriter o = new PrintWriter(socket.getOutputStream()); //输出流
o.println(str); //输出
o.flush(); //清空
}
} catch (IOException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
return;
}
}
}
}
java实现聊天室的代码的介绍就聊到这里吧 ， 感谢你花时间阅读本站内容，更多关于java实现聊天室功能包含全部代码,有界面、java实现聊天室的代码的信息别忘了在本站进行查找喔 。

推荐阅读


上一篇：oracle数据库的查找，oracle数据库查找数据

下一篇：b站王者直播赚钱吗现在，b站王者荣耀直播间