хотел написать клиент-серверное приложение, клиент на android-e, а сервер в компьютере. как отправить image с сервера на клиент? я реализовал так: отправляю image когда клиент только что подключился, а он сохраняет его в память телефона и обратно загружает его в ImageView. я не могу отправить image в любое время, а вот message могу. Как это реализовать?
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Iterator;
public class Main extends Thread {
ArrayList clientOutputStreams;
int k = 0;
Socket socket;
PrintWriter writer;
static DBWorker worker;
ThreadGroup tGroup = new ThreadGroup("Clients");
String car_name = "";
String way = "C:\\Users\\NurSultan\\Desktop\\cars\\audi\\audi_a1.jpg";
public class ClientHandler implements Runnable{
BufferedReader reader;
public ClientHandler(Socket clientSocket){
try{
socket = clientSocket;
InputStreamReader isReader = new InputStreamReader(socket.getInputStream());
reader = new BufferedReader(isReader);
}catch (IOException ex){
ex.printStackTrace();
}catch (Exception ex){
ex.printStackTrace();
}
}
@Override
public void run() {
String message;
try{
while ((message = reader.readLine()) != null){
Car car = new Car();
try {
if(message.equals("")) {
String query = "select * from cars";
Statement statement = worker.getConnection().createStatement();
ResultSet resultSet = statement.executeQuery(query);
String cars = "cars";
while (resultSet.next()) {
car.setCars_name(resultSet.getString("cars_name"));
cars += String.valueOf(car) + "-";
}
System.out.println(cars);
tellEveryone(String.valueOf(cars));
}else{
String four = message.substring(0, 4);
message = message.substring(4);
if(four.equals("mdls")){
//convert "A" to "a"
char[] ccc = message.toCharArray();
message = "";
for(int i=0; i<ccc.length; i++){
if(!((int)ccc[i]>=97 && (int)ccc[i]<=122) && !(ccc[i] >= 0 && ccc[i] <= 9)){
ccc[i] = (char)((int)ccc[i] + 32);
}
message += ccc[i];
}
car_name = message;
System.out.println("char message = " + message);
String query = "select * from " + message + "_models";
String mdls = "mdls";
Statement statement = worker.getConnection().createStatement();
ResultSet resultSet = statement.executeQuery(query);
while (resultSet.next()){
car.setCars_name(resultSet.getString("models_name"));
mdls += String.valueOf(car) + "-";
}
System.out.println(mdls);
tellEveryone(mdls);
}else{
if(four.equals("dtls")){
way = "C:\\Users\\NurSultan\\Desktop\\cars\\audi\\audi_a1.jpg";
//sendPhoto(way);
//telEveryone("dtls" + "об машине");
}
}
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}catch (Exception ex){
ex.printStackTrace();
}
}
}
public static void main(String[] args){
System.out.println("Server started...");
System.out.println("Listening port 5000");
System.out.println();
worker = new DBWorker();
new Main().go();
}
public void go(){
clientOutputStreams = new ArrayList();
try {
ServerSocket serverSocket = new ServerSocket(5000);
while (true) {
Socket clientSocket = serverSocket.accept();
PrintWriter writer = new PrintWriter(clientSocket.getOutputStream());
clientOutputStreams.add(writer);
new Thread(tGroup, new ClientHandler(clientSocket), String.valueOf(k)).start();
System.out.println("got a connection");
sendPhoto(way);
k++;
}
}catch (Exception e){
e.printStackTrace();
}
}
public void tellEveryone(String message){
Iterator it = clientOutputStreams.iterator();
while (it.hasNext()){
try{
writer = (PrintWriter) it.next();
writer.println(message);
writer.flush();
}catch (Exception ex){
ex.printStackTrace();
}
}
}
public void sendPhoto(String way){
ObjectOutputStream objectOutputStream;
try {
FileInputStream file = new FileInputStream(way);
byte[] buffer = new byte[file.available()];
file.read(buffer);
objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
objectOutputStream.writeObject(buffer);
objectOutputStream.flush();
System.out.println("Send foto");
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
DBWorker() - подключение к базе данных, Car - класс для получение имя машины из базы данных, tellEveryone - отправляем сообщение всем клиентам, sendPhoto - отправляем фото! Этот код отправляет фото только тогда когда клиент подключается, я хотел отправить фото в class-e ClientHandler в методе run(). ИЛИ у меня в клиенте ошибка посмотрите его тоже.
в ChatOperator - e подключаюсь к серверу, InputStreamReader - для получения сообщения. он нормально работает, a ObjectInputStream - для получения картинки, он только в начале принимает картинку, если сервер хочет отправить еще картинку он просто вылетает из приложения.
Средний
