大学JAVA实验五

2019-11-17 04:05:05

字体：大中小

来源：转载

供稿：网友

指定不同协议的URL地址，获得资源文件的内容和属性

URLStudy.java

package first;

import java.awt.FileDialog;
import java.awt.Font;
import java.awt.TextArea;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PRintWriter;

import javax.swing.ImageIcon;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JTextField;

public class URLStudy extends JFrame {

private static final long serialVersionUID = 1L;
private Font font = new Font("宋体", Font.CENTER_BASELINE, 13);
TextArea textarea = new TextArea();
JButton button[] = new JButton[3];
String buttonName[] = { "确定", "取消", "保存文件" };
JLabel label = new JLabel("请输入URL地址：");
JTextField urlfield = new JTextField(20);

JPanel panel = new JPanel();

URLStudyListener listener = new URLStudyListener(this);

private String file = "";

private FileDialog filesave;

public URLStudy() {

  super.setTitle("资源文件的内容和属性查看器");

  ImageIcon icon = new ImageIcon("195032.jpg");
  setIconImage(icon.getImage());

  textarea.setFont(font);
  label.setFont(font);
  urlfield.setFont(font);

  panel.add(label);
  panel.add(urlfield);

  for (int i = 0; i < buttonName.length; i++) {
   button[i] = new JButton(buttonName[i]);
   button[i].addActionListener(listener);
   button[i].setFont(font);
   panel.add(button[i]);
  }
  super.setDefaultCloSEOperation(EXIT_ON_CLOSE);
  super.add(textarea, "Center");
  super.add(panel, "South");
  super.setLocation(250, 200);
  super.setSize(600, 400);
  super.setVisible(true);
  super.setResizable(true);


  filesave = new FileDialog(this, "保存文件-----XiaoHuanJie", FileDialog.SAVE);
}

public void saveFile() {
  String dangqianwenjian = textarea.getText();
  try {
   if (file.isEmpty()) {
    filesave.setVisible(true);
    String direct = filesave.getDirectory();
    String filename = filesave.getFile();

    if ((direct != null) && (filename != null)) {
     file = direct + filename;
     PrintWriter pw = new PrintWriter(new FileWriter(file));
     pw.println(dangqianwenjian);
     pw.flush();
     pw.close();
    }
   } else {
    PrintWriter pw = new PrintWriter(new FileWriter(file));
    pw.println(dangqianwenjian);
    pw.flush();
    pw.close();
   }
  } catch (IOException e) {
   e.printStackTrace();
  }
}

public static void main(String[] args) {
  new URLStudy();
}
}

URLStudyListener.java

package first;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.URL;

import javax.swing.JOptionPane;

public class URLStudyListener implements ActionListener {
BufferedReader br;
URLStudy urlstudy;

public URLStudyListener(URLStudy urlstudy) {
  this.urlstudy = urlstudy;
}

@Override
public void actionPerformed(ActionEvent ae) {
  String command = ae.getActionCommand();
  if (command.equals("确定")) {
   try {
    URL url = new URL(((urlstudy.urlfield).getText()).trim());
    br = new BufferedReader(new InputStreamReader(url.openStream()));
    while (br.readLine() != null) {
     urlstudy.textarea.append(br.readLine() + "/n");
    }
   } catch (IOException e) {

    JOptionPane.showMessageDialog(null, "您输入的URL地址错误！", "系统提示",
      JOptionPane.ERROR_MESSAGE);

   }
  } else if (command.equals("取消")) {
   (urlstudy.urlfield).setText("");
  } else if (command.equals("保存文件")) {
   urlstudy.saveFile();
  }
}
}

（1）增加上线功能。离线后，将【离线】按钮变成【上线】按钮，单击可再次申请建立连接。
（2）将文本区中对方和己方的字符串以不同的字体区别显示。
（3）发送带格式的字符串。
（4）增加复制功能，将文本区中的若干选中字符串复制到文本行中。
（5）增加若干图标作为表情，发送表情图标。
（6）增加对方信息到达时的语音提示。
（7）将聊天记录存储到文件中。

MyQQServer.java

package second;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.Collection;
import java.util.Date;
import java.util.Hashtable;

public class MyQQServer {

public static void main(String[] args) {
  Hashtable<String, DataOutputStream> userList = new Hashtable<String, DataOutputStream>();
  String name;
  DataInputStream dis;
  DataOutputStream dos;

  try {
   ServerSocket serversocket = new ServerSocket(8088);
   while (true) {
    Socket socket = serversocket.accept();
    dis = new DataInputStream(socket.getInputStream());
    dos = new DataOutputStream(socket.getOutputStream());

    name = dis.readUTF();

    userList.put(name, dos);

    new QQServerReader(name, dis, userList).start();
   }
  } catch (IOException e) {

   e.printStackTrace();
  }
}
}

class QQServerReader extends Thread {

private String name;
private DataInputStream dis;

private Hashtable<String, DataOutputStream> userList;

public QQServerReader(String name, DataInputStream dis,
   Hashtable<String, DataOutputStream> userList) {
  // super();
  this.name = name;
  this.dis = dis;
  this.userList = userList;
}

@Override
public void run() {
  String info;
  Date date1 = new Date();
  SimpleDateFormat sdf1 = new SimpleDateFormat("yy-MM-dd  HH:mm:ss");
  String time = "/t/t" + sdf1.format(date1);

  transmitMessage(name + " 上线 !", "-------系统消息-------" + time);

  while (true) {

   try {

    info = dis.readUTF();
    if (info.equals("^%#$^$jg4653|+=--09-89jh)*")) {// 暗号吻合,该用户退出聊天室
     DataOutputStream dos = (DataOutputStream) userList
       .get(name);

     dos.close();
     dis.close();
     userList.remove(name);
     Date date2 = new Date();
     SimpleDateFormat sdf2 = new SimpleDateFormat(
       "yy-MM-dd  HH:mm:ss");
     time = "/t/t" + sdf2.format(date2);

     transmitMessage(name + " 退出聊天室啦！", "-------系统提示-------"
       + time);
     break;
    } else if (info.equals("L^%#$5@#h(8yh^+_)_)(=78UTh*%@!")) {// 暗号吻合，该用户离线
     //info = "";
     userList.remove(name);
     Date date2 = new Date();
     SimpleDateFormat sdf2 = new SimpleDateFormat(
       "yy-MM-dd  HH:mm:ss");
     time = "/t/t" + sdf2.format(date2);

     transmitMessage(name + " 离线 !", "-------系统提示-------" + time);
     break;
    } else if (info.equals("^&%()&(*85KJ$%@+_9)(80(8()*)(")) {// 暗号吻合，该用户重新上线
     DataOutputStream dos = (DataOutputStream) userList
       .get(name);
     userList.put(name, dos);
    } else if (info.length() > 0) {
     Date date3 = new Date();
     SimpleDateFormat sdf3 = new SimpleDateFormat(
       "yy-MM-dd  HH:mm:ss");
     time = "/t/t" + sdf3.format(date3);

     transmitMessage(info, name + time);
    }
   } catch (IOException e) {
    e.printStackTrace();
   }
  }
}

public void transmitMessage(String msg, String name) {
  Collection<DataOutputStream> doses = userList.values();
  DataOutputStream dos;

  // 把信息发送给所有在线的用户
  for (Object o : doses) {
   dos = (DataOutputStream) o;
   try {
    dos.writeUTF(name + "/n" + msg + "/n");
   } catch (IOException e) {

    e.printStackTrace();
   }
  }
}

}

MyQQClient.java

package second;

import java.awt.Font;
import java.awt.GridLayout;
import java.awt.Panel;
import java.awt.TextArea;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

import javax.swing.ImageIcon;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JOptionPane;

public class MyQQClient {

private String name;
private Socket socket;
private DataInputStream dis;
private DataOutputStream dos;
JFrame frame;
private TextArea oldInfoArea;
private TextArea newInfoArea;
private boolean runnable=true;
private Font font;

private File file;

ImageIcon icon;

JButton button[] = new JButton[4];

public MyQQClient() {

  runnable = true;
  frame = new JFrame("QQ客户端");

  icon = new ImageIcon("195032.jpg");
  frame.setIconImage(icon.getImage());

  oldInfoArea = new TextArea(15, 20);
  oldInfoArea.setEditable(false);
  newInfoArea = new TextArea(8,20);

  font = new Font("宋体", Font.CENTER_BASELINE, 13);
  oldInfoArea.setFont(font);
  newInfoArea.setFont(font);
  MyQQKeyListener keylistener =new MyQQKeyListener(this);

  newInfoArea.addKeyListener(keylistener);

  MyQQClientListener listener = new MyQQClientListener(this);

  String buttonName[] = { "表情", "离线", "聊天记录", "发送" };

  Panel panel = new Panel();
  panel.setLayout(new GridLayout(1, 4));

  for (int i = 0; i < buttonName.length; i++) {
   button[i] = new JButton(buttonName[i]);
   button[i].setFont(font);
   button[i].addActionListener(listener);
   panel.add(button[i]);
  }

  frame.add(this.oldInfoArea, "North");
  frame.add(this.newInfoArea, "Center");
  frame.add(panel, "South");

  frame.addWindowListener(new WindowAdapter() {

   @Override
   public void windowClosing(WindowEvent e) {

    int option = JOptionPane.showConfirmDialog(null, "是否完全退出此次聊天？",
      "系统提示", JOptionPane.YES_NO_OPTION,
      JOptionPane.QUESTION_MESSAGE);
    if (option == JOptionPane.YES_OPTION)
     // System.exit(0);
     MyQQClient.this.shutDown();
   }
  });

  frame.setSize(500, 400);
  frame.setLocation(300, 200);
  frame.setResizable(false);

}

public static void main(String[] args) {
  MyQQClient QQClient = new MyQQClient();
  QQClient.inputName();
  QQClient.connect();
  QQClient.createThread();

}

public void saveFile() {
  String oldInfo = oldInfoArea.getText();
  try {
   PrintWriter pw = new PrintWriter(new FileWriter(file, true));// true,不覆盖已有文件

   pw.println(oldInfo);
   pw.flush();
   pw.close();
  } catch (IOException e) {
   e.printStackTrace();
  }

}

// 检查是否存在目标文件，不存在就新建一个
public void init() {
  if (file == null) {
   file = new File(name + ".employee");
   try {
    file.createNewFile();
   } catch (IOException e) {
    e.printStackTrace();
   }
  }
}

public void xiaXian() {
  try {
   dos.writeUTF("L^%#$5@#h(8yh^+_)_)(=78UTh*%@!");// 暗号，告诉服务器，离线了
   this.runnable=false;
  } catch (IOException e) {
   e.printStackTrace();
  }
}

public void shangXian() {
  try {
   this.runnable=true;
   this.connect();
   dos.writeUTF("^&%()&(*85KJ$%@+_9)(80(8()*)(");// 暗号，告诉服务器，重新上线
  } catch (IOException e) {
   e.printStackTrace();
  }
}

public void shutDown() {
  try {
   dos.writeUTF("^%#$^$jg4653|+=--09-89jh)*");// 暗号，告诉服务器，下线了
   Thread.sleep(500);
   saveFile();// 退出时将聊天记录一次性保存
   this.stop();

   //dis.close();
   dos.close();
   this.socket.close();
  } catch (IOException e) {
   e.printStackTrace();
  } catch (InterruptedException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
  System.exit(0);// 聊天窗口退出
}

public void connect() {
  try {
   socket = new Socket("127.0.0.1", 8088);
  } catch (UnknownHostException e1) {
   System.out.println("连接服务器失败!");
   e1.printStackTrace();
  } catch (IOException e1) {
   e1.printStackTrace();
  }
  try {
   dos = new DataOutputStream(socket.getOutputStream());
   dis = new DataInputStream(socket.getInputStream());
   dos.writeUTF(name);// 将本用户的姓名发送给服务器
  } catch (IOException e) {
   e.printStackTrace();
  }
}

public void createThread() {
  MyQQClientReader reader = new MyQQClientReader(this);
  reader.start();
}

public void inputName() {

  String name = (javax.swing.JOptionPane.showInputDialog("请输入您的昵称："))
    .trim();
  if (name == null || name.equals("")) {// 不接受散客聊天
   JOptionPane.showMessageDialog(null, "昵称不能为空哦，请输入您的昵称！", "系统提示",
     JOptionPane.ERROR_MESSAGE);

   inputName();

  } else {
   this.setName(name);
  }
  init();
  frame.setTitle(name);
  frame.setVisible(true);
}

public void stop() {
  runnable = false;
}

public boolean isRunnable() {
  return runnable;
}

public DataInputStream getDis() {
  return dis;
}

public DataOutputStream getDos() {
  return dos;
}

public TextArea getOldTextArea() {
  return oldInfoArea;
}

public TextArea getNewTextArea() {
  return newInfoArea;
}

public void setName(String name) {
  this.name = name;
}

}

MyQQClientListener.java

package second;

import java.awt.TextArea;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;

//MyQQClientLister监听器
class MyQQClientListener implements ActionListener {
MyQQClient myQQClient;
String command ;

public MyQQClientListener(MyQQClient myQQClient) {
  this.myQQClient = myQQClient;
}

public void actionPerformed(ActionEvent ae) {
  command = ae.getActionCommand();
  if (command.equals("发送")) {

   TextArea textArea = myQQClient.getNewTextArea();
   String info = textArea.getText();

   try {
    myQQClient.getDos().writeUTF(info);
   } catch (IOException e1) {
    e1.printStackTrace();
   }

   textArea.setText("");
   textArea.requestFocus();
  } else if (command.equals("离线")) {
   myQQClient.button[1].setText("上线");
   myQQClient.xiaXian();
  } else if (command.equals("上线")) {
   myQQClient.button[1].setText("离线");
   myQQClient.shangXian();
  }else if(command.equals("聊天记录")){

  }
}
}

MyQQKeyListener.java

package second;

import java.awt.TextArea;
import java.awt.event.KeyEvent;
import java.awt.event.KeyListener;
import java.io.IOException;

public class MyQQKeyListener implements KeyListener {
MyQQClient myQQClient;

MyQQClientListener myQQClientListener;

public MyQQKeyListener(MyQQClientListener myQQClientListener) {
  this.myQQClientListener = myQQClientListener;
}

public MyQQKeyListener(MyQQClient myQQClient) {
  this.myQQClient = myQQClient;
}

@Override
public void keyPressed(KeyEvent ke) {
  if (ke.getKeyCode() == KeyEvent.VK_ENTER && ke.isControlDown()) {
   TextArea textArea = myQQClient.getNewTextArea();
   String info = textArea.getText();

   try {
    myQQClient.getDos().writeUTF(info);
   } catch (IOException e1) {
    e1.printStackTrace();
   }

   textArea.setText("");
   textArea.requestFocus();
  }
}

@Override
public void keyReleased(KeyEvent e) {

}

@Override
public void keyTyped(KeyEvent e) {

}
}

MyQQClientReader.java

package second;

import java.awt.Color;
import java.awt.TextArea;
import java.io.DataInputStream;
import java.io.IOException;

class MyQQClientReader extends Thread {

private MyQQClient myQQClient;

public MyQQClientReader(MyQQClient myQQClient) {
  this.myQQClient = myQQClient;
}

@Override
public void run() {
  String info;

  int a = (int) (Math.random() * 255);
  int b = (int) (Math.random() * 255);
  int c = (int) (Math.random() * 255);

  Color color = new Color(a, b, c);

  DataInputStream dis = myQQClient.getDis();
  TextArea textArea = myQQClient.getOldTextArea();
  textArea.setForeground(color);

  try {
   while (myQQClient.isRunnable()) {

    info = dis.readUTF();
    textArea.append(info + "/n");
   }
  } catch (IOException e) {
    //e.printStackTrace();//有错误
  }
}
}

上一篇：利用Java Servlet实现在Web服务器平台上的开发

下一篇：微软购Teamprise技术为Java与.net开发者搭桥