Beiträge von Brausebernd

package com.example.client;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.annotation.SuppressLint;
import android.app.Activity;
import android.widget.TextView;


@SuppressLint("HandlerLeak")
public class Client extends Activity 
{
	
	static private TextView serverdaten;
	String s ="0";
	Socket socket;
	BufferedReader input;
	Thread verbindung;


	static Handler myHandler = new Handler()
	{
		@Override
		public void handleMessage(Message msg) {
			serverdaten.setText("Antwort vom Server: "+msg.obj);  
		}
	};
	
	public void onCreate(Bundle savedInstanceState) 
	{
		super.onCreate(savedInstanceState);
			setContentView(R.layout.activity_client);
			serverdaten = (TextView) findViewById(R.id.serverdaten);
			this.verbindung = new Thread(new Verbindung());
			this.verbindung.start();
	}
	
	class Verbindung extends Thread
	{
		Thread empfang;
		
		public void run()
		{
			try 
			{
				socket = new Socket("192.168.2.3", 4444);						  
				input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			} 
			catch (IOException e) 
			{
				serverdaten.setText(e.toString());
			}
			this.empfang = new Thread(new Empfang());
			this.empfang.start();
		}
	}
	
	class Empfang extends Thread
	{
		public void run()
		{
			try 
			{
				s=input.readLine();																		
				Message msg = myHandler.obtainMessage();	   	
				msg.obj = s;	   	
				myHandler.sendMessage(msg);
				input.close();
			} 
			catch (IOException e) 
			{
				serverdaten.setText(e.toString());
			}
		}
	}
	
}

package server;


import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Timer;
import java.util.TimerTask;


public class Server
{
	static int n;
	static String x;
	static BufferedWriter output;
	static  int[] array = { 1, 2, 3, 4, 5};
	static Timer timer = new Timer();


	ServerSocket socket = new ServerSocket(4444);


	Server() throws IOException 
	{
		System.out.println("Server gestartet!");
		Socket client = socket.accept();
		output = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
	}


	public static void main(String[] args) 
	{


		timer.scheduleAtFixedRate(new TimerTask()
		{
			private int next = 0;
			@Override
			public void run()
			{
				n = (array[next % array.length]);
				next++;
				x = String.valueOf(n);
			}
		}, 0, 2000);
		
		try 
		{
			new Server();
			System.out.println(x);
			output.write(x);
			output.newLine();
			output.flush();
		} 
		catch (IOException e) {
			System.out.println(e);
		}
	}
}

package com.example.client;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.widget.TextView;


public class Client extends Activity 
{
	private TextView serverdaten;
	String s ="0";


	final Handler myHandler = new Handler(){
		@Override
		public void handleMessage(Message msg) {
			serverdaten.setText("Antwort vom Server: "+msg.obj);  
		}
	};
	
	public void onCreate(Bundle savedInstanceState) 
	{
		super.onCreate(savedInstanceState);
			setContentView(R.layout.activity_client);
			serverdaten = (TextView) findViewById(R.id.serverdaten);


	}
	
	class Verbindung implements Runnable
	{
		private boolean running;
		private Socket socket;
		private BufferedReader input;
		
		public Verbindung() 
		{
	
				socket = new Socket("192.168.2.3", 4444);
				input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		
		}


		public void run()
		{
			while(running)
			{
				try 
				{
					s = input.readLine();																		
					Message msg = myHandler.obtainMessage();	   	
					msg.obj = s;	   	
					myHandler.sendMessage(msg);
				} 
				catch (IOException e) 
				{
					serverdaten.setText(e.toString());
				}
			}
		}
		
		public void start()
		{
			new Thread(this).start();
			running = true;
		}


		public void stop()
		{
			running = false;
			close();
		}
		
		private void close()
		{
			if(input != null)
			{
				try
				{
					input.close();
				}
				catch (IOException e)
				{
					// fehlerbehandlung
				}
			}
			
			if(socket != null)
			{
				try
				{
					socket.close();
				}
				catch (IOException e)
				{
					// fehlerbehandlung
				}
			}
		}
	}
}

package com.example.tcpclient;


import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import android.annotation.SuppressLint;
import android.app.Activity;
import android.content.Intent;
import android.os.AsyncTask;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;


@SuppressLint("HandlerLeak")
public class TCPClient extends Activity 
{
	private TextView NachrichtText;
	String s ="0";
	
	/** Called when the activity is first created. */
	
	final Handler myHandler = new Handler()
	{
		@Override
		public void handleMessage(Message msg) 
		{
			NachrichtText.setText("Antwort vom Server: "+msg.obj);  
		}
	};
	
	public void onCreate(Bundle savedInstanceState) 
	{
		super.onCreate(savedInstanceState);
			setContentView(R.layout.main);
			NachrichtText = (TextView) findViewById(R.id.nachricht_text);
			class Verbindung implements Runnable
			{
				public void run()
				{
					try 
					{
						Socket server = new Socket("192.168.2.3", 4444);						  
						BufferedReader input = new BufferedReader(new InputStreamReader(server.getInputStream()));
						s=input.readLine();																		
						Message msg = myHandler.obtainMessage();	   	
						msg.obj = s;	   	
						myHandler.sendMessage(msg);
					} 
					catch (IOException e) 
					{
						NachrichtText.setText(e.toString());
					}
				}
			}
			Thread t = new Thread( new Verbindung() );
			t.start();
	}		
}

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Timer;
import java.util.TimerTask;


public class TCPServer
{
	static ServerSocket server;
	static Socket client;
	static BufferedWriter output;
	static int n;


	public static void main(String[] args)throws IOException  
	{


			server = new ServerSocket(4444);
			System.out.println("Server gestartet!");
			client = server.accept();
			output = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
			
			final int[] array = { 1, 2, 3, 4, 5};
			Timer timer = new Timer();
			timer.scheduleAtFixedRate(new TimerTask()
			{
				private int next = 0;
				
				@Override
				public void run()
				{
					n = (array[next % array.length]);
					next++;


					try {
						
						String x = String.valueOf(n);
						output.write(x);
						System.out.println(x);
						output.newLine();
						output.flush();
						
					} catch (IOException e) 
					{
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
					
				}
			}, 0, 2000);	
	}
}

package com.example.tcpclient;


import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import android.annotation.SuppressLint;
import android.app.Activity;
import android.content.Intent;
import android.os.AsyncTask;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;


public class TCPClient extends Activity 
{
	private TextView IPAdresseText;
	private Button VerbindenButton;
	private EditText IPAdresseEingabefeld;
	private TextView NachrichtText;
	private Button SendenButton;
	private EditText NachrichtEingabefeld;
	String s ="0";
	String ip ="0";
	/** Called when the activity is first created. */
	
	final Handler myHandler = new Handler()
	{
		@Override
		public void handleMessage(Message msg) 
		{
			NachrichtText.setText("Antwort vom Server: "+msg.obj);  
		}
	};
		
	public void onCreate(Bundle savedInstanceState) 
	{
		super.onCreate(savedInstanceState);
			setContentView(R.layout.main);
			IPAdresseText = (TextView) findViewById(R.id.ipadresse_text);
			VerbindenButton = (Button) findViewById(R.id.verbinden_button);
			IPAdresseEingabefeld = (EditText) findViewById(R.id.ipadresse_eingabefeld);
			NachrichtText = (TextView) findViewById(R.id.nachricht_text);
			SendenButton = (Button) findViewById(R.id.senden_button);
			NachrichtEingabefeld = (EditText) findViewById(R.id.nachricht_eingabefeld);
			
			VerbindenButton.setOnClickListener(new View.OnClickListener()
	    	{
	        		public void onClick(View v) 
	        		{
	        		    	ip = IPAdresseEingabefeld.getText().toString();
	        		    	IPAdresseText.setText("verbunden");
	        		}
	    	});
			
			SendenButton.setOnClickListener(new View.OnClickListener() 
			{
				@SuppressLint("HandlerLeak")
				public void onClick(View view) 
				{
					NachrichtText.setText("Button wurde gedrückt!");
					if (NachrichtEingabefeld.getText().toString().length() != 0) 
					{
						class Verbindung implements Runnable
						{
							public void run()
							{
								String nachricht = NachrichtEingabefeld.getText().toString();
								
								try 
								{
									Socket server = new Socket(ip, 4444);						  
									BufferedReader input = new BufferedReader(new InputStreamReader(server.getInputStream()));
									BufferedWriter output = new BufferedWriter(new OutputStreamWriter(server.getOutputStream()));									 
									output.write(nachricht);
									output.newLine();
									output.flush();
									s=input.readLine();																		
									Message msg = myHandler.obtainMessage();	   	
									msg.obj = s;	   	
									myHandler.sendMessage(msg);
				
																
								} 
								catch (IOException e) 
								{
									NachrichtText.setText(e.toString());
								}
							}
						}
						Thread t = new Thread( new Verbindung() );
						t.start();
					} 
					else 
					{
						NachrichtText.setText("Bitte etwas eingeben!");
					}
				}
			});
	}
}

<ScrollView xmlns:android="http://schemas.android.com/apk/res/android"
	android:layout_width="fill_parent" 
	android:layout_height="fill_parent"
	android:scrollbars="vertical">


	<HorizontalScrollView xmlns:android="http://schemas.android.com/apk/res/android"
    	android:layout_width="fill_parent" 
    	android:layout_height="fill_parent">




	    	<RelativeLayout
	    	android:layout_width="2000dp"
	    	android:layout_height="2000dp"
	    	
	    	
	    	android:background="@drawable/grundriss" >
	
	    	<Button
	        	android:id="@+id/aufruf_eingabeseite"
	        	android:layout_width="wrap_content"
	        	android:layout_height="wrap_content"
	        	android:layout_alignParentRight="true"
	        	android:layout_alignParentTop="true"
	        	android:text="Zurück zur Eingabe" />
	
	    	<RadioButton
	        	android:id="@+id/sensor"
	        	android:layout_width="wrap_content"
	        	android:layout_height="wrap_content"
	        	android:layout_alignParentLeft="true"
	        	android:layout_below="@+id/aufruf_eingabeseite"
	        	android:layout_marginLeft="30dp"
	        	android:layout_marginTop="308dp"
	        	android:text="Sensor1" />
	
	    	<TextView
	        	android:id="@+id/serverdaten"
	        	android:layout_width="wrap_content"
	        	android:layout_height="wrap_content"
	        	android:layout_alignParentLeft="true"
	        	android:layout_below="@+id/aufruf_eingabeseite"
	        	android:layout_marginTop="48dp"
	        	android:text="TextView" />
	
	
	
		</RelativeLayout>


	</HorizontalScrollView>


</ScrollView>

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Timer;
import java.util.TimerTask;


public class TCPServer
{
	static int n;


	ServerSocket server = new ServerSocket(4444);


	TCPServer() throws IOException 
	{
		System.out.println("Server gestartet!");
		System.out.println(n);


		Socket client = server.accept();
		BufferedReader input = new BufferedReader(new InputStreamReader(client.getInputStream()));
		BufferedWriter output = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
		
		String nachricht = input.readLine();
		System.out.println("Nachricht vom Client: " + nachricht);
		output.write(n);
		output.newLine();
		output.flush();
	}


	public static void main(String[] args) 
	{
		final int[] array = { 1, 2, 3, 4, 5};
		Timer timer = new Timer();
		timer.scheduleAtFixedRate(new TimerTask()
		{
			private int next = 0;
			@Override
			public void run()
			{
				n = (array[next % array.length]);
				next++;
			}
		}, 0, 2000);
		
		try 
		{
			new TCPServer();
		} 
		catch (IOException e) {
			System.out.println(e);
		}
	}


}

<manifest xmlns:android="http://schemas.android.com/apk/res/android"
	package="com.example.client"
	android:versionCode="1"
	android:versionName="1.0" >


	<uses-sdk
    	android:minSdkVersion="8"
    	android:targetSdkVersion="15" />
	<uses-permission android:name="android.permission.INTERNET"/>


	<application
    	android:icon="@drawable/ic_launcher"
    	android:label="@string/app_name"
    	android:theme="@style/AppTheme" >
    	<activity
        	android:name=".MainActivity"
        	android:label="@string/title_activity_main" >
        	<intent-filter>
            	<action android:name="android.intent.action.MAIN" />


            	<category android:name="android.intent.category.LAUNCHER" />
        	</intent-filter>
    	</activity>
	</application>


</manifest>

package com.example.client;


import android.app.Activity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.EditText;


import java.net.*;
import java.io.*;




public class MainActivity extends Activity {
	/** Called when the activity is first created. */
	String ip = "0";
	ChatClient client = null;
	@Override
	public void onCreate(Bundle savedInstanceState) {
    	super.onCreate(savedInstanceState);
    	setContentView(R.layout.activity_main);
    	
     	
     	
     	
	}
	
	public void onSendClick(View v)
	{
    	EditText nachricht = (EditText) this.findViewById(R.id.EditText01);
    	String msg = nachricht.getText().toString();
    	client.send(msg);
    	
	}
	
	public void onConnectClick(View v)
	{
    	EditText AdressEditText = (EditText) this.findViewById(R.id.EditText02);
    	ip = AdressEditText.getText().toString();
    	int port = 1337;
    	client =  new ChatClient(ip, port);
	}
}








class ChatClient
{  
   private Socket socket          	= null;
   private DataInputStream  console   = null;
   private DataOutputStream streamOut = null;


   public ChatClient(String serverName, int serverPort)
   {  System.out.println("Establishing connection. Please wait ...");
  	try
  	{  socket = new Socket(serverName, serverPort);
     	Log.d("DEBUG","Connected: " + socket);
     	start();
  	}
  	catch(UnknownHostException uhe)
  	{  Log.d("DEBUG","Host unknown: " + uhe.getMessage());
  	}
  	catch(IOException ioe)
  	{  Log.d("DEBUG","Unexpected exception: " + ioe.getMessage());
  	}
  	
 	
   }
   
   public void start() throws IOException
   {  
  	console   = new DataInputStream(System.in);
  	streamOut = new DataOutputStream(socket.getOutputStream());
   }
   
   public void stop()
   {  try
  	{  if (console   != null)  console.close();
     	if (streamOut != null)  streamOut.close();
     	if (socket	!= null)  socket.close();
  	}
  	catch(IOException ioe)
  	{  System.out.println("Error closing ...");
  	}
   }
   
   public void send(String msg)
   {
   	try
   	{  
      	streamOut.writeUTF(msg);
      	streamOut.flush();
   	}
   	catch(IOException ioe)
   	{  
       	Log.d("DEBUG","Sending error: " + ioe.getMessage());
   	}
   }
  
}

import java.net.*;
import java.io.*;


public class Server implements Runnable
{  private Socket   	socket = null;
   private ServerSocket server = null;
   private Thread   	thread = null;
   private DataInputStream  streamIn  =  null;


   public Server()
   {  
  	int port = 4444; 
  	try
  	{  System.out.println("Binding to port " + port + ", please wait  ...");
     	server = new ServerSocket(port);  
     	System.out.println("Server started: " + server);
     	start();
  	}
  	catch(IOException ioe)
  	{  
      	System.out.println(ioe); 
  	}
   }
   public void run()
   {  while (thread != null)
  	{   try
     	{  System.out.println("Waiting for a client ..."); 
        	socket = server.accept();
        	System.out.println("Client accepted: " + socket);
        	open();
        	boolean done = false;
        	while (!done)
        	{  try
           	{  String line = streamIn.readUTF();
              	System.out.println(line);
              	done = line.equals(".bye");
           	}
           	catch(IOException ioe)
           	{  done = true;  }
        	}
        	close();
     	}
     	catch(IOException ie)
     	{  System.out.println("Acceptance Error: " + ie);  }
  	}
   }
   public void start()
   {  if (thread == null)
  	{  thread = new Thread(this); 
     	thread.start();
  	}
   }
   @SuppressWarnings("deprecation")
   public void stop()
   {  if (thread != null)
  	{  thread.stop(); 
     	thread = null;
  	}
   }
   public void open() throws IOException
   {  streamIn = new DataInputStream(new 
                    	BufferedInputStream(socket.getInputStream()));
   }
   public void close() throws IOException
   {  if (socket != null)	socket.close();
  	if (streamIn != null)  streamIn.close();
   }
   public static void main(String args[])
   {  
   	Server server =  new Server();
   }
}

<manifest xmlns:android="http://schemas.android.com/apk/res/android"
	package="com.example.client"
	android:versionCode="1"
	android:versionName="1.0" >


	<uses-sdk
    	android:minSdkVersion="8"
    	android:targetSdkVersion="15" />
	<uses-permission android:name=""/>


	<application
    	android:icon="@drawable/ic_launcher"
    	android:label="@string/app_name"
    	android:theme="@style/AppTheme" >
    	<activity
        	android:name=".MainActivity"
        	android:label="@string/title_activity_main" >
        	<intent-filter>
            	<action android:name="android.intent.action.MAIN" />


            	<category android:name="android.intent.category.LAUNCHER" />
        	</intent-filter>
    	</activity>
	</application>


</manifest>