travis Haycock

Qt And openCV in Mac OSX

For anyone that has done this can you please explain how you accomplish installing openCV in Qt on Mac OS ... heres what I have done so far.. I have installed openCV successfully on my mac I have confirmed its properly function playing with Xcode .. I am using Qt for lots of obvious reasons and am met with a bit of confusion in context of integrating the two. Heres what I have put in my title.pro file (see Below Code) I have also tried to include these header files into the main file but with no luck. I have been looking proper configuration and this seems to be a rather common problem with a lot of no posted answers or rather answers that do not seem to fit my case

8 years ago

Can Someone Please Explain Proper Set-up Of OpenCV in C

Hello thanks for your effort I have cleared this up essentially following some of your advice and researching and have saved myself some headaches

although I am met with more questions which are confusing considering I'm using a new IDE for C++ and newish to the language, again thanks for your help.

8 years ago

Can Someone Please Explain Proper Set-up Of OpenCV in C

Ive switched to C ++ a bit more organized with the OOP ;) just getting familiar with the opencv library etc. But i do find myself slow and going in circles in context of GUI... I realize the highgui is suppose to create a functioning gui but am having problems with simply creating these? I am using Xcode and am getting errors. Is there any clear documentation on constructing GUI I should note that I'm new to C++ so if I'm asking questions that seem simplistic its due to my lack of familiarity with C ++

8 years ago

Can Someone Please Explain Proper Set-up Of OpenCV in C

Thanks for the reply. I have actually solved the issue after a few hours of searching. I found the tutorial on openCv community on Youtube which demonstrated how to install it on mac osx This seems to functioning fine now, although if you don't mind i'd like to ask something in direct relation to openCV /C ... I found the documentation is mostly in C++ the OpenCV syntax on these demo pages it states C/ C++ Does this mean the syntax and structure are the same for C and C++ thanks, this is essentially what is holding me back at the moment, just searching for correct documentation thats all.

8 years ago

Can Someone Please Explain Proper Set-up Of OpenCV in C

Hello,

I am new to C and testing the waters this is a language I'm really interested in for a lot of reasons... I am attempting to play around with openCV and want to put it in my C project in Netbeans, Can someone please explain how to put openCV in my project folder so it will function. Thanks

8 years ago

Send universal File over Socket (pdf,txt,doc,jpeg, png etc.) between Client And Server

Thanks for the reply, why would this code be allowing only ZIP files to go through? it seems I can send those files without any modification of the code

8 years ago

Java in General

Send universal File over Socket (pdf,txt,doc,jpeg, png etc.) between Client And Server

Hello I am having difficulties sending files to my server I have successfully designed a few voice messaging methods which send a wav file over the network which work great but I am unable to send a file... I see lots of examples and try to make my own but it either stalls or throws exceptions I have been reading and can't find a real credible source that neither functional or provides theory can someone please help me out? my Server is receiving and my client is sending

CLIENT

public void chooseFile() throws IOException {
JFileChooser fc = new JFileChooser();
fc.setDialogTitle("Send File");
fc.setMultiSelectionEnabled(true);
fc.setFileSelectionMode(JFileChooser.FILES_AND_DIRECTORIES);
int dialog = fc.showSaveDialog(this);
if (dialog == JFileChooser.APPROVE_OPTION) {
File inputFile = fc.getSelectedFile();
System.out.println("the extension type:" + fc.getTypeDescription(inputFile));
inputFile.getName();
inputFile.getAbsoluteFile();
String nameOf = inputFile.getName();
System.out.println(" File: " + inputFile);
sendFile(inputFile);
}
}
public void sendFile(File inputFile) throws IOException {
connection3 = new Socket(InetAddress.getByName(serverIP), 1991);
byte[] mybytearray = new byte[(int) inputFile.length()];
FileInputStream fis = new FileInputStream(inputFile);
BufferedInputStream bis = new BufferedInputStream(fis);
bis.read(mybytearray, 0, mybytearray.length);
DataInputStream dis = new DataInputStream(bis);
dis.readFully(mybytearray, 0, mybytearray.length);
OutputStream os = connection3.getOutputStream();
//Sending file name and file size to the server
DataOutputStream dos = new DataOutputStream(os);
dos.writeUTF(inputFile.getName());
dos.writeLong(mybytearray.length);
dos.write(mybytearray, 0, mybytearray.length);
dos.flush();
//Sending file data to the server
os.write(mybytearray, 0, mybytearray.length);
os.flush();
//Closing socket
os.close();
dos.close();
connection3.close();

SERVER

class downloadFile implements Runnable {
public static final int BUFFER_SIZE = 100;
Echo echo;
ServerSocket server_download;
Socket connection_download;
FileOutputStream fos;
DataInputStream dis;
OutputStream output;
InputStream input;
int bytesRead;
int current = 0;
public downloadFile() {
}
@Override
public void run() {
try {
server_download = new ServerSocket(1991, 100);
} catch (IOException ex) {
Logger.getLogger(downloadFile.class.getName()).log(Level.SEVERE, null, ex);
}
try {
connection_download = server_download.accept();
} catch (IOException ex) {
Logger.getLogger(downloadFile.class.getName()).log(Level.SEVERE, null, ex);
}
System.out.println("waiting for file to be sent");
InputStream in = null;
try {
in = connection_download.getInputStream();
} catch (IOException ex) {
Logger.getLogger(downloadFile.class.getName()).log(Level.SEVERE, null, ex);
}
DataInputStream clientData = new DataInputStream(in);
String fileName = null;
try {
fileName = clientData.readUTF();
} catch (IOException ex) {
Logger.getLogger(downloadFile.class.getName()).log(Level.SEVERE, null, ex);
}
OutputStream output = null;
try {
output = new FileOutputStream(fileName);
} catch (FileNotFoundException ex) {
Logger.getLogger(downloadFile.class.getName()).log(Level.SEVERE, null, ex);
}
long size = 0;
try {
size = clientData.readLong();
} catch (IOException ex) {
Logger.getLogger(downloadFile.class.getName()).log(Level.SEVERE, null, ex);
}
byte[] buffer = new byte[1024];
try {
while (size > 0 && (bytesRead = clientData.read(buffer, 0, (int)Math.min(buffer.length, size))) != -1)
{
output.write(buffer, 0, bytesRead);
size -= bytesRead;
}
} catch (IOException ex) {
Logger.getLogger(downloadFile.class.getName()).log(Level.SEVERE, null, ex);
}
try {
// Closing the FileOutputStream handle
in.close();
} catch (IOException ex) {
Logger.getLogger(downloadFile.class.getName()).log(Level.SEVERE, null, ex);
}
try {
clientData.close();
} catch (IOException ex) {
Logger.getLogger(downloadFile.class.getName()).log(Level.SEVERE, null, ex);
}
try {
output.close();

8 years ago

Java in General

Where I think I was mistaken was just a lack of knowledge on my part I thought for example I could have used: (ill illustrate)

while(true){
Thread 1 (perform streams only etc.)

Thread 2 (perform only download etc.)

}

But in reality i need to replicate the whole class(s) for each connection .. if I'm not getting stuff mixed up again.

8 years ago

Thanks Paul, I'm rebuilding now I did what you recommend; started small scale with a simple echo server which worked kind of showed more in depth actually when I was working with shorter code what was going wrong. I tried to make the server fail and have found a couple faults where I went wrong with the threads.

8 years ago

Im officially stumped I have 7 hours on this now and am still able to make little progress on this. i have rebuilt the whole server hoping I missed something, but apparently its me. I don't understand where I'm going wrong but the output is showing below... 130 is referring to Objectoutput.writeObject(hostName + ": " + m); I have tried correcting it with no prevail If anyone can help that would be amazing.. When I start the server up and then the client everything seems to go fine at first than I get the ERROR(S) I put below on serverSide

As well when activating the Microphone and sending the sound file I am receiving this Error which I don't understand entirely, but am pretty positive its related to the first problem as well its pointing to the client-side
message = (String) Objectinput.readObject();

Im going to post my code with the server first following the client

public class ServerMain extends JFrame {
private ServerSocket server;
public Socket connection;
private ObjectOutputStream Objectoutput;
private ObjectInputStream Objectinput;
private JTextField userText;
final JTextArea chatWindow;
// Playback pb = new Playback();
final InetAddress ip;
String hostName;
public ServerMain() throws UnknownHostException {
super("SERVER");
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
setSize(500, 500);
System.out.println("Server Started");
userText = new JTextField();
userText.setEditable(false);
userText.addActionListener(
new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
sendMessage(e.getActionCommand());
userText.setText(" ");
}
});
chatWindow = new JTextArea();
ip = InetAddress.getLocalHost();
hostName = ip.getHostName();
add(userText, BorderLayout.SOUTH);
add(new JScrollPane(chatWindow));
add(chatWindow, BorderLayout.CENTER);
setVisible(true);
}
/* This is the main method that activated the loop
*/
private void handleAll() throws IOException {
System.out.println("SERVER RUNNING>>");
while (true) {
server = new ServerSocket(1998, 100);
connection = server.accept();
waitForConnection(connection);
/*
Set up COnnections for chat
*/
Thread textStreams = new Thread(new textStreams(connection));
textStreams.start();
whileChatting();
/*
download the voice file that can be sent by client
*/
Thread downloadVoice = new Thread(new downloadVoice(connection));
downloadVoice.start();
}
}
private void waitForConnection(Socket connection) throws IOException {
showMessage("\nWaiting For Connection To Be Established");
showMessage("\n\nNow Connected To : " + connection.getInetAddress().getHostName());
}
/*
This will show the message a user has sent to server
*/
private void whileChatting() throws IOException {
String message = "Now Connected";
sendMessage(message);
ableToType(true);
do {
try {
message = (String) Objectinput.readObject();
showMessage("\n" + message);
Objectinput.close();
} catch (ClassNotFoundException classNotFoundException) {
showMessage("ERROR");
}
} while (!message.equals("END"));
}
/*
Send Message To Cliente
*/
private void sendMessage(String m) {
try {
///************************************************************************************ ERROR HERE BELOW LINE 130
Objectoutput.writeObject(hostName + ": " + m);
//*****
Objectoutput.flush();
showMessage("\n" + hostName + ": " + m);
Objectoutput.close();
} catch (IOException e) {
chatWindow.append("\nERROR Sending Message!");
e.printStackTrace();
}
}
private void showMessage(final String text) {
SwingUtilities.invokeLater(
new Runnable() {
@Override
public void run() {
chatWindow.append(text);
}
}
);
}
/*
Permit user to type into JTextField
*/
private void ableToType(final boolean tof) {
SwingUtilities.invokeLater(
new Runnable() {
@Override
public void run() {
userText.setEditable(tof);
}
});
}
private void closeAll() {
showMessage("\n Closing Connections..");
ableToType(false);
try {
Objectoutput.close();
Objectinput.close();
} catch (IOException ioException) {
ioException.printStackTrace();
}
}
class textStreams implements Runnable {
Socket connection;
public textStreams(Socket connection) {
this.connection = connection;
}
@Override
public void run() {
try {
Objectoutput = new ObjectOutputStream(connection.getOutputStream());
Objectoutput.flush();
} catch (IOException ex) {
Logger.getLogger(ServerMain.class.getName()).log(Level.SEVERE, null, ex);
}
try {
Objectinput = new ObjectInputStream(connection.getInputStream());
} catch (IOException ex) {
Logger.getLogger(ServerMain.class.getName()).log(Level.SEVERE, null, ex);
}
showMessage("\nInput Stream Data Initialized And Stable");
}
}
public static void main(String[] args) throws IOException {
ServerMain sm = new ServerMain();
sm.handleAll();
}
}

CLIENT SIDE BELOW

public class chat extends JFrame implements KeyListener, Runnable {
String voiceOutput = "voice.wav";
private JTextField userText;
final JTextArea chatWindow;
private ObjectOutputStream Objectoutput;
private ObjectInputStream Objectinput;
private String message = " ";
final String serverIP;
private Socket connection;
final int bufSize = 16384;
TargetDataLine line;
Thread thread;
InputStream inputVoice;
Playback playback = new Playback();
AudioInputStream audioInputStream;
JButton playB, captB;
String errStr;
double duration, seconds;
InetAddress ip;
String hostName;
public chat(String host) throws UnknownHostException {
super("Client");
System.out.println("Client Listening ");
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
setSize(500, 500);
ip = InetAddress.getLocalHost();
hostName = ip.getHostName();
serverIP = host;
userText = new JTextField();
setLookAndFeel();
SoftBevelBorder sbb = new SoftBevelBorder(SoftBevelBorder.LOWERED);
userText.setEditable(false);
userText.addActionListener(
new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
sendMessage(e.getActionCommand());
userText.setText(" ");
}
});
/*
Add comps
*/
add(userText, BorderLayout.SOUTH);
chatWindow = new JTextArea();
add(new JScrollPane(chatWindow), BorderLayout.CENTER);
userText.addKeyListener(this);
setVisible(true);
}
/*
Our main method that loops all methods
*/
public void startRunning() throws IOException {
try {
connectToServer();
setupStreams();
whileChatting();
} catch (EOFException eofException) {
showMessage("\n" + hostName + " Terminated Connection");
} finally {
}
}
/*
Sets up connection process
*/
private void connectToServer() throws IOException {
showMessage("\nConnecting...");
connection = new Socket(InetAddress.getByName(serverIP), 1998);
showMessage("\nYou Are Now Connected On Primary Port: " + connection.getInetAddress().getHostName());
userText.setEditable(true);
}
/*
Sets up streams
*/
private void setupStreams() throws IOException {
Objectoutput = new ObjectOutputStream(connection.getOutputStream());
Objectoutput.flush();
Objectinput = new ObjectInputStream(connection.getInputStream());
showMessage("\nInput Stream Data Initialized");
}
/*
While chatting to append messages received/sent
*/
public void whileChatting() throws IOException {
String message = "Now Connected";
sendMessage(message);
ableToType(true);
do {
try {
message = (String) Objectinput.readObject(); ************************* ERROR 2 Here
showMessage("\n" + message);
} catch (ClassNotFoundException classNotFoundException) {
showMessage("ERROR");
}
} while (!message.equals("END"));
}
/*
Closes streams and connection
*/
private void closeAll() {
showMessage("\nclosing..");
ableToType(false);
try {
Objectoutput.close();
Objectinput.close();
connection.close();
} catch (IOException e) {
e.printStackTrace();
}
}
/*
Allows user to send a message to the Server/Client
*/
private void sendMessage(String message) {
try {
Objectoutput.writeObject("\n" + hostName + ":" + message);
Objectoutput.flush();
showMessage("\n" + hostName + ":" + message);
} catch (IOException e) {
chatWindow.append("\nERROR Sending Message!");
}
}
/*
Appends chat messages to the users JTextArea
*/
private void showMessage(final String m) {
SwingUtilities.invokeLater(
new Runnable() {
@Override
public void run() {
chatWindow.append(m);
}
}
);
}
/*
Allows user to Type
*/
public void ableToType(final boolean tof) {
SwingUtilities.invokeLater(
new Runnable() {
@Override
public void run() {
userText.setEditable(tof);
}
}
);
}
/*
Look And Feel of GUI
*/
private void setLookAndFeel() {
try {
UIManager.setLookAndFeel("UIManager.getSystemLookAndFeelClassName");
} catch (ClassNotFoundException | InstantiationException | IllegalAccessException |
UnsupportedLookAndFeelException e) {
}
}
/*
Key Action Events Which trigger the Miscrophone
*/
@Override
public void keyTyped(KeyEvent e) {
}
/*
When Key is pushed it will activate the mic on/off through activating
the Thread below. start() and stop() both methods integrated with the Thread
*/
@Override
public void keyPressed(KeyEvent e) {
Object source = e.getSource();
if (e.getKeyChar() == 'q') {
System.out.println("Started Recording");
start();
} else if (e.getKeyChar() == 'l') {
playback.start();
}
}
@Override
public void keyReleased(KeyEvent e) {
Object source = e.getSource();
if (e.getKeyChar() == 'q') {
System.out.println("Stopped Recording");
stop();
}
}
private void shutDown(String message) {
if ((errStr = message) != null && thread != null) {
thread = null;
playB.setEnabled(true);
captB.setText("Record");
System.err.println(errStr);
}
}
public void start() {
errStr = null;
thread = new Thread(this);
thread.setName("Capture");
thread.start();
}
public void stop() {
thread = null;
}
@Override
@SuppressWarnings("empty-statement")
/*
This will capture the users mic when he/she presses the key 'Q'
Mic will terminate listening after user released the key 'Q'
*/
public void run() {
duration = 0;
audioInputStream = null;
// define the required attributes for our line,
// and make sure a compatible line is supported.
AudioFormat.Encoding encoding = AudioFormat.Encoding.PCM_SIGNED;
float rate = 44100.0f;
int channels = 2;
int frameSize = 4;
int sampleSize = 16;
boolean bigEndian = true;
AudioFormat format = new AudioFormat(encoding, rate, sampleSize, channels, (sampleSize / 8) * channels, rate, bigEndian);
DataLine.Info info = new DataLine.Info(TargetDataLine.class, format);
if (!AudioSystem.isLineSupported(info)) {
shutDown("Line matching " + info + " not supported.");
return;
}
// get and open the target data line for capture.
try {
line = (TargetDataLine) AudioSystem.getLine(info);
line.open(format, line.getBufferSize());
} catch (LineUnavailableException ex) {
shutDown("Unable to open the line: " + ex);
return;
} catch (SecurityException ex) {
shutDown(ex.toString());
//JavaSound.showInfoDialog();
return;
} catch (Exception ex) {
shutDown(ex.toString());
return;
}
// play back the captured audio data
ByteArrayOutputStream out = new ByteArrayOutputStream();
int frameSizeInBytes = format.getFrameSize();
int bufferLengthInFrames = line.getBufferSize() / 8;
int bufferLengthInBytes = bufferLengthInFrames * frameSizeInBytes;
byte[] data = new byte[bufferLengthInBytes];
int numBytesRead;
line.start();
while (thread != null) {
if ((numBytesRead = line.read(data, 0, bufferLengthInBytes)) == -1) {
break;
}
out.write(data, 0, numBytesRead);
}
// we reached the end of the stream.
// stop and close the line.
line.stop();
line.close();
line = null;
// stop and close the output stream
try {
out.flush();
out.close();
} catch (IOException ex) {
ex.printStackTrace();
}
// load bytes into the audio input stream for playback
byte audioBytes[] = out.toByteArray();
ByteArrayInputStream bais = new ByteArrayInputStream(audioBytes);
audioInputStream = new AudioInputStream(bais, format, audioBytes.length / frameSizeInBytes);
long milliseconds = (long) ((audioInputStream.getFrameLength() * 1000) / format.getFrameRate());
duration = milliseconds / 1000.0;
try {
AudioSystem.write(audioInputStream, AudioFileFormat.Type.WAVE, new File(voiceOutput));
// METHOD WHICH ACTIVATES SENDING
// sendSoundFile();
Thread sendVoice = new Thread(new sendVoice(voiceOutput, connection));
sendVoice.start();
} catch (IOException ex) {
Logger.getLogger(chat.class.getName()).log(Level.SEVERE, null, ex);
}
}
class sendVoice implements Runnable {
String VoiceOutput;
Socket connection;
OutputStream output2;
DataOutputStream dos;
InputStream input2;
FileInputStream fis;
public sendVoice(String voiceOutput, Socket connection) {
this.VoiceOutput = voiceOutput;
this.connection = connection;
}
@Override
public void run() {
System.out.println("send voice now");
try {
output2 = connection.getOutputStream();
output2.flush();
} catch (IOException ex) {
Logger.getLogger(chat.class.getName()).log(Level.SEVERE, null, ex);
}
try {
input2 = connection.getInputStream();
} catch (IOException ex) {
Logger.getLogger(chat.class.getName()).log(Level.SEVERE, null, ex);
}
try {
dos = new DataOutputStream(connection.getOutputStream());
} catch (IOException ex1) {
Logger.getLogger(chat.class.getName()).log(Level.SEVERE, null, ex1);
System.out.println("error creating data input stream ");
}
try {
fis = new FileInputStream(voiceOutput);
} catch (FileNotFoundException ex1) {
Logger.getLogger(chat.class.getName()).log(Level.SEVERE, null, ex1);
System.out.println("error in creating file input stream");
}
int count = 0;
byte[] buffer = new byte[4096];
try {
while ((count = fis.read(buffer)) > 0) {
dos.write(buffer, 0, count);
dos.flush();
System.out.println(fis);
}
} catch (IOException ex1) {
Logger.getLogger(chat.class.getName()).log(Level.SEVERE, null, ex1);
System.out.println("error in loop writing");
}
try {
// fis.close();
dos.flush();
dos.close();
} catch (IOException ex1) {
Logger.getLogger(chat.class.getName()).log(Level.SEVERE, null, ex1);
System.out.println("error closing dos");
}
}
}
}

8 years ago

Thanks for the info, I've tried to apply it but I'm still getting a refusal to connect. The method that actually listens to download the file is at the very bottom. I included just the server-side because I have tested the client side sending to another server that just listens for the incoming data and it works flawless its just this server side particularly this code whats giving me problems and from my understanding and knowledge i don't know what I'm doing wrong.

public class SERVERMessenger extends JFrame implements ActionListener {
private ObjectOutputStream output;
private ObjectInputStream input;
private JTextField userText;
private JTextArea chatWindow;
private ServerSocket server;
private ServerSocket server2;
private Socket connection;
private Socket connection2;
private String message = "";
Playback pb = new Playback();
private InetAddress ip;
String hostName;
public SERVERMessenger() throws UnknownHostException {
super("SERVER");
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
setSize(500, 500);
System.out.println("Server Started");
chatWindow = new JTextArea();
/*
Obtain IP & Host Info.
*/
ip = InetAddress.getLocalHost();
hostName = ip.getHostName();
userText = new JTextField();
userText.addActionListener(
new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
sendMessage(e.getActionCommand());
userText.setText("");
}
});
userText.setEditable(false);
/*
Adding comps.
*/
add(userText, BorderLayout.SOUTH);
add(new JScrollPane(chatWindow));
add(chatWindow, BorderLayout.CENTER);
setVisible(true);
}
/*
Permit user to type into JTextArea
*/
private void ableToType(final boolean tof) {
SwingUtilities.invokeLater(
new Runnable() {
@Override
public void run() {
userText.setEditable(tof);
}
}
);
}
/* Append new messages from server to the JTextArea
*/
private void showMessage(final String m) {
SwingUtilities.invokeLater(
new Runnable() {
@Override
public void run() {
chatWindow.append(m);
}
}
);
}
/*
set-up streams for text-to-text communication
*/
private void setUpStreams() throws IOException {
// to oputput message
showMessage(" ");
output = new ObjectOutputStream(connection.getOutputStream());
output.flush();
input = new ObjectInputStream(connection.getInputStream());
showMessage("\nInput Stream Data Initialized");
downloadFile();
}
/*
loop while chatting or while session alive
*/
private void whileChatting() throws IOException {
ableToType(true);
do {
try {
message = (String) input.readObject();
showMessage("\n" + hostName + ":" + message);
} catch (ClassNotFoundException classNotfoundException) {
showMessage("\nI Dont know what object to type");
}
} while (!message.equals("SERVER - END"));
}
/*
Send Message to other user/client
*/
private void sendMessage(String message) {
try {
// server would be username in real workd
output.writeObject(hostName + message);
output.flush();
showMessage(hostName + message);
} catch (IOException ioException) {
ioException.printStackTrace();
chatWindow.append("\nCannot Send That Message");
}
}
/*
Procedure to close chat session
*/
private void closeAll() {
showMessage("\n Closing Connections..");
ableToType(false);
try {
output.close();
input.close();
} catch (IOException ioException) {
ioException.printStackTrace();
}
}
/*
This is the main loop which runs all other methods and originated from main
" messenger.startRunning "
*/
public void startRunning() {
try {
server = new ServerSocket(1246, 100);
while (true) {
try {
waitForConnection();
setUpStreams();
whileChatting();
downloadFile();
} catch (EOFException eofException) {
showMessage("\nEnd Of Connection");
} finally {
}
}
} catch (IOException ioException) {
ioException.printStackTrace();
}
}
/*
Please ignore, buttons will be added in future to chat GUI
*/
@Override
public void actionPerformed(ActionEvent e) {
Object source = e.getSource();
if (source == userText) {
sendMessage(userText.getText());
}
}
/*
This will wait for the connection when window is first opened and will inform
user when the streams have been connected
*/
private void waitForConnection() throws IOException {
showMessage("\nWaiting For Connection To Be Established");
connection = server.accept();
showMessage("\n\nNow Connected To : " + connection.getInetAddress().getHostName());
}
/*
*************************************************************************************************************************** MAIN
*/
public static void main(String[] args) throws IOException {
SERVERMessenger messenger = new SERVERMessenger();
messenger.startRunning();
}
/*
Download file method creates new serverSocket and receives the file sent from client/user
*/
public void downloadFile() throws IOException {
SwingUtilities.invokeLater(
new Runnable() {
@Override
public void run() {
System.out.println("download method called");
try {
// ServerSocket server2 = new ServerSocket (1200,100);
// Socket = connection2
while (true) {
// have tried activated and deactivated
connection = server.accept();
System.out.println("downloading file.........");
OutputStream output = new ObjectOutputStream(connection.getOutputStream());
output.flush();
input = new ObjectInputStream(connection.getInputStream());
DataInputStream dis = new DataInputStream(connection.getInputStream());
FileOutputStream fos = new FileOutputStream(input.toString());
byte[] buffer = new byte[4096];
System.out.println(buffer.length);
int read = 0;
while ((read = dis.read(buffer)) > 0) {
fos.write(buffer, 0, read);
}
fos.close();
dis.close();
}
} catch (IOException ex) {
Logger.getLogger(secondSocket.class.getName()).log(Level.SEVERE, null, ex);
}
/// thread
}
}
);
///// thread
}
}

8 years ago

Thanks again for the insight Paul, I will take your advice and watch some more tutorials... never can learn too much! So in all honesty should I just use the single ServerSocket? instead of using two? I mentioned above I believe that it closes the chat program as soon as the file sends and doesn't actually go through but this is because it should have been threaded so I am leaning towards just using one ServerSocket now and threading.

8 years ago

Ok I am assuming the reason why one is not going through and getting a socket connection refusal is because of this I will make a new thread and report back.

8 years ago

Thanks Paul for a prompt hand. OK, So they are on different ports exp. [1] severSocket 222 [2] serverSocket 222 lets say [1] is for text and [2] is for files etc. BUT they need to be most defiantly in separate threads??

8 years ago