?? frame1.java~1~
字號:
package chatserver;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import com.borland.jbcl.layout.*;
import java.net.*;//需要增加的包
import java.io.*;
import java.util.Vector;
import java.util.StringTokenizer;
/**
* <p>Title: </p>
* <p>Description: </p>
* <p>Copyright: Copyright (c) 2003</p>
* <p>Company: </p>
* @author not attributable
* @version 1.0
*/
public class Frame1 extends JFrame {
JPanel contentPane;
JPanel jPanel1 = new JPanel();
JPanel jPanel2 = new JPanel();
XYLayout xYLayout1 = new XYLayout();
BorderLayout borderLayout1 = new BorderLayout();
BorderLayout borderLayout2 = new BorderLayout();
JPanel jPanel3 = new JPanel();
JLabel jLabel1 = new JLabel();
JLabel jLabel2 = new JLabel();
JLabel jLabel3 = new JLabel();
PaneLayout paneLayout1 = new PaneLayout();
JPanel jPanel4 = new JPanel();
JLabel jLabel4 = new JLabel();
JLabel jLabel5 = new JLabel();
JLabel jLabel6 = new JLabel();
PaneLayout paneLayout2 = new PaneLayout();
JScrollPane jScrollPane1 = new JScrollPane();
JScrollPane jScrollPane2 = new JScrollPane();
JTextArea jTextArea2 = new JTextArea();
JPanel jPanel5 = new JPanel();
JTextField jTextField1 = new JTextField();
PaneLayout paneLayout3 = new PaneLayout();
JButton send = new JButton();
JButton sysexit = new JButton();
JTextField jTextField2 = new JTextField();
//定義相關變量
ServerSocket serverSocket=null;//建立服務器的socket
Socket socket=null; //用來存儲一個連接套接字
BufferedReader cin=null;//用來實現接受從客戶端發來的數據流
PrintWriter cout=null;//用來實現向客戶端發送信息的流
static Vector clients=new Vector(20); //用vector向量數組存儲連接客戶變量
static int active_connects=0;//記錄目前連接的客戶數
java.awt.List list1 = new java.awt.List();
JButton link = new JButton();//用來列出目前連接的客戶數
//Construct the frame
public Frame1() {
enableEvents(AWTEvent.WINDOW_EVENT_MASK);
try {
jbInit();
run();
}
catch(Exception e) {
e.printStackTrace();
}
}
//Component initialization
private void jbInit() throws Exception {
contentPane = (JPanel) this.getContentPane();
contentPane.setLayout(xYLayout1);
this.setLocale(java.util.Locale.getDefault());
this.setSize(new Dimension(407, 379));
this.setTitle("網絡聊天服務器");
jPanel1.setLayout(borderLayout1);
jPanel2.setLayout(borderLayout2);
jLabel1.setBorder(BorderFactory.createEtchedBorder());
jLabel1.setText("用戶名");
jLabel2.setBorder(BorderFactory.createEtchedBorder());
jLabel2.setText("IP地址");
jLabel3.setBorder(BorderFactory.createEtchedBorder());
jLabel3.setToolTipText("");
jLabel3.setText("連接情況");
jPanel3.setLayout(paneLayout1);
jLabel4.setBorder(BorderFactory.createEtchedBorder());
jLabel4.setText("信息類型");
jLabel5.setBorder(BorderFactory.createEtchedBorder());
jLabel5.setText("信息來源");
jLabel6.setBorder(BorderFactory.createEtchedBorder());
jLabel6.setText("信息內容");
jPanel4.setLayout(paneLayout2);
jTextField1.setEditable(false);
jTextField1.setText("");
jPanel5.setLayout(paneLayout3);
send.setText("發送");
send.addActionListener(new Frame1_send_actionAdapter(this));
sysexit.setText("退出");
sysexit.addActionListener(new Frame1_sysexit_actionAdapter(this));
jTextArea2.setText("");
link.setText("連接");
link.addActionListener(new Frame1_link_actionAdapter(this));
contentPane.add(jPanel1, new XYConstraints(-2, 0, 402, 152));
jPanel1.add(jPanel3, BorderLayout.NORTH);
jPanel1.add(jScrollPane1, BorderLayout.CENTER);
jScrollPane1.getViewport().add(list1, null);
contentPane.add(jPanel2, new XYConstraints(-1, 160, 401, 140));
jPanel2.add(jPanel4, BorderLayout.NORTH);
jPanel4.add(jLabel4, new PaneConstraints("jLabel4", "jLabel4", PaneConstraints.ROOT, 0.5f));
jPanel4.add(jLabel5, new PaneConstraints("jLabel5", "jLabel4", PaneConstraints.RIGHT, 0.7431421f));
jPanel4.add(jLabel6, new PaneConstraints("jLabel6", "jLabel5", PaneConstraints.RIGHT, 0.63758385f));
jPanel2.add(jScrollPane2, BorderLayout.CENTER);
jPanel2.add(jPanel5, BorderLayout.SOUTH);
contentPane.add(jTextField2, new XYConstraints(1, 295, 306, 31));
contentPane.add(jTextField1, new XYConstraints(2, 329, 242, -1));
contentPane.add(send, new XYConstraints(328, 301, 60, 22));
contentPane.add(sysexit, new XYConstraints(329, 329, 60, 22));
contentPane.add(link, new XYConstraints(261, 330, 56, 22));
jScrollPane2.getViewport().add(jTextArea2, null);
jPanel3.add(jLabel1, new PaneConstraints("jLabel1", "jLabel1", PaneConstraints.ROOT, 0.5f));
jPanel3.add(jLabel2, new PaneConstraints("jLabel2", "jLabel1", PaneConstraints.RIGHT, 0.75124377f));
jPanel3.add(jLabel3, new PaneConstraints("jLabel3", "jLabel2", PaneConstraints.RIGHT, 0.5532646f));
}
//File | Exit action performed
public void jMenuItemClear_actionPerformed(ActionEvent e) {
System.exit(0);
}
//Help | About action performed
//Overridden so we can exit when window is closed
protected void processWindowEvent(WindowEvent e) {
super.processWindowEvent(e);
if (e.getID() == WindowEvent.WINDOW_CLOSING) {
jMenuItemClear_actionPerformed(null);
}
}
public void run() {
} //end of run
public static void notifyRoom(){//監視聊天窗口的連接變化,不
//斷刷新clients數組并刷新用戶列表信息
StringBuffer people=new StringBuffer("PEOPLE");
for(int i=0;i<clients.size();i++)
{
Client c=(Client)clients.elementAt(i);
people.append(":"+c.name+":"+c.ip);
}
sendClients(people);
}
public static boolean checkName(Client newClient)
{
for(int i=0;i<clients.size();i++)
{
Client c=(Client)clients.elementAt(i);
if((c!=newClient)&&c.equals(newClient.name))
return false;
}
return true;
}
public synchronized void disconnect(Client c)//缺少static
{
try{
int k=0;
jTextArea2.append("系統消息： "+c.name+" "+c.ip+" 斷開連接");
active_connects--; //連接數減1
jTextField1.setText("目前已經有"+active_connects+"用戶連接");
c.send(new StringBuffer("QUIT"+":"+c.name+":"+c.ip));
//向客戶發送斷開信息
c.socket.close();//斷開連接
}
catch(IOException e)
{
jTextArea2.append("系統消息："+"Error "+e);
}
finally{
clients.removeElement(c);
}
}
public static synchronized void sendClients(StringBuffer msg)
{
for(int i=0;i<clients.size();i++){
Client c=(Client)clients.elementAt(i);
c.send(msg);
}
}
public void sendtoClient(StringBuffer msg,String name) //將信息發送到單個用戶
{
for(int i=0;i<clients.size();i++)
{
Client c=(Client)clients.elementAt(i);
if(c.name==name)
{
c.ps.println(msg);
c.ps.flush();
break;
}
else i++;
}
}
public void closeAll()//缺少static
{
while(clients.size()>0)
{
Client c=(Client)clients.firstElement();
try{
c.socket.close();
}
catch(IOException e){
jTextArea2.append("系統消息："+" 聊天服務器"+ " Error "+e);
}
finally{
clients.removeElement(c);//從clients數組中刪除客戶相關的socket信息
}
}
}
private class Client extends Thread{
String name; //用來存儲客戶的連接姓名
String ip; //用來存儲客戶的連接IP
DataInputStream dis; //用于實現接受從客戶端發送來的數據流
PrintStream ps; //用來實現向客戶端發送信息的打印流
Socket socket;
public Client(Socket s) //Client 線程的構造器
{
socket=s;
try{
dis=new DataInputStream(s.getInputStream()); //存儲特定客戶socket的輸入流，
//接受s客戶發送到服務器端的信息
ps=new PrintStream(s.getOutputStream()); //存儲特定客戶socket的輸出流，
//發送服務器給s客戶的信息
String info=dis.readLine(); //讀取接受來的信息
StringTokenizer stinfo=new StringTokenizer(info,":"); //讀取用"："分開的分段字符
String head=stinfo.nextToken(); //用head存儲關鍵字的頭信息
if(stinfo.hasMoreTokens())
name=stinfo.nextToken(); //關鍵字的第二個數據段是客戶的名稱
if(stinfo.hasMoreTokens())
ip=stinfo.nextToken(); //關鍵字的第三個數據段是客戶的IP地址
// jTextArea2.append(head);
}
catch(IOException e){
jTextArea2.append("系統消息："+" 聊天服務器"+"Error "+e);
}
}
public void send(StringBuffer msg) //實現向客戶端發送信息的方法
{
ps.println(msg); //用打印流發送信息
ps.flush();
}
public void run(){ //線程的運行方法
while(true){
String line=null;
try{
line=dis.readLine(); //讀取客戶端發送的數據流
}
catch(IOException e)
{
jTextArea2.append("系統消息："+" 聊天服務器"+" Error： "+e);
disconnect(this);
notifyRoom();
return ;
}
if(line==null) //客戶已經離開
{
disconnect(this);
notifyRoom();
return;
}
StringTokenizer st=new StringTokenizer(line,":");
String keyword=st.nextToken();//存儲關鍵字，判斷消息類型
String broadcast=st.nextToken();//存儲消息是屬于廣播，還是屬于單播
//如果單播，則記錄的是目標用戶名
if(keyword.equalsIgnoreCase("MSG")) //如果關鍵字是MSG，則是客戶端發送的聊天信息
{
StringBuffer message=new StringBuffer("MSG:");//在服務器端建立一個緩沖區，用于信息的發送
message.append(st.nextToken("\0"));
if(broadcast.equalsIgnoreCase("BROAD"))
{
sendClients(message);
}
else
{
sendtoClient(message,broadcast);
}
}
else if(keyword.equalsIgnoreCase("QUIT")) //如果關鍵字是QUIT，則是客戶端發送的退出信息
{
disconnect(this);
notifyRoom();
this.stop();
}
}
}
}
void send_actionPerformed(ActionEvent e) {
StringBuffer info=new StringBuffer("INFO");
info.append(":"+"ALL"+":");
info.append(jTextField2.getText());
sendClients(info);
jTextField2.setText("");
}
void sysexit_actionPerformed(ActionEvent e) {
sendClients(new StringBuffer("QUIT"+":"+"Server"));
closeAll();
System.exit(0);
}
void link_actionPerformed(ActionEvent e) {
//進行服務器的初始化建立
if (serverSocket == null) {
try {
serverSocket = new ServerSocket(4000);
jTextArea2.append("系統提示： 聊天服務器 系統開始啟動......\n");
}
catch (IOException ee) {
jTextArea2.append("系統消息： 聊天服務器 "+ e.toString() + "\n");
}
}
if(serverSocket!=null){
jTextArea2.append("系統消息： 已經連接\n");
watch();
}
}
public void watch(){
while(true){
/*if(clients.size()<20)//當客戶數目小于20的時候開始連接
{*/
try{
socket=serverSocket.accept();//用來存儲連接上的客戶socket
if(socket!=null){
jTextArea2.append("系統消息： "+socket.toString()+" 已經連接\n");
}
}
catch(IOException ee){
jTextArea2.append("系統消息： 聊天服務器 "+ee.toString()+" 用戶連接失敗\n");
}
int i=0;
do{
Client c=new Client(socket);//定義并實例化一個Client線程，每一個線程對應一個客戶連接
if(checkName(c))
{
clients.addElement(c);//加入到clients數組中
active_connects++;//連接數目加1
jTextField1.setText("目前已經有"+active_connects+"用戶連接");//在狀態欄中顯示目前的活動數目
Client listdata=(Client)clients.elementAt(i);
list1.add(listdata.name+" "+listdata.ip+" 連接",i);
c.start(); //啟動線程
notifyRoom(); //監視聊天窗口的連接變化
}
else{
c.ps.println("FaultName");//檢查名字不合法，則在發送流中發送FaultName
disconnect(c); //斷開連接
}
i++;
break;
}
while(i<clients.size());
}
/*else{ //如果超過連接數目
try{
Thread.sleep(200);
}
catch(InterruptedException ee)
{ }
}
} //end of while*/
}
}
class Frame1_send_actionAdapter implements java.awt.event.ActionListener {
Frame1 adaptee;
Frame1_send_actionAdapter(Frame1 adaptee) {
this.adaptee = adaptee;
}
public void actionPerformed(ActionEvent e) {
adaptee.send_actionPerformed(e);
}
}
class Frame1_sysexit_actionAdapter implements java.awt.event.ActionListener {
Frame1 adaptee;
Frame1_sysexit_actionAdapter(Frame1 adaptee) {
this.adaptee = adaptee;
}
public void actionPerformed(ActionEvent e) {
adaptee.sysexit_actionPerformed(e);
}
}
class Frame1_link_actionAdapter implements java.awt.event.ActionListener {
Frame1 adaptee;
Frame1_link_actionAdapter(Frame1 adaptee) {
this.adaptee = adaptee;
}
public void actionPerformed(ActionEvent e) {
adaptee.link_actionPerformed(e);
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -