Feb 20, 2013 at 5:25pm UTC
I actually tried to pretend it was a c++ problem but i couldnt post the code there, Im trying different kinds of synchronisation but just cant seem to get the chat running freely, i have to hit return for the next line :/
can some explain why calling threads chatthreadsend/receive crashes
1public void begin (){
System.out.println("Welcome to Iffy chat client, Enter target IP" );
theIP = name.nextLine();
try {
try {
connect();
setarp();
runchatprogram();
}catch (IOException ioexception){
ioexception.printStackTrace();
}finally{
System.out.println("\nio-exception...sry\n" );
closethestuff();
}
}catch (IOException ioexcption){
ioexcption.printStackTrace();
}
}
private void runchatprogram() throws IOException{
sendmeassage("iffy unstable chat client managed to send you this start message" );
System.out.println("*----READY----*" );
while (true ){
//this is where i tried chat threads send and recieve
//there were errors
sendmeassage(typemessage());
getmessage();
}
}
private void closethestuff() throws IOException {
System.out.println("Killing everything" );
connectify.close();
soot.close();
sin.close();
}
private synchronized void getmessage () throws IOException{
gets++;
try {
System.out.printf("%s:%s" , gets, sin.readObject());//be surprised if the syntax works
}catch (ClassNotFoundException cnfe){
System.out.println("been sent some odd ass class" );
}
}
private synchronized void sendmeassage(String s)throws IOException {
soot.writeObject(s);
soot.flush();
}
private String typemessage (){
String sentence;
sentence = name.nextLine();
return sentence;
}
private void setarp() throws IOException{
soot = new ObjectOutputStream(connectify.getOutputStream());
soot.flush();
sin = new ObjectInputStream(connectify.getInputStream());
System.out.println("*-----TO------*\n*---STREAMS---*" );
}
private void connect() throws IOException {
connectify = new Socket (InetAddress.getByName(theIP),9000);
System.out.println("*--CONNECTED--*" );
}
class chatthreadrecieve extends Thread{
public void run(){
try {
getmessage();
try {
sleep(1);
} catch (InterruptedException e) {
System.out.println(e);
}
}catch (IOException ioe){
System.out.printf("in threads recieve: %d" ,ioe);
}
}
}
class chatthreadsend extends Thread{
public void run(){
try {
sendmeassage(typemessage());
try {
sleep(1);
} catch (InterruptedException e) {
System.out.println(e);
}
}catch (IOException ioe){
System.out.printf("in threads recieve: %d" , ioe);
}
}
}
}
Last edited on Feb 20, 2013 at 5:26pm UTC
Feb 23, 2013 at 3:52pm UTC
Well, first of all, the compiler should reject that code you posted, as those methods exist outside of a class along with some undeclared variables. Any chance you can post the complete code?
Feb 23, 2013 at 5:37pm UTC
Thanks for looking, I added the swing stuff but its still the same code, with the same-ish problem
1import javax.swing.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Scanner;
import java.util.concurrent.locks.Lock;
public class connecty extends JFrame{
private JTextField inputer,ipmonster;
private JTextArea chatwindow;
private Socket connectify;
public String theIP;
private ObjectOutputStream soot;
private ObjectInputStream sin;
Scanner name;
static Integer gets;
public connecty(){
super ("I R CLIENT" );
inputer = new JTextField();
ipmonster = new JTextField();
ipmonster.setText("Enter target IP here" );
chatwindow = new JTextArea();
inputer.setEditable(true );
inputer.addActionListener(
new ActionListener() {
public void actionPerformed(ActionEvent event) {
try {
sendmeassage(event.getActionCommand());
} catch (IOException e) {
e.printStackTrace();
}
inputer.setText("" );
}
}
);
ipmonster.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent event) {
theIP = event.getActionCommand();
ipmonster.setEditable(false );
begin();
}
});
add(ipmonster, BorderLayout.SOUTH);
add(inputer, BorderLayout.NORTH);
chatwindow = new JTextArea();
add(new JScrollPane(chatwindow));
setSize(300,150);
setVisible(true );
}
public void begin (){
try {
try {
connect();
setarp();
runchatprogram();
}catch (IOException ioexception){
ioexception.printStackTrace();
}
finally{
showmessage("\n***io-exception...sry***" );
closethestuff();
}
}catch (IOException ioexcption){
ioexcption.printStackTrace();
}
}
private void runchatprogram() throws IOException {
abletotype(true ,1);
sendmeassage("--STREAM OBJECT RECEIVED FROM CLIENT--" );
showmessage("\n*----READY----*\n\n" );
while (true ){
getmessage();
}
}
private void closethestuff() throws IOException {
showmessage("\nKilling everything" );
connectify.close();
soot.close();
sin.close();
}
private synchronized void getmessage () throws IOException{
String streamstring;
try {
streamstring = (String)sin.readObject();
showmessage(streamstring);//be surprised if the syntax works
}catch (ClassNotFoundException cnfe){
showmessage("been sent some odd ass class" );
}
}
private synchronized void sendmeassage(String s)throws IOException {
soot.writeObject(s);
soot.flush();
}
private String typemessage (){
String sentence;
sentence = name.nextLine();
return sentence;
}
public void setarp() throws IOException{
soot = new ObjectOutputStream(connectify.getOutputStream());
soot.flush();
sin = new ObjectInputStream(connectify.getInputStream());
showmessage("\n*-----TO------*\n*---STREAMS---*" );
}
public void connect() throws IOException {
connectify = new Socket (InetAddress.getByName(theIP),9000);
showmessage("\n*--CONNECTED--*" );
}
public void showmessage (final String text){ //why final??
SwingUtilities.invokeLater(new Runnable() {
public void run() {
chatwindow.append(text);
}
});
}
class chatthreadrecieve extends Thread{
public void run(){
try {
getmessage();
try {
sleep(1);
} catch (InterruptedException e) {
System.out.println(e);
}
}catch (IOException ioe){
showmessage(ioe.toString());
}
}
}
class chatthreadsend extends Thread{
public void run(){
try {
sendmeassage(typemessage());
try {
sleep(1);
} catch (InterruptedException e) {
showmessage(e.toString());
}
}catch (IOException ioe){
showmessage(ioe.toString());
}
}
}
public void abletotype (final boolean tof,final Integer A){
SwingUtilities.invokeLater(new Runnable() {
public void run() {
if (A == 1)
inputer.setEditable(tof);
if (A == 2)
ipmonster.setEditable(tof);
}
});
}
}
1public class test {
public static void main(String[] args) {
connecty crapclient = new connecty();
crapclient.setSize(200,200);
crapclient.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
crapclent.setVisible(true );
}
}
Last edited on Feb 23, 2013 at 5:38pm UTC
Feb 23, 2013 at 8:30pm UTC
Still a compile-time error:
Last edited on Feb 23, 2013 at 8:37pm UTC
Feb 23, 2013 at 8:55pm UTC
sry, I forgot to mention it only works if a server is listening on that port
