Das deutsche Python-Forum

Code: Alles auswählen

import socket

def traceroute():
		#dest = raw_input('Bitte geben sie eine Adresse ein: ')
		#if dest == None:
		#		dest = 'google.de'
		# Variablen
		dest = 'google.de'
		destination = socket.gethostbyname(dest)
		port = 33434
		#verwendete Protokolle
		icmp = socket.getprotobyname('icmp')
		udp = socket.getprotobyname('udp')
		#Timetolive + maximale spruenge
		ttl = 1
		max_hops = 30
		while ttl < max_hops:
				# Socket zum empfangen
				receive_socket = socket.socket(socket.AF_INET, socket.SOCK_RAW, icmp)
				# Socket fuer senden
				send_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, udp)
				# ttl wird geaendert
				send_socket.setsockopt(socket.SOL_IP, socket.IP_TTL, ttl)
				#bind socket + send
				receive_socket.bind(("",port))
				send_socket.sendto("",(destination, port))
				# erstelle leere Variablen
				current_addr = None
				current_name = None
				try:
						print "try 1 " + destination
						#ersten 512 bits des Empfangenen Objekts
						daten,current_addr = receive_socket.recvfrom(512)
						# ip adresse aus dem array
						current_addr = current_addr[0]
						try:
								print "try 2"
								current_name = socket.gethostbyaddr(current_addr)
						#fehler abfangen
						except socket.error:
								current_name = current_addr
				#fehler abfangen
				except socket.error:
						print "Fehler Socket"
						break
						
				finally:
						print "finally"
						#sockets schliessen
						send_socket.close()
						receive_socket.close()

				if current_addr is not None:
						current_host = "%s (%s)" %(current_name, current_addr)
				else:
						curr_host = "*"

				print "%d\t%s" %(ttl, current_host)

				#abbrechen falls noetig
				if current_addr == destination:
						break
				# ttl erhoehen
				ttl += 1
				
print traceroute()

Code: Alles auswählen

daten,current_addr = receive_socket.recvfrom(512)

Code: Alles auswählen

#!/usr/bin/env python
# coding: utf8
import socket
from contextlib import closing


def traceroute(destination, max_hops=30):
    destination_ip = socket.gethostbyname(destination)
    port = 33434
    icmp = socket.getprotobyname('icmp')
    udp = socket.getprotobyname('udp')
    with closing(
        socket.socket(socket.AF_INET, socket.SOCK_DGRAM, udp)
    ) as send_socket:
        with (
            closing(socket.socket(socket.AF_INET, socket.SOCK_RAW, icmp))
        ) as receive_socket:
            receive_socket.bind(('', port))
            receive_socket.settimeout(3)
            for ttl in xrange(1, max_hops + 1):
                send_socket.setsockopt(socket.SOL_IP, socket.IP_TTL, ttl)
                send_socket.sendto('', (destination_ip, port))
                try:
                    _data, (current_ip, _port) = receive_socket.recvfrom(512)
                except socket.timeout:
                    current_ip = None

                if current_ip:
                    try:
                        current_name, _, _ = socket.gethostbyaddr(current_ip)
                    except socket.error:
                        current_name = current_ip
                    current_host = '{0} ({1})'.format(current_name, current_ip)
                else:
                    current_host = '*'

                print '{0:d}\t{1}'.format(ttl, current_host)

                if current_ip == destination_ip:
                    break
            else:
                print 'Ziel nicht in {0} hops erreicht.'.format(max_hops)


def main():
    try:
        traceroute('python-forum.de')
    except socket.error as error:
        print error


if __name__ == '__main__':
    main()

Code: Alles auswählen

#!/usr/bin/python


import socket
import time
from contextlib import closing

# variables
ttl = 1
BUF_MAX = 4096
DEST_PORT = 53
WAIT_TIME = 0.0005
MAX_HOPS = 20
ORIGIN_PORT = 2112 #starts with 1024
port_counter = 1
QUERY_DNS = '\xde\xa3\x01\x00\x00\x01\x00\x00\x00\x00\x00\x00\x08facebook\x03com\x00\x00\x01\x00\x01'

def sendquery(dest_ip):
	for ttl in xrange(1,MAX_HOPS+1):
		with (
        	closing(socket.socket(socket.AF_INET, socket.SOCK_DGRAM))
        ) as send_socket:
        	#send_socket.setblocking(0)
			#send_socket.bind(('', ORIGIN_PORT))
			send_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
			try:
				send_socket.sendto(QUERY_DNS, (dest_ip, DEST_PORT))
			except socket.error as e:
				print "error in sendto"
			time.sleep(2)
		with (
			closing(socket.socket(socket.AF_INET, socket.SOCK_RAW))
		) as read_socket:
			read_socket.bind(('', ORIGIN_PORT))
			read_socket.settimeout(60)
			try:
				data, (current_ip, _port) = read_socket.recvfrom(BUF_MAX)
				print str(ttl) + " received data from : " + current_ip
				try:
					current_name, _, _ = socket.gethostbyaddr(current_ip)
					print "name = " + current_name
				except socket.error:
					print "error current_name "
			except socket.timeout:
				print "Socket timeout"
                current_ip = None
        if current_ip == dest_ip:
        	break


def main():
	try:
		sendquery("8.8.8.8")
	except socket.error:
		print "main error"

if __name__ == "__main__":
	main()

Code: Alles auswählen

# receive all packages
s.ioctl(socket.SIO_RCVALL, socket.RCVALL_ON)