java實(shí)現(xiàn)簡(jiǎn)單聊天軟件

更新時(shí)間：2018年07月23日 10:14:39 作者：如果當(dāng)初早知道

這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)簡(jiǎn)單的聊天軟件，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

本文為大家分享了java實(shí)現(xiàn)簡(jiǎn)單聊天軟件的具體代碼，供大家參考，具體內(nèi)容如下

介紹

這是我自己學(xué)習(xí)Socket時(shí)寫(xiě)的，用到了多線(xiàn)程，Socket的知識(shí)，還有Java的IO技術(shù)，并且做了一個(gè)Java的UI，廢話(huà)不多說(shuō)，先上效果圖

SendThread

這個(gè)類(lèi)是用來(lái)實(shí)現(xiàn)數(shù)據(jù)的發(fā)送的，當(dāng)按鍵按下時(shí)，會(huì)調(diào)用sendMessage方法

public class SendThread {

 ChatWindow chatWindow;
 private String remoteIP = "";
 private int port = 0;
 private String message = "";

 public SendThread(int port,ChatWindow window) {
  chatWindow = window;
 }

 public void notRun() {
  InetSocketAddress isa = new InetSocketAddress(remoteIP, port);
  try {
   Socket socket = new Socket();
   socket.connect(isa);
   OutputStreamWriter writer = new OutputStreamWriter(socket.getOutputStream());
   writer.write(message);
   writer.flush();
   writer.close();
   System.out.println("將數(shù)據(jù)寫(xiě)入到流中");
  } catch (IOException e) {
   e.printStackTrace();
  }finally{
   message = "";
  }
 }

 public void senMessage(String host,int port,String message){
  remoteIP = host;
  this.port = port;
  this.message = message;
  notRun();
 }

}

ReceiveThread

這個(gè)類(lèi)實(shí)現(xiàn)的功能是維護(hù)一個(gè)阻塞線(xiàn)程，來(lái)對(duì)端口進(jìn)行監(jiān)聽(tīng)，接受收到的信息，每當(dāng)收到信息時(shí)，都會(huì)顯示。

public class ReceiveThread extends Thread {

 private ServerSocket server;
 private ChatWindow window;

 public ReceiveThread(ChatWindow window) {
  this.window = window;
  try {
   server = new ServerSocket(0);
   window.setLocalPort(server.getLocalPort());
   start();
  } catch (IOException e) {
   // TODO Auto-generated catch block
   window.printError("連接出錯(cuò)");
  }
 }

 @Override
 public void run() {
  // TODO Auto-generated method stub
  while(true){
   Socket socket;
   try {
    socket = server.accept();
    InputStreamReader reader = new InputStreamReader(socket.getInputStream());
    int c;
    StringBuilder sb = new StringBuilder();
    while((c = reader.read()) != -1){
     sb.append((char)c);
    }
    window.setReceive(sb.toString());
   } catch (IOException e) {
    // TODO Auto-generated catch block
    System.out.println("線(xiàn)程將接受到的數(shù)據(jù)寫(xiě)入對(duì)話(huà)框出錯(cuò)");
   }
  }
 }
}

ChatWindow

這個(gè)類(lèi)是UI的實(shí)現(xiàn)，通過(guò)綁定各個(gè)按鈕的操作來(lái)實(shí)現(xiàn)別的功能

public class ChatWindow extends JFrame {

 private JButton sendButton;
 private JButton cancelButton;
 private JButton receiveButton;
 private JTextArea receiveText;
 private JTextField sendText;

 private JLabel localPort;

 private JTextField remoteAddress;
 private JTextField remotePort;
 private SendThread sendThread;
 private ReceiveThread receiveThread;

 private void GUIini(){
  Container c = this.getContentPane();
  c.setLayout(new BorderLayout());
  setSize(400, 500);

  //第一個(gè)panel
  JPanel panel1 = new JPanel(new GridLayout(4, 2));
//  JPanel panel1 = new JPanel(new (4, 2));
  panel1.setSize(400, 75);
  panel1.add(new JLabel("當(dāng)前機(jī)器的IP地址是:"));
  try {
   panel1.add(new JLabel(InetAddress.getLocalHost().getHostAddress()));
  } catch (UnknownHostException e) {
   // TODO Auto-generated catch block
   panel1.add(new JLabel("當(dāng)前機(jī)器的IP地址是:" + "Unknown"));
  }
  panel1.add(new JLabel("當(dāng)前對(duì)話(huà)的端口是:"));
  panel1.add(localPort = new JLabel(""+0));
  panel1.add(new JLabel("Remote Host IP Address:"));
  remoteAddress = new JTextField();
  remoteAddress.setColumns(0);
  panel1.add(remoteAddress);
  panel1.add(new JLabel("Remote Host Port:"));
  remotePort = new JTextField();
  remotePort.setColumns(0);
  panel1.add(remotePort);
  c.add(panel1,BorderLayout.NORTH);


  //第二個(gè)panel
  JPanel panel2 = new JPanel(new FlowLayout(FlowLayout.LEADING));
  panel2.setSize(400,200);
  panel2.add(new JLabel("收到的內(nèi)容"));
  receiveText = new JTextArea(15,30);
  receiveText.setEditable(false);
  receiveText.setAutoscrolls(true);
  JScrollPane jsp = new JScrollPane(receiveText);
  panel2.add(jsp);
  //第三個(gè)panel
//  JPanel panel3 = new JPanel(new GridLayout(2, 1));
  panel2.add(new JLabel("請(qǐng)輸入發(fā)送的內(nèi)容"));
  sendText = new JTextField(30);
  sendText.setAutoscrolls(true);
  panel2.add(sendText);
  c.add(panel2,BorderLayout.CENTER);
  //c.add(panel3);
  //第四個(gè)panel
  JPanel panel4 = new JPanel(new GridLayout(1, 0));
  panel4.setSize(400,20);
  receiveButton = new JButton("開(kāi)始接受數(shù)據(jù)");
  sendButton = new JButton("發(fā)送");
  cancelButton = new JButton("取消");
  panel4.add(receiveButton);
  panel4.add(cancelButton);
  panel4.add(sendButton);
  c.add(panel4,BorderLayout.SOUTH);
  //四個(gè)面板內(nèi)容設(shè)置完畢

  setVisible(true);
  setResizable(false);
  setDefaultCloseOperation(EXIT_ON_CLOSE);
 }

 private void ActionIni() {

  //鍵盤(pán)動(dòng)作
  this.addKeyListener(new KeyListener() {

   @Override
   public void keyTyped(KeyEvent e) {

   }

   @Override
   public void keyReleased(KeyEvent e) {
    // TODO Auto-generated method stub
    if(e.getKeyCode() == KeyEvent.VK_ENTER){
     //發(fā)送文本
     sendThread.senMessage(remoteAddress.getText(), Integer.parseInt(remotePort.getText()), sendText.getText());
     receiveText.setText(receiveText.getText() + "\n" + "發(fā)送:" + sendText.getText());
    }
   }

   @Override
   public void keyPressed(KeyEvent e) {
    // TODO Auto-generated method stub

   }
  });
  //取消按鈕的動(dòng)作
  cancelButton.addMouseListener(new MouseListener() {

   @Override
   public void mouseReleased(MouseEvent e) {
    // TODO Auto-generated method stub
    sendText.setText("");
   }

   @Override
   public void mousePressed(MouseEvent e) {
    // TODO Auto-generated method stub

   }

   @Override
   public void mouseExited(MouseEvent e) {
    // TODO Auto-generated method stub

   }

   @Override
   public void mouseEntered(MouseEvent e) {
    // TODO Auto-generated method stub

   }

   @Override
   public void mouseClicked(MouseEvent e) {
    // TODO Auto-generated method stub

   }
  });
  sendButton.addMouseListener(new MouseListener() {

   @Override
   public void mouseReleased(MouseEvent e) {
    //發(fā)送文本
    sendThread.senMessage(remoteAddress.getText(), Integer.parseInt(remotePort.getText()), sendText.getText());
    receiveText.setText(receiveText.getText() + "發(fā)送:" + sendText.getText()+ "\n");
   }

   @Override
   public void mousePressed(MouseEvent e) {
    // TODO Auto-generated method stub

   }

   @Override
   public void mouseExited(MouseEvent e) {
    // TODO Auto-generated method stub

   }

   @Override
   public void mouseEntered(MouseEvent e) {
    // TODO Auto-generated method stub

   }

   @Override
   public void mouseClicked(MouseEvent e) {
    // TODO Auto-generated method stub

   }
  });
 }

 private void ThreadIni() {
  // TODO Auto-generated method stub
  sendThread = new SendThread(0, this);
  receiveThread = new ReceiveThread(this);
 }
 //構(gòu)造函數(shù)
 public ChatWindow() {
  GUIini();
  ActionIni();
  ThreadIni();
 }

 public void printError(String err){
  System.out.println("Error occur:" + err);
 }

 //回調(diào)函數(shù),用于接受從線(xiàn)程中返回的數(shù)據(jù)
 public void setReceive(String receive){
  receiveText.setText(receiveText.getText() + "收到:" + receive+ "\n" );
 }

 //當(dāng)接受數(shù)據(jù)的線(xiàn)程開(kāi)始工作以后，就調(diào)用該回調(diào)函數(shù)，設(shè)置當(dāng)前聊天窗口使用的端口是哪個(gè)
 public void setLocalPort(int localPortText){
  localPort.setText(""+localPortText);
 }

 //放遠(yuǎn)，這個(gè)是整個(gè)程序的起點(diǎn)
 public static void main(String[] args) {
  // TODO Auto-generated method stub
  new ChatWindow();
 }

}

如何使用

將工程導(dǎo)入到Eclipse中以后，運(yùn)行兩次，因?yàn)檫@個(gè)程序不屬于單例模式，所以可以出現(xiàn)兩個(gè)窗口，在遠(yuǎn)程端口，遠(yuǎn)程地址那個(gè)輸入框中分別輸入另一個(gè)窗口中顯示的IP和端口號(hào)，接下來(lái)在輸入框中輸入要發(fā)送的文字就可以了

源碼下載：java實(shí)現(xiàn)簡(jiǎn)單聊天軟件

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: