Вот краткий пример приложения, которое отправляет данные на себя более Socket
с.
public class App {
private static final AtomicInteger port = new AtomicInteger(-1);
private static final AtomicBoolean read = new AtomicBoolean(true);
private static final class SocketReader implements Runnable {
@Override
public void run() {
try {
final ServerSocket serverSocket = new ServerSocket(0);
System.out.println("Connected on " + serverSocket);
synchronized (port) {
port.set(serverSocket.getLocalPort());
port.notifyAll();
}
while (read.get()) {
try (final Socket socket = serverSocket.accept()) {
final DataInputStream dis = new DataInputStream(socket.getInputStream());
System.out.println(dis.readDouble());
byte[] buffer = new byte[1024];
int numRead;
while ((numRead = dis.read(buffer)) != -1) {
System.out.print(new String(buffer, 0, numRead, "UTF-8"));
}
}
}
} catch (Exception ex) {
throw new RuntimeException(ex);
}
}
}
private static final class SocketWriter implements Runnable {
private final double d;
private final File file;
public SocketWriter(double d, File file) {
this.d = d;
this.file = file;
}
@Override
public void run() {
try {
while (port.get() < 1) {
synchronized (port) {
port.wait();
}
}
try (final Socket clientSocket = new Socket("localhost", port.get());
final DataOutputStream dos = new DataOutputStream(clientSocket.getOutputStream())) {
System.out.println(clientSocket);
dos.writeDouble(d);
try (final FileInputStream fis = new FileInputStream(file)) {
byte[] buffer = new byte[1024];
int bytesRead;
while ((bytesRead = fis.read(buffer)) != -1) {
dos.write(buffer, 0, bytesRead);
}
}
dos.flush();
}
} catch (Exception ex) {
throw new RuntimeException(ex);
}
}
}
public static void main(String[] args) throws InterruptedException {
final double d = 2.35;
final File f = new File(new File(System.getProperty("user.home"), "Downloads"), "readme.txt");
final ExecutorService executorService = Executors.newSingleThreadExecutor();
final Future<?> future = executorService.submit(new SocketReader());
new SocketWriter(d, f).run();
read.set(false);
executorService.shutdownNow();
try {
future.get();
} catch (ExecutionException ex) {
throw new RuntimeException(ex);
}
}
}
Сначала мы посылаем double
сериализации, то он посылает содержимое случайного файла в моем каталоге Downloads.
Другой Thread
, между тем, эхо все, что на консоли.
Объект 'File' в java представляет _path_ файла, ** не ** его содержимое. Вам нужно будет отправить содержимое «FileInputStream» через ваш сокет. –
во-первых, спасибо за внимание. Да. Я знаю. Это всего лишь псевдокод. Идея логики заключается в том, что мне не нужно отправлять файл каждый раз. Это зависит от значения числа. – Way