热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

socket的使用

基于TCP协议的sockettcp是基于链接的,必须先启动服务端,然后再启动客户端去链接服务端server端importsocketsksocket.

基于TCP协议的socket

tcp是基于链接的,必须先启动服务端,然后再启动客户端去链接服务端

server端

import socket
sk
= socket.socket()
sk.bind((
'127.0.0.1',8898)) #把地址绑定到套接字
sk.listen() #监听链接
conn,addr = sk.accept() #接受客户端链接
ret = conn.recv(1024) #接收客户端信息
print(ret) #打印客户端信息
conn.send(b'hi') #向客户端发送信息
conn.close() #关闭客户端套接字
sk.close() #关闭服务器套接字(可选)

client端

import socket
sk
= socket.socket() # 创建客户套接字
sk.connect(('127.0.0.1',8898)) # 尝试连接服务器
sk.send(b'hello!')
ret
= sk.recv(1024) # 对话(发送/接收)
print(ret)
sk.close()
# 关闭客户套接字

 

问题:有的同学在重启服务端时可能会遇到

解决方法:

#加入一条socket配置,重用ip和端口
import socket
from socket import SOL_SOCKET,SO_REUSEADDR
sk
= socket.socket()
sk.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) #就是它,在bind前加
sk.bind(('127.0.0.1',8898)) #把地址绑定到套接字
sk.listen() #监听链接
conn,addr = sk.accept() #接受客户端链接
ret = conn.recv(1024) #接收客户端信息
print(ret) #打印客户端信息
conn.send(b'hi') #向客户端发送信息
conn.close() #关闭客户端套接字
sk.close() #关闭服务器套接字(可选)

  

基于UDP协议的socket

udp是无链接的,启动服务之后可以直接接受消息,不需要提前建立链接

简单使用

server端

import socket
udp_sk
= socket.socket(type=socket.SOCK_DGRAM) #创建一个服务器的套接字
udp_sk.bind(('127.0.0.1',9000)) #绑定服务器套接字
msg,addr = udp_sk.recvfrom(1024)
print(msg)
udp_sk.sendto(b
'hi',addr) # 对话(接收与发送)
udp_sk.close() # 关闭服务器套接字

client端

import socket
ip_port
=('127.0.0.1',9000)
udp_sk
=socket.socket(type=socket.SOCK_DGRAM)
udp_sk.sendto(b
'hello',ip_port)
back_msg,addr
=udp_sk.recvfrom(1024)
print(back_msg.decode('utf-8'),addr)

 带颜色和名字的聊天程序

#格式:设置颜色开始 :\033[显示方式;前景色;背景色m
#说明:
前景色 背景色 颜色
---------------------------------------
30 40 黑色
31 41 红色
32 42 绿色
33 43 黃色
34 44 蓝色
35 45 紫红色
36 46 青蓝色
37 47 白色
显示方式 意义
-------------------------
0 终端默认设置
1 高亮显示
4 使用下划线
5 闪烁
7 反白显示
8 不可见#例子:
\033[1;31;40m
\
033[0m

# udp协议的服务器端# import socket
#
dic = {'alex':'\033[0;31;42m','taibai':'\033[1;32;41m'}
#
sk = socket.socket(type=socket.SOCK_DGRAM) #udp协议
#
sk.bind(('127.0.0.1',9000))
#
while True:
#
msg,addr = sk.recvfrom(1024)
#
name,msg1 = msg.decode('utf-8').split(':')
#
color = dic.get(name.strip(),'')
#
print('%s%s\033[0m' % (color,msg.decode('utf-8')))
#
content = input('content:')
#
sk.sendto(content.encode('utf-8'),addr)
#
#
sk.close()

# udp协议的客户端# import socket
#
#
sk = socket.socket(type=socket.SOCK_DGRAM)
#
name = input('name:')
#
while True:
#
content = input('content:')
#
sk.sendto(('%s:%s' % (name,content)).encode('utf-8'),('127.0.0.1',9000))
#
msg,addr = sk.recvfrom(1024)
#
print(msg.decode('utf-8'))
#
#
sk.close()

时间服务器

# udp协议的服务器端# import time
#
import socket
#
#
sk = socket.socket(type=socket.SOCK_DGRAM)
#
sk.bind(('127.0.0.1',9000))
#
while True:
#
msg,addr = sk.recvfrom(1024)
#
sk.sendto(time.strftime(msg.decode('utf-8')).encode('utf-8'),addr)
#
#
sk.close()

# udp协议的客户端# import time
#
import socket
#
#
sk = socket.socket(type=socket.SOCK_DGRAM)
#
while True:
#
sk.sendto('%Y-%m-%d %H-%M-%S'.encode('utf-8'),('127.0.0.1',9000))
#
msg,addr = sk.recvfrom(1024)
#
print(msg.decode('utf-8'))
#
time.sleep(2)
#
#
sk.close()

升级版udp协议

# mysocket.py文件

from socket import *

class Mysocket(socket):
def __init__(self,coding='utf-8'):
self.coding = coding
super().__init__(type=SOCK_DGRAM)
def my_recv(self,num):
msg,addr = self.recvfrom(num)
return msg.decode(self.coding),addr
def my_send(self,msg,addr):
return self.sendto(msg.encode(self.coding),addr)

# server.py文件from mysocket import Mysocketsk = Mysocket()
sk.bind((
'127.0.0.1',9000))
while True:msg,addr = sk.my_recv(1024)print(msg,addr)content = input('content:')sk.my_send(content,addr)sk.close()

# client.py文件from mysocket import Mysocketsk = Mysocket()
while True:content = input('content:')sk.my_send(content,('127.0.0.1',9000))msg,addr = sk.my_recv(1024)print(msg,addr)sk.close()

socket参数的详解

socket.socket(family=AF_INET,type=SOCK_STREAM,proto=0,fileno=None)

创建socket对象的参数说明:

family地址系列应为AF_INET(默认值),AF_INET6,AF_UNIX,AF_CAN或AF_RDS。
(AF_UNIX 域实际上是使用本地 socket 文件来通信)
type套接字类型应为SOCK_STREAM(默认值),SOCK_DGRAM,SOCK_RAW或其他SOCK_常量之一。
SOCK_STREAM 是基于TCP的,有保障的(即能保证数据正确传送到对方)面向连接的SOCKET,多用于资料传送。 
SOCK_DGRAM 是基于UDP的,无保障的面向消息的socket,多用于在网络上发广播信息。
proto协议号通常为零,可以省略,或者在地址族为AF_CAN的情况下,协议应为CAN_RAW或CAN_BCM之一。
fileno如果指定了fileno,则其他参数将被忽略,导致带有指定文件描述符的套接字返回。
与socket.fromfd()不同,fileno将返回相同的套接字,而不是重复的。
这可能有助于使用socket.close()关闭一个独立的插座。

 

转:https://www.cnblogs.com/molieren/p/9334456.html



推荐阅读
author-avatar
naniwang99_537_742
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有