package com.map.service;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
public class Client2 implements Runnable{
private static Client2 c;
public static void main(String[] args){
c=new Client2();
c.run();
}
public void run() {
try {
Socket socket = new Socket("192.168.28.122", 10000);
System.out.println("00");
SocketHandler h = new SocketHandler(socket);
System.out.println("11");
new Thread(h).start();
h.send();
System.out.println("33");
Thread.sleep(20000);
socket.close();
c.run();
} catch (Exception e) {
e.printStackTrace();
}
}
static class SocketHandler implements Runnable {
private Socket socket;
private BufferedReader in;
private DataInputStream dis;
private DataOutputStream dos;
public SocketHandler(Socket socket){
this.socket = socket;
try {
this.in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
this.dos = new DataOutputStream(socket.getOutputStream());
this.dis = new DataInputStream(new FileInputStream("C:\\Users\\dong\\Desktop\\my.txt"));
} catch (IOException e) {
e.printStackTrace();
}
}
public void send() {
try {
byte[] buffer = new byte[1024];
int size;
while ((size = dis.read(buffer)) != -1) {
dos.write(buffer, 0, size);
dos.flush();
}
dis.close();
dos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
public void run() {
try {
String line;
System.out.println("sdlf");
while((line = in.readLine()) != null) {
System.out.println(line);
if(line.equalsIgnoreCase("load")){
System.out.println("6666666666666888888888888888");
}
}
} catch(Exception e) {}
}
}
}
- 1
- 2
前往页