Siemka, od paru dni siedzę nad kodem który ma za zadanie wysłać od strony servera do strony clienta wiadomość od razu gdy ten się połączy. Połączenie wykonuje się bezbłędnie, ale wysyłanie wiadomości... w ogóle... Przeszukałem Internety i nic... nie pomaga. Ostatnią nadzieją jesteście Wy. Z góry mega dziękuje! Pozdrawiam :)
KOD SERVER,JAVA
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.StringReader;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketAddress;
import java.net.Socket.*;
import java.util.Scanner;
import java.net.ServerSocket.*;
class Server{
static ServerSocket serverSocket;
static Socket client = null;
static String command;
static String message;
static Scanner scanner;
static Scanner sendMessage;
static int port;
static int ip;
static boolean isToSend = false;
public static void main(String[] args) throws Exception {
scanner = new Scanner(System.in);
sendMessage = new Scanner(System.in);
EnterPortAndIp();
CreateSocket();
SendToClient();
}
static void CreateSocket(){
try{
serverSocket = new ServerSocket(port);
client = serverSocket.accept();
}catch(Exception e){
System.out.println(e);
}
}
static void SendToClient(){
try{
while(true){
PrintWriter out = null;
out = new PrintWriter(client.getOutputStream() , true);
BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
String a = in.readLine();
System.out.println("message: " + a);
}
}catch(Exception e){
System.out.println(e);
}
}
static void EnterPort(){
scanner = new Scanner(System.in);
System.out.print("Please enter port: ");
port = scanner.nextInt();
}
KOD CLIENT.JAVA
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketAddress;
import java.net.Socket.*;
import java.util.Scanner;
import java.net.ServerSocket.*;
class Client{
static Socket client2;
static Scanner scanner;
static String ip;
static String message;
static String command;
static int port;
static BufferedReader in = null;
public static void main(String[] args) {
scanner = new Scanner(System.in);
EnterIpAndPort();
CreateSocket();
}
static void CreateSocket(){
try{
client2 = new Socket(ip, port);
MessageFromServer();
}
catch(Exception e){
System.out.println(e);
}
}
static void EnterIpAndPort(){
System.out.print("Please enter ip: ");
ip = scanner.next();
System.out.print("Please enter port: ");
port = scanner.nextInt();
}
static void StatusConnection (){
if(client2.isConnected()){
System.out.println("connect status: " + client2.isConnected());
}
}
static void MessageFromServer(){
System.out.println("Message form server: ");
try{
while(true){
BufferedReader in = new BufferedReader(new InputStreamReader(client2.getInputStream()));
PrintWriter out = new PrintWriter(client2.getOutputStream());
DataOutputStream outData = new DataOutputStream(client2.getOutputStream());
BufferedReader inServer = new BufferedReader(new InputStreamReader(System.in));
while(true){
while(in.ready()){
System.out.println(in.readLine());
}
}
}
}catch(Exception e){
System.out.println(e);
}
}
}