Java Chat via Socket (mom. nur 2 user)


  • TheDude
  • 1153 Aufrufe 2 Antworten

Diese Seite verwendet Cookies. Durch die Nutzung unserer Seite erklären Sie sich damit einverstanden, dass wir Cookies setzen. Weitere Informationen

  • Java Chat via Socket (mom. nur 2 user)

    Hab einen Chat für 2 User über Sockets gecodet.
    Ist noch eine Ur-Version..aber die reicht um das Prinzip zu verstehen.
    Falls es wer brauchen kann.


    InitClient.java

    Java-Quellcode

    1. package client;
    3. import java.awt.*;
    4. import java.awt.event.*;
    5. import java.net.*;
    7. /**
    8. * <p>Überschrift: </p>
    9. * <p>Beschreibung: </p>
    10. * <p>Copyright: Copyright (c) 2003</p>
    11. * <p>Organisation: </p>
    12. * @author unbekannt
    13. * @version 1.0
    14. */
    16. public class InitClient extends Frame implements ActionListener{
    17. public Label lbl_ip;
    18. public TextField ip1,ip2,ip3,ip4;
    19. public Label lbl_port;
    20. public TextField port;
    21. public Button start;
    23. public InitClient() {
    24. this.setLayout(new FlowLayout());
    26. this.addWindowListener(new WindowAdapter(){
    27. public void windowClosing(WindowEvent e)
    28. {
    29. dispose();
    30. System.exit(0);
    31. }});
    32. lbl_port = new Label("Portnummer:");
    33. port = new TextField(5);
    34. lbl_ip = new Label(" IP-Nummer:");
    35. ip1 = new TextField(3);
    36. ip2 = new TextField(3);
    37. ip3 = new TextField(3);
    38. ip4 = new TextField(3);
    39. start = new Button("Start");
    40. this.setTitle("Client");
    41. this.add(lbl_port);
    42. this.add(port);
    43. this.add(lbl_ip);
    44. this.add(ip1);
    45. this.add(ip2);
    46. this.add(ip3);
    47. this.add(ip4);
    48. this.add(start);
    49. this.pack();
    50. this.setResizable(false);
    51. start.addActionListener(this);
    52. this.setVisible(true);
    53. }
    55. public void actionPerformed(ActionEvent e)
    56. {
    57. String ip = new String();
    58. int prt=0;
    59. try
    60. {
    61. prt = Integer.parseInt(port.getText());
    62. if (!(prt < 32768 && prt > 128))
    63. {
    64. System.out.println("Port muss einen Zahl < 32768 und > 128");
    65. System.exit(1);
    66. }
    68. }
    69. catch(NumberFormatException nfe)
    70. {
    71. System.out.println("Port muss einen Zahl < 32768 und > 128");
    72. System.exit(1);
    73. }
    76. if(isOk() == false)
    77. {
    78. System.out.println("IP nicht korrekt");
    79. System.exit(0);
    80. }
    82. ip = ip1.getText() + "." + ip2.getText() + "." + ip3.getText() + "." + ip4.getText();
    83. ChatClient cc = new ChatClient(ip,prt);
    85. }
    87. public static void main(String[] args)
    88. {
    89. InitClient ic = new InitClient();
    90. }
    92. // Überprüft ob IP korrekt ist
    93. public boolean isOk()
    94. {
    95. if (Integer.parseInt(ip1.getText()) < 255 && Integer.parseInt(ip2.getText()) < 255 && Integer.parseInt(ip3.getText()) < 255 && Integer.parseInt(ip4.getText()) < 255)
    96. return true;
    97. else return false;
    98. }
    99. }
    Alles anzeigen


    ChatClient.java

    Java-Quellcode

    1. package client;
    3. import java.awt.*;
    4. import java.awt.event.*;
    5. import java.net.*;
    6. import java.io.*;
    8. public class ChatClient extends Frame implements ActionListener, Runnable
    9. {
    10. public TextArea oben;
    11. public TextField unten;
    12. public Socket s;
    13. public DataInputStream din;
    14. public DataOutputStream dout;
    16. public ChatClient(String ip, int port)
    17. {
    18. this.setLayout(new BorderLayout(1,2));
    19. this.setSize(640,480);
    20. this.setResizable(false);
    21. this.setTitle("Client");
    22. this.setBackground(Color.gray);
    24. oben = new TextArea();
    25. unten = new TextField(255);
    27. this.add(oben,BorderLayout.CENTER);
    28. this.add(unten,BorderLayout.SOUTH);
    30. this.addWindowListener(new WindowAdapter(){
    31. public void windowClosing(WindowEvent e){
    32. send("quit");
    33. dispose();
    34. System.exit(0);}});
    35. unten.addActionListener(this);
    36. this.setVisible(true);
    37. // Socket erstellen
    38. try
    39. {
    40. s = new Socket(ip,port);
    41. din = new DataInputStream(s.getInputStream());
    42. dout = new DataOutputStream(s.getOutputStream());
    43. }
    44. catch(UnknownHostException uhe)
    45. {
    46. System.out.println("unkown");
    47. }
    48. catch(IOException i)
    49. {
    50. System.out.println("Initialisierungsfehler: " + i.getMessage());
    51. }
    53. // auf Message warten
    54. Thread th = new Thread(this);
    55. th.start();
    58. }
    61. public void actionPerformed(ActionEvent e)
    62. {
    63. oben.append("\n" + unten.getText());
    64. System.out.println(send(unten.getText()));
    65. unten.setText("");
    66. }
    68. public int send(String msg)
    69. {
    70. try
    71. {
    73. if (msg == null) return 0;
    74. dout.writeUTF(msg);
    75. // dout.close();
    76. }
    77. catch(IOException io)
    78. {
    79. System.out.println("Sendefehler: " + io.getMessage());
    80. return -1;
    81. }
    82. return 1;
    83. }
    85. public void run()
    86. {
    87. String msg = new String("");
    88. while(!msg.equals("quit"))
    89. {
    90. try
    91. {
    93. msg = din.readUTF();
    94. if (msg != null) oben.append("\n" + msg);
    96. }
    97. catch (IOException io)
    98. {
    99. System.out.println("Empfangsfehler: " + io.getMessage());
    100. }
    101. }
    102. }
    103. }
    Alles anzeigen

  • InitServer.java

    Java-Quellcode

    1. package server;
    3. import java.awt.*;
    4. import java.awt.event.*;
    6. /**
    7. * <p>Überschrift: </p>
    8. * <p>Beschreibung: </p>
    9. * <p>Copyright: Copyright (c) 2003</p>
    10. * <p>Organisation: </p>
    11. * @author unbekannt
    12. * @version 1.0
    13. */
    15. public class InitServer extends Frame implements ActionListener {
    16. public Label lbl_port;
    17. public TextField port;
    18. public Button start;
    20. public InitServer() {
    21. this.setLayout(new BorderLayout());
    23. this.addWindowListener(new WindowAdapter(){
    24. public void windowClosing(WindowEvent e)
    25. {
    26. dispose();
    27. System.exit(0);
    28. }});
    29. lbl_port = new Label("Portnummer:");
    30. start = new Button("Start");
    31. port = new TextField(5);
    32. this.setTitle("SERVER");
    33. this.add(lbl_port,BorderLayout.WEST);
    34. this.add(port,BorderLayout.CENTER);
    35. this.add(start,BorderLayout.EAST);
    36. this.pack();
    37. this.setResizable(false);
    38. start.addActionListener(this);
    39. this.setVisible(true);
    41. }
    43. public void actionPerformed(ActionEvent e)
    44. {
    45. int prt;
    46. try
    47. {
    48. prt = Integer.parseInt(port.getText());
    49. if (!(prt < 32768 && prt > 128))
    50. {
    51. System.out.println("Port muss einen Zahl < 32768 und > 128");
    52. System.exit(0);
    53. }
    54. ChatServer cs = new ChatServer(prt);
    55. }
    56. catch(NumberFormatException nfe)
    57. {
    58. System.out.println("Port muss einen Zahl < 32768 und > 128");
    59. }
    60. //ChatServer cs = new ChatServer(1234);
    61. }
    62. public static void main(String[] args)
    63. {
    64. InitServer is = new InitServer();
    65. }
    66. }
    Alles anzeigen


    ChatServer.java

    Java-Quellcode

    1. package server;
    3. import java.awt.*;
    4. import java.awt.event.*;
    5. import java.net.*;
    6. import java.io.*;
    8. public class ChatServer extends Frame implements ActionListener, Runnable
    9. {
    10. public TextArea oben;
    11. public TextField unten;
    12. public ServerSocket ss;
    13. public Socket s;
    14. public DataInputStream din;
    15. public DataOutputStream dout;
    17. public ChatServer(int port)
    18. {
    19. // Oberfläche
    20. this.setLayout(new BorderLayout(1,2));
    21. this.setSize(640,480);
    22. this.setResizable(false);
    23. this.setTitle("Server");
    24. this.setBackground(Color.gray);
    26. oben = new TextArea();
    27. unten = new TextField(255);
    29. this.add(oben,BorderLayout.CENTER);
    30. this.add(unten,BorderLayout.SOUTH);
    32. this.addWindowListener(new WindowAdapter(){
    33. public void windowClosing(WindowEvent e){
    34. send("quit");
    35. dispose();
    36. System.exit(0);}});
    37. unten.addActionListener(this);
    38. this.setVisible(true);
    39. // Verbindung zum Client herstellen
    40. try
    41. {
    42. ss = new ServerSocket(port);
    43. s = ss.accept();
    44. din = new DataInputStream(s.getInputStream());
    45. dout = new DataOutputStream(s.getOutputStream());
    46. }
    47. catch(UnknownHostException uhe)
    48. {
    49. System.out.println("unkown");
    50. }
    51. catch(IOException i)
    52. {
    53. System.out.println("Initialisierungsfehler: " + i.getMessage());
    54. }
    56. // auf Message warten
    57. Thread th = new Thread(this);
    58. th.start();
    60. }
    63. public void actionPerformed(ActionEvent e)
    64. {
    65. oben.append("\n" + unten.getText());
    66. System.out.println(send(unten.getText()));
    67. unten.setText("");
    68. }
    70. public int send(String msg)
    71. {
    72. try
    73. {
    75. if (msg == null) return 0;
    76. dout.writeUTF(msg);
    77. }
    78. catch(IOException io)
    79. {
    80. System.out.println("Sendefehler: " + io.getMessage());
    81. return -1;
    82. }
    83. return 1;
    84. }
    86. public void run()
    87. {
    88. String msg = new String("");
    89. while(!msg.equals("quit"))
    90. {
    91. try
    92. {
    94. msg = din.readUTF();
    95. if (msg != null) oben.append("\n" + msg);
    97. }
    98. catch (IOException io)
    99. {
    100. System.out.println("Empfangsfehler: " + io.getMessage());
    101. }
    102. }
    103. }
    Alles anzeigen