Das deutsche Python-Forum

Code: Alles auswählen

import socket
import time

ip = '192.168.43.1'
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
s.connect((ip, 1511))

try: 
    for x in range(2):
        nachricht = "test"+"\n"

        s.send(nachricht)
       
        #antwort = s.recv(1024)
        print("sende")



finally: 
    s.close()

Code: Alles auswählen

    public CommunicationThread(Socket clientSocket) {
      this.clientSocket = clientSocket;

      try {
        Log.v(TAG, "CommunicationThread, instanziert");
        this.input = new BufferedReader(new InputStreamReader(
            this.clientSocket.getInputStream()));
        
        this.output = new PrintWriter(new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream())), true);
        
                address = clientSocket.getInetAddress();
                
        if(!known_addresses.contains(clientSocket.getInetAddress()))
          known_addresses.add(clientSocket.getInetAddress());

      } catch (IOException e) {
        Log.e(TAG, "ClientSocket inputStreamReader error");
        e.printStackTrace();
      }
    }

    // eine zeile vom imput einlesen, wenn der thread nicht unterbraichen
    // ist
    public void run() {

      while (!Thread.currentThread().isInterrupted()) {

        try {
          Log.v(TAG, "CommunicationThread Running");
          String response = "#,nix,nix,nix,nix,#";
          
          PrintWriter out = new PrintWriter(new BufferedWriter(
                        new OutputStreamWriter(clientSocket.getOutputStream())),
                        true);
                
          String read = input.readLine();
                
          if (read != null){
            list.setNachticht(read, address.getHostAddress());
            out.println(response);
                  out.flush();
                  Log.d(TAG, "Antwort=\""+response+"\"");
            updateConversationHandler.post(new updateUIThread(read, address));
            
          }
          else{
            Log.e(TAG, "null erhalten");
            list.setNullcount();
            counter++;
            if (counter > 5){
              Log.e(TAG, "Restarte conntection");
              list.conntectionreset();
              counter = 0;
              this.clientSocket.close();
              this.clientSocket = serverSocket.accept();
              
            }
          }
          

        } catch (IOException e) {
          Log.e(TAG, "updateConversationHandler error");
          e.printStackTrace();
        }
      }
    }

  }

  // texst in den viewtun
  class updateUIThread implements Runnable {
    private String msg = "";
    private InetAddress address;

    // private TextView text = (TextView) findViewById(R.id.text2);

    public updateUIThread(String str, InetAddress address) {
      this.msg = str;
      this.address = address;

    }

    @Override
    public void run() {
      Log.d(TAG, "Daten erhalten: \""+msg+"\", würden an dieser Stelle zur verarbeitung weitergegeben werden, IP="+address.getHostAddress());
      if (msg != null){
        nullcounter = 0;
      }
      else{
        nullcounter++;
        if (nullcounter >100){
        }
      }

    }
  }
  
  public interface listener{
     public void setNachticht(String nachrichat, String IP);
     public void setNullcount();
     public void conntectionreset();
    
  }

}

Code: Alles auswählen

package com.example.connectiontest;

import android.os.Bundle;
import android.app.Activity;
import android.view.Menu;
import android.widget.TextView;

public class MainActivity extends Activity implements WifiListener.listener {
  
  private  TextView nachricht;
  private  TextView ip;
  private  TextView nullcounter;
  private  TextView connresets;
  private  TextView nachrichtcounter;
  
  private  int stringcounter =0;
  private  int ncounter = 0;
  private  int resetcounter =0;
  
  
  

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        this.nachricht = (TextView) this.findViewById(R.id.laststring);
        this.ip = (TextView) this.findViewById(R.id.ip);
        this.nullcounter = (TextView) this.findViewById(R.id.nullcounter);
        this.connresets = (TextView) this.findViewById(R.id.connresets);
        this.nachrichtcounter = (TextView) this.findViewById(R.id.stringcounter);
        
        
        
        new WifiListener(this);
    }


    @Override
    public boolean onCreateOptionsMenu(Menu menu) {
        // Inflate the menu; this adds items to the action bar if it is present.
        getMenuInflater().inflate(R.menu.main, menu);
        return true;
    }
    
    public void setNachticht(final String nachrichat, final String IP){
      stringcounter ++;
      
      
      
      runOnUiThread(new Runnable() {
           @Override
           public void run() {
             nachrichtcounter.setText(" "+stringcounter+"");
          nachricht.setText(" "+nachrichat);
          ip.setText(" "+IP);
          }
      });
    }
    public void setNullcount(){
      ncounter++;
      
      runOnUiThread(new Runnable() {
         @Override
         public void run() {

          nullcounter.setText(" "+ncounter+"");
        }
    });
      
    }
    public void conntectionreset(){
      resetcounter++;
      
      runOnUiThread(new Runnable() {
         @Override
         public void run() {

          connresets.setText(" "+resetcounter+"");;
        }
    });
    }

    
}