Client1 funktioniert. Message modifiziert.
This commit is contained in:
parent
fcb9dc9b5e
commit
59ed34c94a
2 changed files with 170 additions and 36 deletions
|
@ -1,49 +1,168 @@
|
||||||
package client;
|
package client;
|
||||||
|
|
||||||
/**
|
import java.awt.BorderLayout;
|
||||||
* @author berdan
|
import java.awt.EventQueue;
|
||||||
*/
|
import java.awt.TextArea;
|
||||||
|
|
||||||
|
import javax.swing.JFrame;
|
||||||
|
import javax.swing.JPanel;
|
||||||
|
import javax.swing.border.EmptyBorder;
|
||||||
|
|
||||||
import utils.Message;
|
import utils.Message;
|
||||||
import java.net.*;
|
|
||||||
import java.io.*;
|
import javax.swing.JTextField;
|
||||||
import java.text.SimpleDateFormat;
|
import javax.swing.JButton;
|
||||||
import java.util.Date;
|
import javax.swing.JTextArea;
|
||||||
import java.time.LocalDateTime;
|
import java.awt.Color;
|
||||||
import java.time.format.DateTimeFormatter;
|
import java.awt.event.ActionListener;
|
||||||
import java.time.format.FormatStyle;
|
import java.io.IOException;
|
||||||
|
import java.io.ObjectInputStream;
|
||||||
|
import java.io.ObjectOutputStream;
|
||||||
|
import java.net.Socket;
|
||||||
|
import java.util.Scanner;
|
||||||
|
import java.awt.event.ActionEvent;
|
||||||
|
|
||||||
|
public class Client1 extends JFrame {
|
||||||
|
|
||||||
|
private static JPanel contentPane;
|
||||||
|
JTextField txtMessage;
|
||||||
|
private JTextField txtUsername;
|
||||||
|
public static String currentText = " ";
|
||||||
|
public static int i = 0;
|
||||||
|
public static Object tosend = new Message("Leer", "Leer");
|
||||||
|
public static Client1 t1;
|
||||||
|
public static Socket socket;
|
||||||
|
public static ObjectInputStream obinstr;
|
||||||
|
public static ObjectOutputStream oboust;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
public class Client1 {
|
public static void main(String[] args) {
|
||||||
public Client1() throws IOException, ClassNotFoundException {
|
t1 = new Client1();
|
||||||
Socket socket = new Socket( "localhost", 1236 );
|
EventQueue.invokeLater(new Runnable() {
|
||||||
ObjectOutputStream oboust = new ObjectOutputStream(socket.getOutputStream());
|
public void run() {
|
||||||
ObjectInputStream obinstr = new ObjectInputStream(socket.getInputStream());
|
try {
|
||||||
|
Client1 frame = new Client1();
|
||||||
|
frame.setVisible(true);
|
||||||
|
} catch (Exception e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
Message senden = new Message( "berdan", "test" );
|
|
||||||
System.out.println(senden);
|
|
||||||
|
|
||||||
// Message senden
|
try {
|
||||||
oboust.writeObject(senden);
|
start();
|
||||||
|
} catch (ClassNotFoundException e) {
|
||||||
|
// TODO Auto-generated catch block
|
||||||
|
e.printStackTrace();
|
||||||
|
} catch (IOException e) {
|
||||||
|
// TODO Auto-generated catch block
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public Client1() {
|
||||||
|
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
|
||||||
|
setBounds(100, 100, 450, 300);
|
||||||
|
contentPane = new JPanel();
|
||||||
|
contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
|
||||||
|
setContentPane(contentPane);
|
||||||
|
contentPane.setLayout(null);
|
||||||
|
|
||||||
|
txtMessage = new JTextField();
|
||||||
|
txtMessage.setText("Message");
|
||||||
|
txtMessage.setBounds(117, 29, 218, 20);
|
||||||
|
contentPane.add(txtMessage);
|
||||||
|
txtMessage.setColumns(10);
|
||||||
|
|
||||||
|
txtUsername = new JTextField();
|
||||||
|
txtUsername.setText("Username");
|
||||||
|
txtUsername.setBounds(21, 29, 86, 20);
|
||||||
|
contentPane.add(txtUsername);
|
||||||
|
txtUsername.setColumns(10);
|
||||||
|
|
||||||
|
JButton btnSend = new JButton("Send");
|
||||||
|
btnSend.addActionListener(new ActionListener() {
|
||||||
|
public void actionPerformed(ActionEvent arg0) {
|
||||||
|
|
||||||
|
String themessage = txtMessage.getText();
|
||||||
|
String theusername = txtUsername.getText();
|
||||||
|
|
||||||
|
tosend = new Message(theusername, themessage);
|
||||||
|
i = 1;
|
||||||
|
|
||||||
|
System.out.println("Button pressed");
|
||||||
|
|
||||||
|
try {
|
||||||
|
oboust.writeObject(tosend);
|
||||||
oboust.flush();
|
oboust.flush();
|
||||||
|
} catch (IOException e) {
|
||||||
|
// TODO Auto-generated catch block
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
|
||||||
// Message erhalten
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
btnSend.setBounds(345, 28, 79, 23);
|
||||||
|
contentPane.add(btnSend);
|
||||||
|
|
||||||
|
JTextArea textArea = new JTextArea(currentText);
|
||||||
|
textArea.setLineWrap(true);
|
||||||
|
textArea.setForeground(Color.WHITE);
|
||||||
|
textArea.setBackground(Color.BLACK);
|
||||||
|
textArea.setBounds(20, 60, 323, 176);
|
||||||
|
contentPane.add(textArea);
|
||||||
|
}
|
||||||
|
|
||||||
|
public static void print(JTextArea textArea, String asd){
|
||||||
|
currentText = asd + "\n" + currentText;
|
||||||
|
textArea.setText(currentText);
|
||||||
|
}
|
||||||
|
|
||||||
|
public static void start() throws IOException, ClassNotFoundException{
|
||||||
|
Scanner scan = new Scanner(System.in);
|
||||||
|
|
||||||
|
JTextArea textArea = new JTextArea(currentText);
|
||||||
|
textArea.setLineWrap(true);
|
||||||
|
textArea.setForeground(Color.WHITE);
|
||||||
|
textArea.setBackground(Color.BLACK);
|
||||||
|
textArea.setBounds(20, 60, 323, 176);
|
||||||
|
contentPane.add(textArea);
|
||||||
|
|
||||||
|
socket = new Socket( "localhost", 1236 );
|
||||||
|
oboust = new ObjectOutputStream(socket.getOutputStream());
|
||||||
|
obinstr = new ObjectInputStream(socket.getInputStream());
|
||||||
|
|
||||||
Object erhalten = null;
|
Object erhalten = null;
|
||||||
while(erhalten==null){
|
Message message = new Message("leer", "leer");
|
||||||
erhalten = obinstr.readObject();
|
|
||||||
}
|
|
||||||
System.out.println(erhalten);
|
|
||||||
|
|
||||||
|
while(!message.getMessage().equals("exit")){
|
||||||
|
try{
|
||||||
|
erhalten = obinstr.readObject(); //Bleibt hier stehen, bis ein neues Object reinkommt
|
||||||
|
|
||||||
|
message = (Message)erhalten;
|
||||||
|
String Ausgeben = "[" + message.getUsername() + "] " + message.getMessage();
|
||||||
|
print(textArea, Ausgeben);
|
||||||
|
oboust.flush();
|
||||||
|
}catch(Exception f){
|
||||||
|
try {
|
||||||
|
Thread.sleep(1000);
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
// TODO Auto-generated catch block
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
oboust.close();
|
oboust.close();
|
||||||
obinstr.close();
|
obinstr.close();
|
||||||
|
socket.close();
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void main(String args[]) throws IOException, ClassNotFoundException {
|
|
||||||
new Client1();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -27,4 +27,19 @@ public class Message implements Serializable {
|
||||||
//+ ", time=" + date;
|
//+ ", time=" + date;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public boolean exit() {
|
||||||
|
if(message.equalsIgnoreCase("exit")){
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getMessage() {
|
||||||
|
return message;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getUsername() {
|
||||||
|
return username;
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue