javase练习，简单多客户端聊天 - 黑马程序员技术交流社区

package cn.seven.client;
import java.awt.BorderLayout;
import java.awt.Frame;
import java.awt.TextArea;
import java.awt.TextField;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ConnectException;
import java.net.Socket;
import java.net.UnknownHostException;
public class ChatClient extends Frame{
private TextField field=new TextField();
private TextArea area=new TextArea();
private Socket s=null;
private DataOutputStream dips=null;
private DataInputStream dops=null;
private boolean connect=false;
public static void main(String[] args) {
new ChatClient().launch();
}
public void launch(){
this.setBounds(300, 200,300,200);
this.addWindowListener(new WindowAdapter(){
public void windowClosing(WindowEvent e) {
System.exit(0);
}
});
this.add(field,BorderLayout.SOUTH);
this.add(area,BorderLayout.NORTH);
pack();
area.setEditable(false);
field.addActionListener(new TextListener());
this.setVisible(true);
connect();
new Thread(new Receive()).start();
}
private class Receive implements Runnable{
public void run(){
try {
while(connect){
String str=dops.readUTF();
area.append(str+"\r\n");
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
private void connect() {
try {
s=new Socket("localhost",8888);
connect=true;
dips=new DataOutputStream(s.getOutputStream());
dops=new DataInputStream(s.getInputStream());
} catch (ConnectException e) {
System.out.println("服务器未开启");
System.exit(0);
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e){
e.printStackTrace();
}
}
private class TextListener implements ActionListener{
public void actionPerformed(ActionEvent e) {
String str=null;
str=field.getText();
try {
if(str!=null&&!str.isEmpty()){
//area.append(str+"\r\n");
dips.writeUTF(str);
dips.flush();
field.setText("");
}
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
}
}

复制代码

package cn.seven.sever;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.BindException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.List;
public class ChatServer {
private static ServerSocket ss;
private static List<ClientRun> clients=new ArrayList<ClientRun>();
public static void main(String[] args) {
boolean start=false;
try {
ss = new ServerSocket(8888);
start=true;
while(start){
Socket s=ss.accept();
String ip=s.getInetAddress().getHostName()+"::::::"+s.getPort();
System.out.println(ip+":connect");
ClientRun c=new ClientRun(s);
new Thread(c).start();
clients.add(c);
}
}catch (BindException e) {
System.out.println("服务器已经开启，不要重复开启");
System.exit(0);
} catch (IOException e) {
e.printStackTrace();
}
}
static class ClientRun implements Runnable
{
private Socket s;
private DataInputStream dips;
private DataOutputStream dops;
ClientRun(Socket s)
{
this.s=s;
}
public void send(String str){
try {
dops=new DataOutputStream(s.getOutputStream());
dops.writeUTF(str);
} catch (IOException e) {
clients.remove(this);
System.out.println(s.getPort()+"已经退出");
}
}
public void run() {
boolean connect=true;
int port=s.getPort();
try {
while(connect){
dips=new DataInputStream(s.getInputStream());
String str=dips.readUTF();
System.out.println("["+port+"]"+str);
for(int x=0;x<clients.size();x++){
clients.get(x).send(port+":"+str);
}
}
} catch (SocketException e) {
System.out.println("a client of port "+port+" is unconnect");
}catch (IOException e) {
e.printStackTrace();
}finally{
if(dips!=null){
try {
dips.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(s!=null){
try {
s.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
}

复制代码

import java.awt.*;
import java.awt.event.*;
import java.net.*;
import java.text.*;
import java.util.*;
class NewChattingFrameTest
{
public static void main(String[] args)throws Exception{
DatagramSocket dsSend = new DatagramSocket();
DatagramSocket dsReceive = new DatagramSocket(10000);
new ChattingFrame(dsSend,dsReceive);
}
}
class ChattingFrame
{
private Frame f;
private TextArea taSend,taReceive;
private Panel pSend,pReceive;
private Button b;
private DatagramSocket dsSend,dsReceive;
//这个窗体是为了传送接收信息的，构造时需要发送和接收数据的包
ChattingFrame(DatagramSocket dsSend,DatagramSocket dsReceive){
this.dsSend = dsSend;
this.dsReceive = dsReceive;
init();
Receive r = new Receive(dsReceive,taReceive);
new Thread(r).start();
}
public void init(){
f = new Frame("聊天程序");
f.setBounds(400,200,500,420);
f.setLayout(new BorderLayout(10,10));
//建立上下主面板
pSend = new Panel();
pSend.setPreferredSize(new Dimension(300,100));
pReceive = new Panel();
pReceive.setPreferredSize(new Dimension(300,300));
//布局下边的发送面板内的内容
pSend.setLayout(new BorderLayout(10,10));
taSend = new TextArea();
taSend.setPreferredSize(new Dimension(250,60));
b = new Button("发送");
b.setPreferredSize(new Dimension(30,20));
pSend.add(taSend,BorderLayout.CENTER);
pSend.add(b,BorderLayout.EAST);
//布局上边接收面板的内容
pReceive.setLayout(new BorderLayout());
taReceive = new TextArea();
taReceive.setEditable(false);
pReceive.add(taReceive);
//把主面板添加进窗体内
f.add(pSend,BorderLayout.SOUTH);
f.add(pReceive,BorderLayout.CENTER);
myEvent();
f.setVisible(true);
}
public void myEvent(){
f.addWindowListener(new WindowAdapter(){
public void windowClosing(WindowEvent e){
System.exit(0);
}
});
//添加按钮监听，点击按钮发送信息
b.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent e){
new Thread(new Send(dsSend,taSend.getText())).start();
//System.out.println("清空内容前的长度"+taSend.getText().length());
taSend.setText("");
//System.out.println("清空内容后的长度"+taSend.getText().length());
}
});
//添加键盘监听，点击回车发送数据
taSend.addKeyListener(new KeyAdapter(){
public void keyPressed(KeyEvent e){
if(e.getKeyCode()==KeyEvent.VK_ENTER && !e.isControlDown()){
e.consume();
new Thread(new Send(dsSend,taSend.getText())).start();
//System.out.println("清空内容前的长度"+taSend.getText().length());
taSend.setText("");
//System.out.println("清空内容后的长度"+taSend.getText().length());
}
//if(taSend.getText()=="\r\n")
//taSend.setText("");
}
});
}
}
class Send implements Runnable
{
private DatagramSocket ds;
private String taSend;
//构造时需要接收要发送的数据和发送数据的包
Send(DatagramSocket ds,String taSend){
this.ds = ds;
this.taSend = taSend;
}
public void run(){
try
{
if(taSend==null)
return;
byte[] buf = taSend.getBytes();
//System.out.println("Send类的taSend的长度:"+taSend.length());
//System.out.println("buf的长度："+buf.length);
if(buf.length!=0){
DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("10.23.12.86"),10000);//发送给指定IP
DatagramPacket owndp = new DatagramPacket(buf,buf.length,InetAddress.getLocalHost(),10000);//发送给本机
ds.send(dp);
ds.send(owndp);
}
else
return;
}
catch (UnknownHostException e)
{
throw new RuntimeException("未知主机");
}
catch(Exception e)
{
throw new RuntimeException("IO异常");
}
}
}
class Receive implements Runnable
{
private DatagramSocket ds;
private TextArea taReceive;
//构造时需要接收数据的包和输出接收数据的窗体组件TextArea
Receive(DatagramSocket ds,TextArea taReceive){
this.ds = ds;
this.taReceive = taReceive;
}
public void run(){
//为实现边输入边接收数据的功能，接收程序必须一直执行，不能停止，所以定义无限循环
while(true){
try
{
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf,buf.length);
ds.receive(dp);
int length = dp.getLength();
//接收的数据以字符串形式存储
String content = new String(dp.getData(),0,length);
//获取现在的时间以字符串形式存储
SimpleDateFormat sdf = new SimpleDateFormat("H:m:s");
String date = sdf.format(new Date());
//排列出要显示的信息样式保存在一个字符串当中
String textReceive = dp.getAddress().getHostName()+" "+date+" \r\n"+content+"\r\n\r\n";
//把定义好的字符串添加进taRecieve组件
taReceive.append(textReceive);
}
catch (Exception e)
{
throw new RuntimeException("接收出现错误");
}
}
}
}

复制代码