Java Chat-Programm

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

  • Java Chat-Programm

    Hi Leute!
    Ich bräuchte mal eure Hilfe, ich hab hier ein Chat-Programm, dass aber nur mit einem Server und einem Client funktioniert. Es soll aber wenn möglich mit mehreren Client (am besten ohne Server-Instanz) rennen.
    Habt ihr da vl Tips für mich wie ich dieses Beispiel verändern kann?

    mfg, nagl


    Quellcode

    1. public class TCPChat {
    3. public static void main(String args[]) {
    5. TCPChatCom comChat = new TCPChatCom();
    6. TCPChatGUI guiChat = new TCPChatGUI();
    8. guiChat.createAndShowGUI( comChat );
    9. comChat.setGUI( guiChat );
    11. }
    13. }
    19. import java.lang.*;
    20. import java.io.*;
    21. import java.net.*;
    23. public class TCPChatCom implements Runnable {
    25. private ServerSocket defSocket = null;
    26. private Socket srvSocket = null;
    27. private BufferedReader inStream = null;
    28. private PrintWriter outStream = null;
    29. private TCPChatGUI guiChat = null;
    30. private Thread process = null;
    32. TCPChatCom() {
    33. }
    36. public void run() {
    37. System.out.println("Verbindung hergestellt");
    38. try {
    39. while( true ) {
    40. try { // Poll every ~10 ms
    41. Thread.sleep(10);
    42. }
    43. catch (InterruptedException e) {}
    45. if (inStream.ready()) {
    46. System.out.print("erhalten: ");
    47. String s = inStream.readLine();
    48. if ((s != null) && (s.length() != 0)) {
    49. guiChat.addMessage( s );
    50. System.out.println(s);
    51. }
    53. }
    54. }
    55. }
    56. catch(Exception e) {
    57. System.out.println("Fehler aufgetreten");
    58. }
    60. try {
    61. inStream.close();
    62. outStream.close();
    63. srvSocket.close();
    64. if ( defSocket != null )
    65. defSocket.close();
    66. System.out.println("Verbindung beendet");
    67. }
    68. catch(Exception e) {
    69. System.out.println("Fehler aufgetreten");
    70. }
    72. }
    74. public void startServer() {
    75. try {
    76. System.out.println("startServer() -> Server wartet auf Verbindung");
    77. defSocket = new ServerSocket(Integer.parseInt(guiChat.port.getText()) );
    78. srvSocket = defSocket.accept();
    79. inStream = new BufferedReader(new InputStreamReader(srvSocket.getInputStream()));
    80. outStream = new PrintWriter(srvSocket.getOutputStream(), true);
    81. process = new Thread( this );
    82. process.start();
    83. }
    84. catch(Exception e) {
    85. System.out.println("TCPChatCom startServer(): Fehler aufgetreten");
    86. }
    87. }
    89. public void startConnection( ) {
    90. try {
    91. String ip = guiChat.ipAdr.getText();
    92. int port = Integer.parseInt(guiChat.port.getText());
    93. srvSocket = new Socket(ip, port );
    94. System.out.println("start Connection");
    95. inStream = new BufferedReader(new InputStreamReader(srvSocket.getInputStream()));
    96. outStream = new PrintWriter(srvSocket.getOutputStream(), true);
    97. process = new Thread( this );
    98. process.start();
    99. }
    100. catch(Exception e) {
    101. System.out.println("TCPChatCom startConnection(): Fehler aufgetreten");
    102. }
    103. }
    105. public void stopConnection( ) {
    106. try {
    107. process.stop();
    108. inStream.close();
    109. outStream.close();
    110. srvSocket.close();
    111. if ( defSocket != null )
    112. defSocket.close();
    113. }
    114. catch(Exception e) {
    115. System.out.println("TCPChatCom stopConnection(): Fehler aufgetreten");
    116. }
    117. }
    119. public void sendMessage( String inMessage ) {
    120. try {
    121. System.out.println("Sende Nachricht: " + inMessage );
    122. outStream.print( inMessage );
    123. outStream.flush();
    124. }
    125. catch(Exception e) {
    126. System.out.println("TCPChatCom sendMessage(): Fehler aufgetreten");
    127. }
    128. }
    130. public void setGUI( TCPChatGUI inGuiChat ) {
    131. guiChat = inGuiChat;
    132. }
    134. }
    143. import java.io.*;
    144. import java.awt.*;
    145. import java.awt.event.*;
    146. import javax.swing.*;
    147. import javax.swing.event.*;
    149. import java.lang.*;
    150. import java.util.*;
    153. public class TCPChatGUI extends JPanel {
    155. private static TCPChatCom comChat = null;
    157. public static JFrame mainFrame = null;
    158. public static JTextArea chatText = null;
    159. public static JTextField chatLine = null;
    160. public static JPanel statusBar = null;
    161. public static JLabel statusField = null;
    162. public static JTextField myName = null;
    163. public static JTextField statusColor = null;
    164. public static JTextField ipAdr = null;
    165. public static JTextField port = null;
    166. public static JRadioButton hostOption = null;
    167. public static JRadioButton guestOption = null;
    168. public static JButton connectButton = null;
    169. public static JButton disconnectButton = null;
    171. ActionListener buttonListener = null;
    172. ChatListener chatListener = null;
    174. public TCPChatGUI() {
    175. super(new BorderLayout());
    176. chatListener = new ChatListener();
    177. JPanel pane = null;
    179. JPanel optionsPane = new JPanel(new GridLayout(5, 1));
    181. pane = new JPanel(new FlowLayout(FlowLayout.CENTER));
    182. pane.add(new JLabel("My Name:"));
    183. myName = new JTextField(10);
    184. myName.setText("");
    185. myName.setEnabled(true);
    186. pane.add( myName );
    187. optionsPane.add(pane);
    189. JPanel ipPanel = new JPanel(new FlowLayout(FlowLayout.CENTER));
    190. ipPanel.add(new JLabel("Server IP:"));
    191. ipAdr = new JTextField(10);
    192. ipAdr.setText("127.0.0.1");
    193. ipAdr.setEnabled(true);
    194. ipPanel.add(ipAdr);
    196. ipPanel.add(new JLabel("Port: "));
    197. port = new JTextField(5);
    198. port.setText("1234");
    199. port.setEnabled(true);
    200. ipPanel.add(port);
    201. optionsPane.add(ipPanel);
    203. ButtonGroup bg = new ButtonGroup();
    204. hostOption = new JRadioButton("Server", true);
    205. hostOption.setMnemonic(KeyEvent.VK_H);
    206. hostOption.setActionCommand("server");
    208. guestOption = new JRadioButton("Client", false);
    209. guestOption.setMnemonic(KeyEvent.VK_G);
    210. guestOption.setActionCommand("client");
    212. bg.add(hostOption);
    213. bg.add(guestOption);
    214. pane = new JPanel(new GridLayout(1, 2));
    215. pane.add(hostOption);
    216. pane.add(guestOption);
    217. optionsPane.add(pane);
    220. JPanel buttonPane = new JPanel(new GridLayout(1, 2));
    222. connectButton = new JButton("Connect");
    223. connectButton.setMnemonic(KeyEvent.VK_C);
    224. connectButton.setActionCommand("connect");
    225. connectButton.addActionListener( chatListener );
    226. connectButton.setEnabled(true);
    227. disconnectButton = new JButton("Disconnect");
    228. disconnectButton.setMnemonic(KeyEvent.VK_D);
    229. disconnectButton.setActionCommand("disconnect");
    230. disconnectButton.addActionListener( chatListener );
    231. disconnectButton.setEnabled(true);
    232. buttonPane.add(connectButton);
    233. buttonPane.add(disconnectButton);
    234. optionsPane.add(buttonPane);
    236. // Set up the chat pane
    237. JPanel chatPane = new JPanel(new BorderLayout());
    238. chatText = new JTextArea(10, 20);
    239. chatText.setLineWrap(true);
    240. chatText.setEditable(false);
    241. chatText.setForeground(Color.blue);
    242. JScrollPane chatTextPane = new JScrollPane(chatText,
    243. JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,
    244. JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
    245. chatLine = new JTextField();
    246. chatLine.setEnabled(true);
    248. chatLine.addActionListener( chatListener );
    250. chatPane.add(chatLine, BorderLayout.SOUTH);
    251. chatPane.add(chatTextPane, BorderLayout.CENTER);
    252. chatPane.setPreferredSize(new Dimension(200, 250));
    254. this.add(optionsPane, BorderLayout.SOUTH);
    255. this.add(chatPane, BorderLayout.NORTH);
    256. }
    258. public static void createAndShowGUI( TCPChatCom inComChat ) {
    259. comChat = inComChat;
    260. JFrame frame = new JFrame("TCPChat");
    261. frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    263. JComponent newContentPane = new TCPChatGUI();
    264. newContentPane.setOpaque(true); //content panes must be opaque
    265. frame.setContentPane(newContentPane);
    267. frame.pack();
    268. frame.setVisible(true);
    269. }
    271. public static void addMessage( String inMessage ) {
    272. chatText.append(inMessage + "\n" );
    273. }
    275. class ChatListener implements ActionListener {
    277. public void actionPerformed(ActionEvent e) {
    279. if ( e.getSource() == chatLine ) {
    280. String message = chatLine.getText();
    281. if ( !message.equals("") ) {
    282. comChat.sendMessage( myName.getText() + ": " + message + "\n");
    283. addMessage( myName.getText() + ": " + message );
    284. chatLine.setText("");
    285. }
    286. }
    288. if ( e.getSource() == connectButton ) {
    289. if ( hostOption.isSelected() )
    290. comChat.startServer();
    291. else
    292. comChat.startConnection();
    293. }
    295. if ( e.getSource() == disconnectButton ) {
    296. comChat.stopConnection();
    297. }
    299. }
    300. }
    302. }
    Alles anzeigen