Проект «SnakeProject» Михаила Козлова

⇒ Python ⇐

CISCO

Voice(Asterisk\Cisco)

Microsoft

Powershell

SQL\T-SQL

FreeBSD and Nix

1С

Общая

WEB Разработка

ORACLE SQL \ JAVA

Мото

Стрельба, пневматика, оружие

Python: основы Twisted, TCP сервер и клиент

Познакомимся с основами Twisted в Python

Создадим элементарное приложение TCP клиент-сервер 

server.py

#Стабильно на python 2.7 #Скачать twisted и необходимый zope #twistedmatrix.com/trac/wiki/Downloads #pypi.python.org/pypi/zope.interface/4.1.2 #Twisted - управляемая событиями(event) структура #Событиями управляют функции – event handler #Цикл обработки событий отслеживает события и запускает соответствующие event handler #Работа цикла лежит на объекте reactor из модуля twisted.internet #Модуль socketserver для сетевого программирования from twisted.internet import protocol, reactor class Twist(protocol.Protocol): #Событие connectionMade срабатывает при соединении def connectionMade(self): print 'connection success!' #Событие dataReceived - получение и отправление данных def dataReceived(self, data): print data #transport.write - отправка сообщения self.transport.write('Hello from server!') #Событие connectionLost срабатывает при разрыве соединения с клиентом def connectionLost(self, reason): print 'Connection lost!' #Конфигурация поведения протокола описывается в – классе Factory из twisted.internet.protocol.Factory factory = protocol.Factory() factory.protocol = Twist print 'wait...' reactor.listenTCP(777, factory) reactor.run()

client.py

from twisted.internet import protocol, reactor host = 'localhost' port = 777 class Twist_client(protocol.Protocol): #Отправка сообщения с проверкой def sendData(self): data = raw_input('write message: ') if data: self.transport.write(data) else: #transport.loseConnection() - разрыв соединения self.transport.loseConnection() def connectionMade(self): self.sendData() def dataReceived(self, data): print data self.sendData() class Twist_Factory(protocol.ClientFactory): protocol = Twist_client def clientConnectionFailed(self, connector, reason): print 'connection failed:', reason.getErrorMessage() reactor.stop() def clientConnectionLost(self, connector, reason): print 'connection lost:', reason.getErrorMessage() reactor.stop() factory = Twist_Factory() reactor.connectTCP(host, port, factory) reactor.run()

Комментарии пользователей