共四個(gè)java文件，源代碼如下：
成都地區(qū)優(yōu)秀IDC服務(wù)器托管提供商(成都創(chuàng)新互聯(lián)).為客戶(hù)提供專(zhuān)業(yè)的綿陽(yáng)服務(wù)器托管,四川各地服務(wù)器托管,綿陽(yáng)服務(wù)器托管、多線服務(wù)器托管.托管咨詢(xún)專(zhuān)線：13518219792
import java.awt.*;
import java.net.*;
import java.awt.event.*;
import java.io.*;
import java.util.Hashtable;
public class ChatArea extends Panel implements ActionListener,Runnable
{
Socket socket=null;
DataInputStream in=null;
DataOutputStream out=null;
Thread threadMessage=null;
TextArea 談話顯示區(qū),私聊顯示區(qū)=null;
TextField 送出信息=null;
Button 確定,刷新談話區(qū),刷新私聊區(qū);
Label 提示條=null;
String name=null;
Hashtable listTable;
List listComponent=null;
Choice privateChatList;
int width,height;
public ChatArea(String name,Hashtable listTable,int width,int height)
{
setLayout(null);
setBackground(Color.orange);
this.width=width;
this.height=height;
setSize(width,height);
this.listTable=listTable;
this.name=name;
threadMessage=new Thread(this);
談話顯示區(qū)=new TextArea(10,10);
私聊顯示區(qū)=new TextArea(10,10);
確定=new Button("送出信息到:");
刷新談話區(qū)=new Button("刷新談話區(qū)");
刷新私聊區(qū)=new Button("刷新私聊區(qū)");
提示條=new Label("雙擊聊天者可私聊",Label.CENTER);
送出信息=new TextField(28);
確定.addActionListener(this);
送出信息.addActionListener(this);
刷新談話區(qū).addActionListener(this);
刷新私聊區(qū).addActionListener(this);
listComponent=new List();
listComponent.addActionListener(this);
privateChatList=new Choice();
privateChatList.add("大家(*)");
privateChatList.select(0);
add(談話顯示區(qū));
談話顯示區(qū).setBounds(10,10,(width-120)/2,(height-120));
add(私聊顯示區(qū));
私聊顯示區(qū).setBounds(10+(width-120)/2,10,(width-120)/2,(height-120));
add(listComponent);
listComponent.setBounds(10+(width-120),10,100,(height-160));
add(提示條);
提示條.setBounds(10+(width-120),10+(height-160),110,40);
Panel pSouth=new Panel();
pSouth.add(送出信息);
pSouth.add(確定);
pSouth.add(privateChatList);
pSouth.add(刷新談話區(qū));
pSouth.add(刷新私聊區(qū));
add(pSouth);
pSouth.setBounds(10,20+(height-120),width-20,60);
}
public void setName(String s)
{
name=s;
}
public void setSocketConnection(Socket socket,DataInputStream in,DataOutputStream out)
{
this.socket=socket;
this.in=in;
this.out=out;
try
{
threadMessage.start();
}
catch(Exception e)
{
}
}
public void actionPerformed(ActionEvent e)
{
if(e.getSource()==確定||e.getSource()==送出信息)
{
String message="";
String people=privateChatList.getSelectedItem();
people=people.substring(0,people.indexOf("("));
message=送出信息.getText();
if(message.length()0)
{
try {
if(people.equals("大家"))
{
out.writeUTF("公共聊天內(nèi)容:"+name+"說(shuō):"+message);
}
else
{
out.writeUTF("私人聊天內(nèi)容:"+name+"悄悄地說(shuō):"+message+"#"+people);
}
}
catch(IOException event)
{
}
}
}
else if(e.getSource()==listComponent)
{
privateChatList.insert(listComponent.getSelectedItem(),0);
privateChatList.repaint();
}
else if(e.getSource()==刷新談話區(qū))
{
談話顯示區(qū).setText(null);
}
else if(e.getSource()==刷新私聊區(qū))
{
私聊顯示區(qū).setText(null);
}
}
public void run()
{
while(true)
{
String s=null;
try
{
s=in.readUTF();
if(s.startsWith("聊天內(nèi)容:"))
{
String content=s.substring(s.indexOf(":")+1);
談話顯示區(qū).append("\n"+content);
}
if(s.startsWith("私人聊天內(nèi)容:"))
{
String content=s.substring(s.indexOf(":")+1);
私聊顯示區(qū).append("\n"+content);
}
else if(s.startsWith("聊天者:"))
{
String people=s.substring(s.indexOf(":")+1,s.indexOf("性別"));
String sex=s.substring(s.indexOf("性別")+2);
listTable.put(people,people+"("+sex+")");
listComponent.add((String)listTable.get(people));
listComponent.repaint();
}
else if(s.startsWith("用戶(hù)離線:"))
{
String awayPeopleName=s.substring(s.indexOf(":")+1);
listComponent.remove((String)listTable.get(awayPeopleName));
listComponent.repaint();
談話顯示區(qū).append("\n"+(String)listTable.get(awayPeopleName)+"離線");
listTable.remove(awayPeopleName);
}
Thread.sleep(5);
}
catch(IOException e)
{
listComponent.removeAll();
listComponent.repaint();
listTable.clear();
談話顯示區(qū).setText("和服務(wù)器的連接已中斷\n必須刷新瀏覽器才能再次聊天");
break;
}
catch(InterruptedException e)
{
}
}
}
}
ChatServer.java
import java.io.*;
import java.net.*;
import java.util.*;
public class ChatServer
{
public static void main(String args[])
{
ServerSocket server=null;
Socket you=null;
Hashtable peopleList;
peopleList=new Hashtable();
while(true)
{
try
{
server=new ServerSocket(6666);
}
catch(IOException e1)
{
System.out.println("正在監(jiān)聽(tīng)");
}
try {
you=server.accept();
InetAddress address=you.getInetAddress();
System.out.println("用戶(hù)的IP:"+address);
}
catch (IOException e)
{
}
if(you!=null)
{
Server_thread peopleThread=new Server_thread(you,peopleList);
peopleThread.start();
}
else {
continue;
}
}
}
}
class Server_thread extends Thread
{
String name=null,sex=null;
Socket socket=null;
File file=null;
DataOutputStream out=null;
DataInputStream in=null;
Hashtable peopleList=null;
Server_thread(Socket t,Hashtable list)
{
peopleList=list;
socket=t;
try {
in=new DataInputStream(socket.getInputStream());
out=new DataOutputStream(socket.getOutputStream());
}
catch (IOException e)
{
}
}
public void run()
{
while(true)
{ String s=null;
try
{
s=in.readUTF();
if(s.startsWith("姓名:"))
{
name=s.substring(s.indexOf(":")+1,s.indexOf("性別"));
sex=s.substring(s.lastIndexOf(":")+1);
boolean boo=peopleList.containsKey(name);
if(boo==false)
{
peopleList.put(name,this);
out.writeUTF("可以聊天:");
Enumeration enum=peopleList.elements();
while(enum.hasMoreElements())
{
Server_thread th=(Server_thread)enum.nextElement();
th.out.writeUTF("聊天者:"+name+"性別"+sex);
if(th!=this)
{
out.writeUTF("聊天者:"+th.name+"性別"+th.sex);
}
}
}
else
{
out.writeUTF("不可以聊天:");
}
}
else if(s.startsWith("公共聊天內(nèi)容:"))
{
String message=s.substring(s.indexOf(":")+1);
Enumeration enum=peopleList.elements();
while(enum.hasMoreElements())
{
((Server_thread)enum.nextElement()).out.writeUTF("聊天內(nèi)容:"+message);
}
}
else if(s.startsWith("用戶(hù)離開(kāi):"))
{
Enumeration enum=peopleList.elements();
while(enum.hasMoreElements())
{ try
{
Server_thread th=(Server_thread)enum.nextElement();
if(th!=thisth.isAlive())
{
th.out.writeUTF("用戶(hù)離線:"+name);
}
}
catch(IOException eee)
{
}
}
peopleList.remove(name);
socket.close();
System.out.println(name+"用戶(hù)離開(kāi)了");
break;
}
else if(s.startsWith("私人聊天內(nèi)容:"))
{
String 悄悄話=s.substring(s.indexOf(":")+1,s.indexOf("#"));
String toPeople=s.substring(s.indexOf("#")+1);
Server_thread toThread=(Server_thread)peopleList.get(toPeople);
if(toThread!=null)
{
toThread.out.writeUTF("私人聊天內(nèi)容:"+悄悄話);
}
else
{
out.writeUTF("私人聊天內(nèi)容:"+toPeople+"已經(jīng)離線");
}
}
}
catch(IOException ee)
{
Enumeration enum=peopleList.elements();
while(enum.hasMoreElements())
{ try
{
Server_thread th=(Server_thread)enum.nextElement();
if(th!=thisth.isAlive())
{
th.out.writeUTF("用戶(hù)離線:"+name);
}
}
catch(IOException eee)
{
}
}
peopleList.remove(name);
try
{
socket.close();
}
catch(IOException eee)
{
}
System.out.println(name+"用戶(hù)離開(kāi)了");
break;
}
}
}
}
import java.awt.*;
import java.io.*;
import java.net.*;
import java.applet.*;
import java.util.Hashtable;
ClientChat.java
public class ClientChat extends Applet implements Runnable
{
Socket socket=null;
DataInputStream in=null;
DataOutputStream out=null;
InputNameTextField 用戶(hù)提交昵稱(chēng)界面=null;
ChatArea 用戶(hù)聊天界面=null;
Hashtable listTable;
Label 提示條;
Panel north, center;
Thread thread;
public void init()
{
int width=getSize().width;
int height=getSize().height;
listTable=new Hashtable();
setLayout(new BorderLayout());
用戶(hù)提交昵稱(chēng)界面=new InputNameTextField(listTable);
int h=用戶(hù)提交昵稱(chēng)界面.getSize().height;
用戶(hù)聊天界面=new ChatArea("",listTable,width,height-(h+5));
用戶(hù)聊天界面.setVisible(false);
提示條=new Label("正在連接到服務(wù)器,請(qǐng)稍等...",Label.CENTER);
提示條.setForeground(Color.red);
north=new Panel(new FlowLayout(FlowLayout.LEFT));
center=new Panel();
north.add(用戶(hù)提交昵稱(chēng)界面);
north.add(提示條);
center.add(用戶(hù)聊天界面);
add(north,BorderLayout.NORTH);
add(center,BorderLayout.CENTER);
validate();
}
public void start()
{
if(socket!=nullin!=nullout!=null)
{ try
{
socket.close();
in.close();
out.close();
用戶(hù)聊天界面.setVisible(false);
}
catch(Exception ee)
{
}
}
try
{
socket = new Socket(this.getCodeBase().getHost(), 6666);
in=new DataInputStream(socket.getInputStream());
out=new DataOutputStream(socket.getOutputStream());
}
catch (IOException ee)
{
提示條.setText("連接失敗");
}
if(socket!=null)
{
InetAddress address=socket.getInetAddress();
提示條.setText("連接:"+address+"成功");
用戶(hù)提交昵稱(chēng)界面.setSocketConnection(socket,in,out);
north.validate();
}
if(thread==null)
{
thread=new Thread(this);
thread.start();
}
}
public void stop()
{
try
{
socket.close();
thread=null;
}
catch(IOException e)
{
this.showStatus(e.toString());
}
}
public void run()
{
while(thread!=null)
{
if(用戶(hù)提交昵稱(chēng)界面.get能否聊天()==true)
{
用戶(hù)聊天界面.setVisible(true);
用戶(hù)聊天界面.setName(用戶(hù)提交昵稱(chēng)界面.getName());
用戶(hù)聊天界面.setSocketConnection(socket,in,out);
提示條.setText("祝聊天愉快!");
center.validate();
break;
}
try
{
Thread.sleep(100);
}
catch(Exception e)
{
}
}
}
}
InputNameTextField。java
import java.awt.*;
import java.net.*;
import java.awt.event.*;
import java.io.*;
import java.util.Hashtable;
public class InputNameTextField extends Panel implements ActionListener,Runnable
{
TextField nameFile=null;
String name=null;
Checkbox male=null,female=null;
CheckboxGroup group=null;
Button 進(jìn)入聊天室=null,退出聊天室=null;
Socket socket=null;
DataInputStream in=null;
DataOutputStream out=null;
Thread thread=null;
boolean 能否聊天=false;
Hashtable listTable;
public InputNameTextField(Hashtable listTable)
{
this.listTable=listTable;
nameFile=new TextField(10);
group=new CheckboxGroup();
male=new Checkbox("男",true,group);
female=new Checkbox("女",false,group);
進(jìn)入聊天室=new Button("進(jìn)入");
退出聊天室=new Button("退出");
進(jìn)入聊天室.addActionListener(this);
退出聊天室.addActionListener(this);
thread=new Thread(this);
add(new Label("昵稱(chēng):"));
add(nameFile);
add(male);
add(female);
add(進(jìn)入聊天室);
add(退出聊天室);
退出聊天室.setEnabled(false);
}
public void set能否聊天(boolean b)
{
能否聊天=b;
}
public boolean get能否聊天()
{
return 能否聊天;
}
public String getName()
{
return name;
}
public void setName(String s)
{
name=s;
}
public void setSocketConnection(Socket socket,DataInputStream in,DataOutputStream out)
{
this.socket=socket;
this.in=in;
this.out=out;
try{
thread.start();
}
catch(Exception e)
{
nameFile.setText(""+e);
}
}
public Socket getSocket()
{
return socket;
}
public void actionPerformed(ActionEvent e)
{
if(e.getSource()==進(jìn)入聊天室)
{
退出聊天室.setEnabled(true);
if(能否聊天==true)
{
nameFile.setText("您正在聊天:"+name);
}
else
{
this.setName(nameFile.getText());
String sex=group.getSelectedCheckbox().getLabel();
if(socket!=nullname!=null)
{
try{
out.writeUTF("姓名:"+name+"性別:"+sex);
}
catch(IOException ee)
{
nameFile.setText("沒(méi)有連通服務(wù)器"+ee);
}
}
}
}
if(e.getSource()==退出聊天室)
{
try
{
out.writeUTF("用戶(hù)離開(kāi):");
}
catch(IOException ee)
{
}
}
}
public void run()
{
String message=null;
while(true)
{
if(in!=null)
{
try
{
message=in.readUTF();
}
catch(IOException e)
{
nameFile.setText("和服務(wù)器斷開(kāi)"+e);
}
}
if(message.startsWith("可以聊天:"))
{
能否聊天=true;
break;
}
else if(message.startsWith("聊天者:"))
{
String people=message.substring(message.indexOf(":")+1);
listTable.put(people,people);
}
else if(message.startsWith("不可以聊天:"))
{
能否聊天=false;
nameFile.setText("該昵稱(chēng)已被占用");
}
}
}
}
【ClientSocketDemo.java 客戶(hù)端Java源代碼】
import java.net.*;
import java.io.*;
public class ClientSocketDemo
{
//聲明客戶(hù)端Socket對(duì)象socket
Socket socket = null;
//聲明客戶(hù)器端數(shù)據(jù)輸入輸出流
DataInputStream in;
DataOutputStream out;
//聲明字符串?dāng)?shù)組對(duì)象response，用于存儲(chǔ)從服務(wù)器接收到的信息
String response[];
//執(zhí)行過(guò)程中，沒(méi)有參數(shù)時(shí)的構(gòu)造方法，本地服務(wù)器在本地，取默認(rèn)端口10745
public ClientSocketDemo()
{
try
{
//創(chuàng)建客戶(hù)端socket，服務(wù)器地址取本地，端口號(hào)為10745
socket = new Socket("localhost",10745);
//創(chuàng)建客戶(hù)端數(shù)據(jù)輸入輸出流，用于對(duì)服務(wù)器端發(fā)送或接收數(shù)據(jù)
in = new DataInputStream(socket.getInputStream());
out = new DataOutputStream(socket.getOutputStream());
//獲取客戶(hù)端地址及端口號(hào)
String ip = String.valueOf(socket.getLocalAddress());
String port = String.valueOf(socket.getLocalPort());
//向服務(wù)器發(fā)送數(shù)據(jù)
out.writeUTF("Hello Server.This connection is from client.");
out.writeUTF(ip);
out.writeUTF(port);
//從服務(wù)器接收數(shù)據(jù)
response = new String[3];
for (int i = 0; i response.length; i++)
{
response[i] = in.readUTF();
System.out.println(response[i]);
}
}
catch(UnknownHostException e){e.printStackTrace();}
catch(IOException e){e.printStackTrace();}
}
//執(zhí)行過(guò)程中，有一個(gè)參數(shù)時(shí)的構(gòu)造方法，參數(shù)指定服務(wù)器地址，取默認(rèn)端口10745
public ClientSocketDemo(String hostname)
{
try
{
//創(chuàng)建客戶(hù)端socket，hostname參數(shù)指定服務(wù)器地址，端口號(hào)為10745
socket = new Socket(hostname,10745);
in = new DataInputStream(socket.getInputStream());
out = new DataOutputStream(socket.getOutputStream());
String ip = String.valueOf(socket.getLocalAddress());
String port = String.valueOf(socket.getLocalPort());
out.writeUTF("Hello Server.This connection is from client.");
out.writeUTF(ip);
out.writeUTF(port);
response = new String[3];
for (int i = 0; i response.length; i++)
{
response[i] = in.readUTF();
System.out.println(response[i]);
}
}
catch(UnknownHostException e){e.printStackTrace();}
catch(IOException e){e.printStackTrace();}
}
//執(zhí)行過(guò)程中，有兩個(gè)個(gè)參數(shù)時(shí)的構(gòu)造方法，第一個(gè)參數(shù)hostname指定服務(wù)器地址
//第一個(gè)參數(shù)serverPort指定服務(wù)器端口號(hào)
public ClientSocketDemo(String hostname,String serverPort)
{
try
{
socket = new Socket(hostname,Integer.parseInt(serverPort));
in = new DataInputStream(socket.getInputStream());
out = new DataOutputStream(socket.getOutputStream());
String ip = String.valueOf(socket.getLocalAddress());
String port = String.valueOf(socket.getLocalPort());
out.writeUTF("Hello Server.This connection is from client.");
out.writeUTF(ip);
out.writeUTF(port);
response = new String[3];
for (int i = 0; i response.length; i++)
{
response[i] = in.readUTF();
System.out.println(response[i]);
}
}
catch(UnknownHostException e){e.printStackTrace();}
catch(IOException e){e.printStackTrace();}
}
public static void main(String[] args)
{
String comd[] = args;
if(comd.length == 0)
{
System.out.println("Use localhost(127.0.0.1) and default port");
ClientSocketDemo demo = new ClientSocketDemo();
}
else if(comd.length == 1)
{
System.out.println("Use default port");
ClientSocketDemo demo = new ClientSocketDemo(args[0]);
}
else if(comd.length == 2)
{
System.out.println("Hostname and port are named by user");
ClientSocketDemo demo = new ClientSocketDemo(args[0],args[1]);
}
else System.out.println("ERROR");
}
}
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
【ServerSocketDemo.java 服務(wù)器端Java源代碼】
import java.net.*;
import java.io.*;
public class ServerSocketDemo
{
//聲明ServerSocket類(lèi)對(duì)象
ServerSocket serverSocket;
//聲明并初始化服務(wù)器端監(jiān)聽(tīng)端口號(hào)常量
public static final int PORT = 10745;
//聲明服務(wù)器端數(shù)據(jù)輸入輸出流
DataInputStream in;
DataOutputStream out;
//聲明InetAddress類(lèi)對(duì)象ip，用于獲取服務(wù)器地址及端口號(hào)等信息
InetAddress ip = null;
//聲明字符串?dāng)?shù)組對(duì)象request，用于存儲(chǔ)從客戶(hù)端發(fā)送來(lái)的信息
String request[];
public ServerSocketDemo()
{
request = new String[3]; //初始化字符串?dāng)?shù)組
try
{
//獲取本地服務(wù)器地址信息
ip = InetAddress.getLocalHost();
//以PORT為服務(wù)端口號(hào)，創(chuàng)建serverSocket對(duì)象以監(jiān)聽(tīng)該端口上的連接
serverSocket = new ServerSocket(PORT);
//創(chuàng)建Socket類(lèi)的對(duì)象socket，用于保存連接到服務(wù)器的客戶(hù)端socket對(duì)象
Socket socket = serverSocket.accept();
System.out.println("This is server:"+String.valueOf(ip)+PORT);
//創(chuàng)建服務(wù)器端數(shù)據(jù)輸入輸出流，用于對(duì)客戶(hù)端接收或發(fā)送數(shù)據(jù)
in = new DataInputStream(socket.getInputStream());
out = new DataOutputStream(socket.getOutputStream());
//接收客戶(hù)端發(fā)送來(lái)的數(shù)據(jù)信息，并顯示
request[0] = in.readUTF();
request[1] = in.readUTF();
request[2] = in.readUTF();
System.out.println("Received messages form client is:");
System.out.println(request[0]);
System.out.println(request[1]);
System.out.println(request[2]);
//向客戶(hù)端發(fā)送數(shù)據(jù)
out.writeUTF("Hello client!");
out.writeUTF("Your ip is:"+request[1]);
out.writeUTF("Your port is:"+request[2]);
}
catch(IOException e){e.printStackTrace();}
}
public static void main(String[] args)
{
ServerSocketDemo demo = new ServerSocketDemo();
}
}
1、swing的界面可以直接用netbeans畫(huà)出來(lái)嘛。
2、可以把輸出的聊天內(nèi)容都放在一個(gè)StringBuffer里，每打出一句話，就把這句話追加在StringBuffer，然后把StringBuffer里的內(nèi)容輸出到Textarea中。
3、好友列表可以用JList
//以下引入包
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import java.applet.*;
public class regit extends JApplet implements ActionListener,ItemListener//接口
{
String s=null;
//對(duì)象的聲明
JLabel labelname,labelpass,labelsxe,labeladdress,labelmail,labelphone;//標(biāo)簽
JTextField textname,textaddress,textmail,textphone;//文本框
JRadioButton r1,r2;//單選按紐
ButtonGroup bg;//組
JPasswordField textpass;//密碼域
JButton buttonregit,buttonreset;//注冊(cè)按紐 重寫(xiě)按紐
JPanel p;//面板
String sex;//定義性別字符串
URL url;//統(tǒng)一資源定位
BufferedWriter out1,out2;//流
BufferedReader in;
//布局方式
GridBagLayout gbl;
GridBagConstraints gc;
AppletContext co;//接口
//初始化
public void init()
{
//new 對(duì)象
labelname=new JLabel("用 戶(hù) 名:");
labelpass=new JLabel("用戶(hù)密碼:");
labelsxe=new JLabel("性別:");
labeladdress=new JLabel("地址:");
labelmail=new JLabel("電子郵件:");
labelphone=new JLabel("聯(lián)系電話:");
textname=new JTextField(15); textname.setForeground(Color.red);
textname.setToolTipText("請(qǐng)?jiān)谶@輸入你的用戶(hù)名");
textaddress=new JTextField(15);textaddress.setForeground(Color.red);
textaddress.setToolTipText("請(qǐng)?jiān)谶@輸入你的地址");
textmail=new JTextField(15); textmail.setForeground(Color.red);
textmail.setToolTipText("請(qǐng)?jiān)谶@里輸入你的E-mail地址");
textphone=new JTextField(15); textphone.setForeground(Color.red);
textphone.setToolTipText("請(qǐng)?jiān)谶@輸入你的電話號(hào)碼");
r1=new JRadioButton("男"); r1.setBackground(new Color(47,177,210));//設(shè)置顏色
r2=new JRadioButton("女"); r2.setBackground(new Color(47,177,210));//設(shè)置顏色
bg=new ButtonGroup();
bg.add(r1);bg.add(r2);//加入組,實(shí)現(xiàn)單選
textpass=new JPasswordField(15);
textpass.setToolTipText("在這里輸入密碼");
textpass.setForeground(Color.red);
buttonregit=new JButton("注冊(cè)"); buttonregit.setBackground(new Color(47,177,210));//設(shè)置顏色
buttonregit.setToolTipText("點(diǎn)擊按紐完成注冊(cè)");
buttonreset=new JButton("填寫(xiě)"); buttonreset.setBackground(new Color(47,177,210));//設(shè)置顏色
buttonreset.setToolTipText("點(diǎn)擊按紐刷新重寫(xiě)");
gbl=new GridBagLayout(); ///////////////////////////////////////
gc=new GridBagConstraints(); //////采用GridBagLayout布局方式////////
p=new JPanel();
p.setLayout(gbl);
p.setBackground(new Color(47,177,210));
this.getContentPane().add(p);//加入面板
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=2;
gc.gridy=2;
gbl.setConstraints(labelname,gc);
p.add(labelname);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=4;
gc.gridy=2;
gbl.setConstraints(textname,gc);
p.add(textname);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=2;
gc.gridy=4;
gbl.setConstraints(labelpass,gc);
p.add(labelpass);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=4;
gc.gridy=4;
gbl.setConstraints(textpass,gc);
p.add(textpass);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=2;
gc.gridy=6;
gbl.setConstraints(labelsxe,gc);
p.add(labelsxe);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=4;
gc.gridy=6;
gbl.setConstraints(r1,gc);
p.add(r1);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=5;
gc.gridy=6;
gbl.setConstraints(r2,gc);
p.add(r2);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=2;
gc.gridy=8;
gbl.setConstraints(labeladdress,gc);
p.add(labeladdress);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=4;
gc.gridy=8;
gbl.setConstraints(textaddress,gc);
p.add(textaddress);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=2;
gc.gridy=10;
gbl.setConstraints(labelmail,gc);
p.add(labelmail);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=4;
gc.gridy=10;
gbl.setConstraints(textmail,gc);
p.add(textmail);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=2;
gc.gridy=12;
gbl.setConstraints(labelphone,gc);
p.add(labelphone);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=4;
gc.gridy=12;
gbl.setConstraints(textphone,gc);
p.add(textphone);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=2;
gc.gridy=16;
gbl.setConstraints(buttonregit,gc);
p.add(buttonregit);
gc.anchor=GridBagConstraints.NORTHWEST;
gc.gridx=4;
gc.gridy=16;
gbl.setConstraints(buttonreset,gc);
p.add(buttonreset);
/////////////////////////////////////////////
co=this.getAppletContext();
/////////////////////////////////////////////
buttonregit.addActionListener(this);//按紐事件的監(jiān)聽(tīng)
buttonreset.addActionListener(this);//按紐事件的監(jiān)聽(tīng)
r1.addItemListener(this);//選擇事件的監(jiān)聽(tīng)
r2.addItemListener(this);//選擇事件的監(jiān)聽(tīng)
textphone.addActionListener(this);
}
public void actionPerformed(ActionEvent e)
{
//注冊(cè)按紐事件
if(e.getSource()==buttonregit)
{
String s1=textname.getText(); ////////////////////
String s2=new String(textpass.getPassword());////////////////////
String s3=textaddress.getText(); // 定義字符串 //
String s4=textmail.getText(); ////////////////////
String s5=textphone.getText(); ////////////////////
//判斷注冊(cè)資料 信息 是否為空
if(s1.length()==0 || s2.length()==0 ||s3.length()==0 ||s4.length()==0 ||s5.length()==0)
{
int error=JOptionPane.INFORMATION_MESSAGE;
JOptionPane.showMessageDialog(null,"資料不能為空，請(qǐng)重新注冊(cè)！","【溫馨提示】",error);
return;//彈出對(duì)話框并返回
}
try//寫(xiě)入到txt文件
{
in=new BufferedReader(new FileReader("d:\\迷離視線聊天室\\password.txt"));
}
catch(Exception ee){}
String ss=s1;
try
{
while((s=in.readLine())!=null)
{
if(s.startsWith(ss))
{
JOptionPane.showMessageDialog(null,"用戶(hù)名已經(jīng)存在，請(qǐng)更換名字！");
textname.setText("");//設(shè)置為空，重新輸入
textpass.setText("");
textaddress.setText("");
textmail.setText("");
textphone.setText("");
return;
}
}
}
catch(Exception ee){}
///////////////////////////以上代碼判斷是否有同名
{
try
{
out1=new BufferedWriter(new FileWriter("d:\\迷離視線聊天室\\password.txt",true));
out2=new BufferedWriter(new FileWriter("d:\\迷離視線聊天室\\message.txt",true));
}//創(chuàng)建文件
catch(Exception ee)
{}
try
{
out1.write(s1+"#"+s2);//寫(xiě)
out1.newLine();
out2.write("用戶(hù)名："+s1);
out2.newLine();
out2.write("密碼："+s2);
out2.newLine();
out2.write("性別："+sex);
out2.newLine();
out2.write("地址："+s3);
out2.newLine();
out2.write("電子郵件："+s4);
out2.newLine();
out2.write("電話："+s5);
out2.newLine();
out1.flush();
out2.flush();//清理緩沖
out1.close();
out2.close();
}
catch(Exception ee)
{}
JOptionPane.showMessageDialog(null,"注冊(cè)成功！");
try
{
String qss="";
url=new url(/qss);//連接上網(wǎng)址
co.showDocument(url);
}
catch(Exception exx)
{}
}
}
//////////////////////以下為回車(chē)事件
if(e.getSource()==textphone)
{
String s1=textname.getText(); ////////////////////
String s2=new String(textpass.getPassword());////////////////////
String s3=textaddress.getText(); // 定義字符串 //
String s4=textmail.getText(); ////////////////////
String s5=textphone.getText(); ////////////////////
//判斷注冊(cè)資料 信息 是否為空
if(s1.length()==0 || s2.length()==0 ||s3.length()==0 ||s4.length()==0 ||s5.length()==0)
{
int error=JOptionPane.INFORMATION_MESSAGE;
JOptionPane.showMessageDialog(null,"資料不能為空，請(qǐng)重新注冊(cè)！","【溫馨提示】",error);
return;//彈出對(duì)話框并返回
}
try//寫(xiě)入到txt文件
{
in=new BufferedReader(new FileReader("d:\\迷離視線聊天室\\password.txt"));
}
catch(Exception ee){}
String ss=s1;
try
{
while((s=in.readLine())!=null)
{
if(s.startsWith(ss))
{
JOptionPane.showMessageDialog(null,"用戶(hù)名已經(jīng)存在，請(qǐng)更換名字！");
textname.setText("");//設(shè)置為空，重新輸入
textpass.setText("");
textaddress.setText("");
textmail.setText("");
textphone.setText("");
return;
}
}
}
catch(Exception ee){}
///////////////////////////以上代碼判斷是否有同名
{
try
{
out1=new BufferedWriter(new FileWriter("d:\\迷離視線聊天室\\password.txt",true));
out2=new BufferedWriter(new FileWriter("d:\\迷離視線聊天室\\message.txt",true));
}//創(chuàng)建文件
catch(Exception ee)
{}
try
{
out1.write(s1+"#"+s2);//寫(xiě)
out1.newLine();
out2.write("用戶(hù)名："+s1+"密碼："+s2+"性別："+sex+"地址："+s3+"電子郵件："+s4+"電話："+s5);//寫(xiě)
out2.newLine();
out1.flush();
out2.flush();//清理緩沖
out1.close();
out2.close();
}
catch(Exception ee)
{}
JOptionPane.showMessageDialog(null,"注冊(cè)成功！");
try
{
String qss="";
url=new url(/qss);//連接上網(wǎng)址
co.showDocument(url);
}
catch(Exception exx)
{}
}
}
if(e.getSource()==buttonreset)//刷新重寫(xiě)事件
{
textname.setText("");
textpass.setText("");
textaddress.setText("");
textmail.setText("");
textphone.setText("");
}
}
//////////////////////////////////////////
//
public void itemStateChanged(ItemEvent ex)
{
if(ex.getSource()==r1)
{
sex=new String("男");
}
else if(ex.getSource()==r2)
{
sex=new String("女");
}
}
}
服務(wù)端 用戶(hù)名 y 密碼 1 客戶(hù)端代碼在我的評(píng)論里，這敲不了那么多字，沒(méi)辦法。
登陸實(shí)現(xiàn)類(lèi)：class Login
package com.server;
import java.awt.Color;
import java.awt.Font;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPasswordField;
import javax.swing.JTextField;
public class Login {
boolean f=false;//按登錄時(shí)設(shè)置的一個(gè)標(biāo)志
private JFrame frame = new JFrame("Welcome To MLDN") ;
//設(shè)置窗體
private JButton submit = new JButton("登陸");//設(shè)置登錄按鈕
private JButton reset = new JButton("重置");//設(shè)置重置按鈕
private JLabel nameLab = new JLabel("服務(wù)器：") ;//標(biāo)簽實(shí)例化
private JLabel passLab = new JLabel("密 碼："); //標(biāo)簽實(shí)例化
private JLabel infoLab = new JLabel("服務(wù)器登陸系統(tǒng)"); //標(biāo)簽實(shí)例化
private JTextField nameText = new JTextField(10);//單行文本輸入條
private JPasswordField passText = new JPasswordField() ;//單行密碼文本輸入條
public Login(){//登錄窗口構(gòu)造方法
Font fnt = new Font("Serief",Font.ITALIC + Font.BOLD,12); //設(shè)置字體
infoLab.setFont(fnt) ; // 設(shè)置標(biāo)簽的顯示文字
submit.addActionListener(new ActionListener(){ //采用內(nèi)部匿名類(lèi)
public void actionPerformed(ActionEvent e){
if(e.getSource()==submit){ //判斷觸發(fā)器源是否是提交按鈕
String tname = nameText.getText() ; //得到輸入的用戶(hù)名
String tpass = new String(passText.getPassword()) ;//得到輸入的密碼,此時(shí)通過(guò)getPassageword()方法返回的是字符數(shù)組
LoginCheck log = new LoginCheck(tname,tpass) ;//實(shí)例化LoginCheck對(duì)象,傳入輸入的用戶(hù)名和密碼
if(log.validate()){//對(duì)用戶(hù)名和密碼進(jìn)行驗(yàn)證
try{ //線程異常處理try
Thread.sleep(2000); //2秒后打開(kāi)聊天窗口
f=true; //登錄成功后的表示項(xiàng)為true
frame.dispose(); //關(guān)閉本窗口
}catch(Exception e1){//異常獲取
e1.printStackTrace();
}
}else{
infoLab.setText("登陸失敗，錯(cuò)誤的用戶(hù)名或密碼！") ;//登錄失敗
}
}
}
});
reset.addActionListener(new ActionListener(){ //采用內(nèi)部匿名類(lèi)
public void actionPerformed(ActionEvent e){
if(e.getSource()==reset){ //判斷觸發(fā)器源是否是提交按鈕
nameText.setText(""); //設(shè)置文本框中的內(nèi)容
passText.setText(""); //設(shè)置文本框中的內(nèi)容
infoLab.setText("服務(wù)器登陸系統(tǒng)"); //恢復(fù)標(biāo)簽顯示
}
}
});
frame.addWindowListener(new WindowAdapter(){//加入窗口監(jiān)聽(tīng)
public void windowClosing(WindowEvent e){ }
}); // 加入事件
frame.setLayout(null); //使用絕對(duì)定位
nameLab.setBounds(5,5,60,20); //設(shè)置標(biāo)簽的位置及大小
passLab.setBounds(5,30,60,20); //設(shè)置標(biāo)簽的位置及大小
infoLab.setBounds(5,65,220,30); //設(shè)置標(biāo)簽的位置及大小
nameText.setBounds(65,5,100,20); //設(shè)置文本域的位置及大小
passText.setBounds(65,30,100,20); //設(shè)置密碼域的位置及大小
submit.setBounds(165,5,60,20); //設(shè)置按鈕的位置及大小
reset.setBounds(165,30,60,20); //設(shè)置按鈕的位置及大小
frame.add(nameLab); //向窗體加入標(biāo)簽
frame.add(passLab); //向窗體加入標(biāo)簽
frame.add(infoLab); //向窗體加入標(biāo)簽
frame.add(nameText); //向窗體加入文本框
frame.add(passText); //向窗體加入密碼框
frame.add(submit); //向窗體加入按鈕
frame.add(reset) ;//向窗體加入按鈕
frame.setSize(280,130); //設(shè)置窗體大小
frame.getContentPane().setBackground(Color.green) ;//設(shè)置窗體的背景顏色
frame.setLocation(300,200) ;//設(shè)置窗體在電腦桌面上的位置
frame.setVisible(true); //顯示窗口
while(f==false){ //當(dāng)?shù)卿浭r(shí),一直循環(huán)運(yùn)行,
}
new MyServer();//顯示窗體頁(yè)面
}
}
驗(yàn)證登陸實(shí)現(xiàn)類(lèi) class LoginCheck
package com.server;
public class LoginCheck {
private String name ;//用戶(hù)名
private String password ;//密碼
//構(gòu)造方法
public LoginCheck(String name,String password){
this.name = name ;//傳遞用戶(hù)名
this.password = password ;//傳遞密碼
}
//驗(yàn)證用戶(hù)名和密碼
public boolean validate(){
//驗(yàn)證方法
if("y".equals(name)"1".equals(password)){ //判斷用戶(hù)名和密碼是否正確
return true; //返回true
}else{
return false ;//返回false
}
}
}
package com.server;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.DateFormat;
import java.util.Date;
import javax.swing.*;
聊天實(shí)現(xiàn)類(lèi) class MyServer
public class MyServer {
protected JLabel lab10;
// 全體變量,做傳遞的一個(gè)組件
String s = "已經(jīng)成功連接";
// 初始字符串,在兩個(gè)聊天窗口鏈接成功時(shí)輸出,同時(shí)作為兩個(gè)窗口傳遞字符的一個(gè)變量
// 構(gòu)造方法
public MyServer(){
try{//異常處理
JFrame frame=new JFrame("服務(wù)器窗口");
//設(shè)置窗體
frame.setLayout(null);
//讓布局管理器為空,使用絕對(duì)定位
Font fnt=new Font("Serief",Font.PLAIN,40);//字體設(shè)置
Font fnt1=new Font("Serief",Font.PLAIN,20);//字體設(shè)置
//我的用戶(hù)名顯示
JLabel lab1=new JLabel("服務(wù)器名:",JLabel.LEFT);
//標(biāo)簽實(shí)例化,文本左對(duì)齊
lab1.setBounds(8, 10, 100, 20);
//設(shè)置組件位置及大小
frame.add(lab1);
//添加組件
JTextField text2=new JTextField(30); //單行文本輸入組件
text2.setBounds(150, 10, 200, 20);//設(shè)置組件位置及大小
text2.setEnabled(false);//文本條不可編輯
text2.setText("笑笑聊天室");//輸入內(nèi)容
text2.setFont(fnt1);//設(shè)置字體
frame.add(text2);//添加組件
//服務(wù)器IP顯示
JLabel lab2=new JLabel("當(dāng)前服務(wù)器IP:",JLabel.LEFT);
//標(biāo)簽實(shí)例化,文本左對(duì)齊
lab2.setBounds(8, 45, 100, 20);//設(shè)置組件位置及大小
frame.add(lab2);//添加組件
JTextField text3=new JTextField(30);//單行文本輸入組件
text3.setBounds(150, 45, 200, 20);//設(shè)置組件位置及大小
text3.setEnabled(false);
//文本不可編輯
text3.setText("127.0.0.1");//輸入內(nèi)容
text3.setFont(fnt1);//設(shè)置字體
frame.add(text3);
//添加組件
//服務(wù)器端口顯示
JLabel lab3=new JLabel("當(dāng)前服務(wù)器端口:",JLabel.LEFT);
//標(biāo)簽實(shí)例化,文本左對(duì)齊
lab3.setBounds(8, 80, 100, 20);//設(shè)置組件位置及大小
frame.add(lab3);//添加組件
JTextField text4=new JTextField(30);//單行文本輸入組件
text4.setBounds(150, 80, 200, 20);//設(shè)置組件位置及大小
text4.setEnabled(false);//文本不可編輯
text4.setText("8888");//輸入內(nèi)容
text4.setFont(fnt1);//設(shè)置字體
frame.add(text4);//添加組件
//聊天記錄顯示
JLabel lab4=new JLabel("聊天記錄如下:",JLabel.LEFT);
//標(biāo)簽實(shí)例化 文本左對(duì)齊
lab4.setBounds(8, 115, 100, 20);//設(shè)置組件位置及大小
frame.add(lab4);//添加組件
final JTextArea text1=new JTextArea();//多行文本輸入組件
text1.setEnabled(false);//文本不可編輯
text1.setLineWrap(true);//自動(dòng)換行
JScrollPane scr=new JScrollPane(text1,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS); //設(shè)置滾動(dòng)條,水平和垂直滾動(dòng)條始終顯示
scr.setBounds(8, 150, 450, 350);//設(shè)置組件位置及大小
frame.add(scr);//添加組件
//聊天輸入窗口及確定
JLabel lab5=new JLabel("請(qǐng)輸入聊天內(nèi)容:",JLabel.LEFT); //標(biāo)簽實(shí)例化,文本左對(duì)齊
lab5.setBounds(8, 500, 100, 20);//設(shè)置組件位置及大小
frame.add(lab5);//添加組件
final JTextArea text5=new JTextArea();//多行文本輸入組件
text5.setLineWrap(true);//自動(dòng)換行
JScrollPane scr2=new JScrollPane(text5,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS);//設(shè)置滾動(dòng)條,水平和垂直滾動(dòng)條始終顯示
scr2.setBounds(150, 500, 300, 50);//設(shè)置組件位置及大小
frame.add(scr2);//添加組件
final JButton but=new JButton("確定");//設(shè)置確定按鈕
but.setFont(fnt);//添加字體設(shè)置
but.setBounds(480, 500, 200, 50);//設(shè)置組件位置及大小
but.addActionListener(
new ActionListener(){ //采用內(nèi)部匿名類(lèi)
public void actionPerformed(ActionEvent e){
if(e.getSource()==but){ //判斷觸發(fā)器源是否是提交按鈕
text1.append("笑笑: "+lab10.getText()+"\n ");//在聊天記錄上添加文本
text1.append(text5.getText()+"\n"); //將輸入的聊天內(nèi)容輸出在聊天記錄上
s=text5.getText(); //得到聊天內(nèi)容
text5.setText(""); // 將聊天窗口內(nèi)容設(shè)置為空
}
}
});
frame.add(but);//添加組件
//當(dāng)前時(shí)間顯示
JLabel lab7=new JLabel("時(shí)間顯示:",JLabel.LEFT);//標(biāo)簽實(shí)例化,文本左對(duì)齊
lab7.setBounds(450, 20, 100, 20);//設(shè)置組件位置及大小
frame.add(lab7);//添加組件
DateFormat df=DateFormat.getDateTimeInstance();//取得系統(tǒng)時(shí)間
String df2= df.format(new Date()); //將時(shí)間轉(zhuǎn)換成字符串
JLabel lab8=new JLabel(df2,JLabel.LEFT);//標(biāo)簽實(shí)例化,文本左對(duì)齊
lab8.setBounds(520, 20, 130, 20);//設(shè)置組件位置及大小
frame.add(lab8);//添加組件
lab10=lab8; //傳遞時(shí)間顯示,以便能在聊天記錄上顯示記錄時(shí)間
new Time(lab8); //使時(shí)間動(dòng)態(tài)顯示
//用戶(hù)列表顯示
JLabel lab6=new JLabel("用戶(hù)列表:",JLabel.LEFT);//標(biāo)簽實(shí)例化,文本左對(duì)齊
lab6.setBounds(500, 40, 100, 20);//設(shè)置組件位置及大小
frame.add(lab6);//添加組件
JTextArea text6=new JTextArea();//標(biāo)簽實(shí)例化,文本左對(duì)齊
text6.setEnabled(false);//文本不可編輯
text6.setLineWrap(true);//自動(dòng)換行
JScrollPane scr3=new JScrollPane(text6,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS);//設(shè)置滾動(dòng)條,水平和垂直滾動(dòng)條始終顯示
scr3.setBounds(460, 70, 220, 420);//設(shè)置組件位置及大小
frame.add(scr3);//添加組件
//窗口的屬性
frame.setSize(700,600);//窗口大小
frame.getContentPane().setBackground(Color.pink);//窗口的背景顏色
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);//關(guān)閉窗口時(shí)關(guān)閉程序
frame.setLocation(100,50);//在電腦桌面上出現(xiàn)的位置
frame.setVisible(true);//顯示窗口
//連個(gè)窗口連接
//建立Server Socket并等待連接請(qǐng)求
ServerSocket server =new ServerSocket(8889);
Socket socket=server.accept();
//連接建立，通過(guò)Socket獲取連接上的輸入/輸出流
BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
final PrintWriter out =new PrintWriter(socket.getOutputStream());
//先讀取Client發(fā)送的數(shù)據(jù)，然后從標(biāo)準(zhǔn)輸入讀取數(shù)據(jù)發(fā)送給Client當(dāng)接收到bye時(shí)關(guān)閉連接
String s1="",s2="";
//標(biāo)志字符串,作為傳遞字符串使用
//得到其他窗口傳遞的字符串,并判斷是否結(jié)束
while(!(s1=in.readLine()).equals("bye")){
text6.setText("可可在線"); //當(dāng)連接成功是在用戶(hù)列表中 輸出用戶(hù)名字
if(!s1.equals("")){ //如果傳遞的字符串不為 空
text1.append("可可: "+lab10.getText()+"\n ");//在聊天記錄上添加文本
text1.append(s1+"\n"); //將輸入的聊天內(nèi)容輸出在聊天記錄上
}
s2=s;//將在聊天窗口中得到的字符串傳遞給輸出字符串
for(;s2.equals("")||s2.equals(null);s2=s){//當(dāng)傳遞的字符串為空時(shí)等待用戶(hù)輸入聊天內(nèi)容
}
s="";//將在聊天窗口中得到的字符串設(shè)為空
if(!s2.equals("")!s2.equals(null)){// s2不為空時(shí)做
out.println(s2); //向其他窗口輸出字符串
}
out.flush();//輸出聊天內(nèi)容
}
//關(guān)閉連接
in.close();
out.close();
socket.close();
server.close();
}catch(Exception e){
}
}
//main函數(shù)
public static void main(String args[]){
new Login();//登錄實(shí)現(xiàn) } }
}
}
時(shí)間類(lèi) class Time
package com.server;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.text.SimpleDateFormat;
import java.util.Date;
import javax.swing.JLabel;
import javax.swing.Timer; //時(shí)間類(lèi)
public class Time {
public Time(JLabel time){
//構(gòu)造方法 this.setTimer(time);
//設(shè)置時(shí)間
}
public void setTimer(JLabel time){
//設(shè)置時(shí)間方法
final JLabel varTime = time;
//傳遞組件
Timer timeAction = new Timer(1000, new ActionListener() {
//時(shí)間監(jiān)聽(tīng)
public void actionPerformed(ActionEvent e) {
long timemillis = System.currentTimeMillis();//得到系統(tǒng)時(shí)間
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//轉(zhuǎn)換日期顯示格式
varTime.setText(df.format(new Date(timemillis)));//輸出得到的時(shí)間
}
});
timeAction.start(); //開(kāi)啟線程
}
}
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import java.net.*;
import java.io.*;
public class ClientDemo01 {
public static void main(String[] args){
JFrame f=new JFrame("AA");
JPanel p1=new JPanel();
JPanel p2=new JPanel();
JTextArea ta=new JTextArea(15,30);
ta.setEditable(false); //文本域只讀
JScrollPane sp=new JScrollPane(ta); //滾動(dòng)窗格
JTextField tf=new JTextField(20);
JButton b=new JButton("發(fā)送");
p1.add(sp);
p2.add(tf);
p2.add(b);
f.add(p1,"Center");
f.add(p2,"South");
f.setBounds(300,300,360,300);
f.setVisible(true);
f.setResizable(false);
f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
Socket socket=null;
BufferedInputStream bis=null;
BufferedOutputStream bos=null;
try{
socket=new Socket("192.168.0.4",5000);
bis=new BufferedInputStream(socket.getInputStream());
bos=new BufferedOutputStream(socket.getOutputStream());
MyThread01 mt=new MyThread01(bis,ta);
mt.start();
}catch(Exception e){
e.printStackTrace();
}
b.addActionListener(new ButtonActionListener01(tf,ta,bos));
}
}
class ButtonActionListener01 implements ActionListener{
JTextField tf;
JTextArea ta;
BufferedOutputStream bos;
public ButtonActionListener01(JTextField tf,JTextArea ta,BufferedOutputStream bos){
this.tf=tf;
this.ta=ta;
this.bos=bos;
}
public void actionPerformed(ActionEvent e){
String message=tf.getText();
if(!message.equals("")){
tf.setText(""); //清空文本框
ta.append("AA:"+message+"\n"); //添加到文本域并換行
try{
bos.write(message.getBytes());
bos.flush();
}catch(Exception ex){
System.out.println("發(fā)送失敗");
}
}
}
}
class MyThread01 extends Thread{
BufferedInputStream bis;
JTextArea ta;
public MyThread01(BufferedInputStream bis,JTextArea ta){
this.bis=bis;
this.ta=ta;
}
public void run(){
try{
while(true){
byte[] b=new byte[100];
int length=bis.read(b);
String message=new String(b,0,length);
ta.append("BB:"+message+"\n");
}
}catch(Exception e){
e.printStackTrace();
}
}
} import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import java.net.*;
import java.io.*;
public class ServerDemo01{
public static void main(String[] args){
JFrame f=new JFrame("BB");
JPanel p1=new JPanel();
JPanel p2=new JPanel();
JTextArea ta=new JTextArea(12,30); //文本域，第一個(gè)參數(shù)為行數(shù)，第二個(gè)參數(shù)為列數(shù)
ta.setEditable(false); //文本域只讀
JScrollPane sp=new JScrollPane(ta); //滾動(dòng)窗格
JTextField tf=new JTextField(20);
JButton b=new JButton("發(fā)送");
p1.add(sp);
p2.add(tf);
p2.add(b);
f.add(p1,"Center");
f.add(p2,"South");
f.setBounds(300,300,360,300);
f.setVisible(true);
f.setResizable(false);
f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
ServerSocket server=null;
Socket socket=null;
BufferedInputStream bis=null;
BufferedOutputStream bos=null;
try{
server=new ServerSocket(5000);
//ta.append("等待AA連接...\n");
socket=server.accept();
//ta.append("AA已連接\n");
bis=new BufferedInputStream(socket.getInputStream());
bos=new BufferedOutputStream(socket.getOutputStream());
MyThread1 mt=new MyThread1(bis,ta);
mt.start();
}catch(Exception e){
e.printStackTrace();
}
b.addActionListener(new ButtonActionListener1(tf,ta,bos));
}
}
class ButtonActionListener1 implements ActionListener{
JTextField tf;
JTextArea ta;
BufferedOutputStream bos;
public ButtonActionListener1(JTextField tf,JTextArea ta,BufferedOutputStream bos){
this.tf=tf;
this.ta=ta;
this.bos=bos;
}
public void actionPerformed(ActionEvent e){
String message=tf.getText(); //獲取文本框中的內(nèi)容
if(!message.equals("")){
tf.setText(""); //清空文本框
ta.append("BB:"+message+"\n"); //添加到文本域并換行
try{
bos.write(message.getBytes());
bos.flush();
}catch(Exception ex){
System.out.println("發(fā)送失??！");
}
}
}
}
class MyThread1 extends Thread{
BufferedInputStream bis;
JTextArea ta;
public MyThread1(BufferedInputStream bis,JTextArea ta){
this.bis=bis;
this.ta=ta;
}
public void run(){
try{
while(true){
byte[] b=new byte[100];
int length=bis.read(b);
String message=new String(b,0,length);
ta.append("AA:"+message+"\n");
}
}catch(Exception e){
e.printStackTrace();
}
}
}
重慶分公司
重慶分公司
