forked from 10961020/GB28181
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathsip_client.py
333 lines (299 loc) · 13.4 KB
/
sip_client.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
import socket, random
from threading import Thread
import time
import hashlib
from utils import generate_random_string
from sip_common import SIPMessage
import xml.etree.ElementTree as ET
# 定义源IP地址和端口
src_ip = '192.168.1.10'
src_port = 15060
src_user_agent = 'tao yf'
host = '192.168.1.10' # 服务端ip
port = 5060 # 服务端ip端口
device_id = '34020000001320000001'
pwd = '123456'
n = 0
# --------------------------注意必须\r\n结尾，否则m7s解析不出来
def register(s):
global n
str_send = 'REGISTER sip:34020000002000000001@3402000000 SIP/2.0\r\n'
str_send += 'Via: SIP/2.0/UDP {}:{};rport;branch=z9hG4bK{}\r\n'.format(src_ip, src_port, generate_random_string(9))
str_send += 'From: <sip:{}@3402000000>;tag=1{}\r\n'.format(device_id, generate_random_string(9))
str_send += 'To: <sip:{}@3402000000>\r\n'.format(device_id)
str_send += 'Call-ID: 1{}\r\n'.format(generate_random_string(9))
str_send += 'CSeq: 1 REGISTER\r\n'
str_send += 'Contact: <sip:{}@{}:{}>\r\n'.format(device_id, src_ip, src_port)
str_send += 'Max-Forwards: 70\r\n'
str_send += 'User-Agent: IP Camera\r\n'
str_send += 'Expires: 3600\r\n'
str_send += 'Content-Length: 0\r\n\r\n'
print(str_send)
b4 = str_send.encode()
s.sendto(b4, (host, port))
# 注册认证
def register_auth(s, msg):
global n
str_send = 'REGISTER sip:34020000002000000001@3402000000 SIP/2.0\r\n'
str_send += 'Via: SIP/2.0/UDP {}:{};rport;branch=z9hG4bK{}\r\n'.format(src_ip, src_port, generate_random_string(9))
str_send += 'From: <sip:{}@3402000000>;tag=1{}\r\n'.format(device_id, generate_random_string(9))
str_send += 'To: <sip:{}@3402000000>\r\n'.format(device_id)
str_send += 'Call-ID: 1{}\r\n'.format(generate_random_string(9))
str_send += 'CSeq: 1 REGISTER\r\n'
str_send += 'Contact: <sip:{}@{}:{}>\r\n'.format(device_id, src_ip, src_port)
www_authenticate = msg.header_dict['WWW-Authenticate']
auth_list = www_authenticate.split() # 按照空格分割
auth_scheme, auth_str = auth_list
auth_dict = {}
for item in auth_str.split(','):
print(item)
key, value = item.split('=') # 按照等号分割每个元素
value = value.strip("\"") # 去除属性值两端的引号
auth_dict[key] = value
# 验证算法
# HA1=MD5 (username:realm:passwd) #username 和 realm 在字段 “Authorization” 中可以找到，passwd 这个是由客户端和服务器协商得到的，一般情况下 UAC 端存一个 UAS 也知道的密码就行了
# HA2=MD5 (Method:Uri) #Method 一般有 INVITE, ACK, OPTIONS, BYE, CANCEL, REGISTER；Uri 可以在字段 “Authorization” 找到
# response = MD5(HA1:nonce:HA2)
uri = 'sip:{}@3402000000'.format(device_id)
ha1_str = device_id + ':' + auth_dict['realm'] + ':' + pwd
ha1 = hashlib.md5(ha1_str.encode()).hexdigest()
ha2_str = 'REGISTER:' + uri
ha2 = hashlib.md5(ha2_str.encode()).hexdigest()
response_str = ha1 + ':' + auth_dict['nonce'] + ':' + ha2
response = hashlib.md5(response_str.encode()).hexdigest()
www_authenticate += ',username="{}"'.format(device_id)
www_authenticate += ',response="{}"'.format(response)
www_authenticate += ',uri="{}"'.format(uri)
str_send += 'Authorization: {}\r\n'.format(www_authenticate)
str_send += 'Max-Forwards: 70\r\n'
str_send += 'User-Agent: IP Camera\r\n'
str_send += 'Expires: 3600\r\n'
str_send += 'Content-Length: 0\r\n\r\n'
print(str_send)
b4 = str_send.encode()
s.sendto(b4, (host, port))
# 设备状态信息报送 心跳监测
def heartbeat_monitor(s):
global n
while True:
n = n + 1
body = '<?xml version="1.0" encoding="UTF-8"?>\n'
body += '<Notify>\n'
body += '<CmdType>Keepalive</CmdType>\n'
body += '<SN>{}</SN>\n'.format(n)
body += '<DeviceID>{}</DeviceID>\n'.format(device_id)
body += '<Status>OK</Status>\n'
body += '<Info></Info>\n'
body += '</Notify>\n'
str_send = 'MESSAGE sip:34020000002000000001@3402000000 SIP/2.0\r\n'
str_send += 'Via: SIP/2.0/UDP {}:{};rport;branch=z9hG4bK{}\r\n'.format(src_ip, src_port, generate_random_string(9))
str_send += 'From: <sip:{}@3402000000>;tag=1{}\r\n'.format(device_id, generate_random_string(9))
str_send += 'To: <sip:{}@3402000000>\r\n'.format(device_id)
str_send += 'Call-ID: 1{}\r\n'.format(generate_random_string(9))
str_send += 'CSeq: {} MESSAGE\r\n'.format(n)
str_send += 'Contact: <sip:{}@{}:{}>\r\n'.format(device_id, src_ip, src_port)
str_send += 'Content-Type: Application/MANSCDP+xml\r\n'
str_send += 'Max-Forwards: 70\r\n'
str_send += 'User-Agent: IP Camera\r\n'
str_send += 'Content-Length: {}\r\n\r\n'.format(len(body))
str_send += body
print(str_send)
b4 = str_send.encode()
s.sendto(b4, (host, port))
time.sleep(60)
def message(s):
str_send = 'MESSAGE sip:34020000001320000001@3402000000 SIP/2.0\n'
str_send += 'Via: SIP/2.0/UDP 192.168.1.120:5060;branch=z9hG4bK.4QGyFck3JIgGYRKQt1mNQ23NSlc6wdyk\n'.format(src_ip, src_port)
str_send += 'From: <sip:[email protected]:5060>;tag=472039997\n'
str_send += 'To: <sip:34020000001320000001@3402000000>\n'
str_send += 'Call-ID: 1141846895\n'
str_send += 'User-Agent: Monibuca\n'
str_send += 'CSeq: 1 MESSAGE\n'.format(src_ip, src_port)
str_send += 'Max-Forwards: 70\n'
str_send += 'Contact: <sip:[email protected]:5060>;tag=472039997\n'
str_send += 'Content-Type: Application/MANSCDP+xml\n'
str_send += 'Content-Length: 118\n'
str_send += 'Expires: 3600\n\n'
body = '<?xml version="1.0"?><Query>\n'
body += '<CmdType>Catalog</CmdType>\n'
body += '<SN>1</SN>\n'
body += '<DeviceID>{}</DeviceID>\n'.format(device_id)
body += '</Query>\n\n'
str_send += body
print(str_send)
b4 = str_send.encode()
s.sendto(b4, (host, port))
def message_ack(s, msg):
str_send = 'SIP/2.0 200 OK\r\n'
str_send += 'Via: {}\r\n'.format(msg.header_dict['Via'])
str_send += 'From: <sip:{}@3402000000>;tag={}\r\n'.format(device_id, generate_random_string(9))
str_send += 'To: {}\r\n'.format(msg.header_dict['To'])
str_send += 'Call-ID: {}\r\n'.format(msg.header_dict['Call-ID'])
str_send += 'CSeq: {}\r\n'.format(msg.header_dict['CSeq'])
str_send += 'User-Agent: IP Camera\r\n'
str_send += 'Content-Length: 0\r\n\r\n'
print(str_send)
b4 = str_send.encode()
s.sendto(b4, (host, port))
# 发送设备目录信息
def send_device_catalog(s, msg):
body = '<?xml version="1.0" encoding="GB2312"?>\n'
body += '<Response>\n'
body += '<CmdType>Catalog</CmdType>\n'
body += '<SN>1</SN>\n'
body += '<DeviceID>{}</DeviceID>\n'.format(device_id)
body += '<SumNum>1</SumNum>\n'
body += '<DeviceList Num="1">\n'
body += '<Item>\n'
body += '<DeviceID>340001</DeviceID>\n'
body += '<Name>IPdome</Name>\n'
body += '<Manufacturer>Hikvision</Manufacturer>\n'
body += '<Model>IP Camera</Model>\n'
body += '<Owner>Owner</Owner>\n'
body += '<CivilCode>3402000000</CivilCode>\n'
body += '<Address>Address</Address>\n'
body += '<Parental>0</Parental>\n'
body += '<ParentID>34020000002000000001</ParentID>\n'
body += '<SafetyWay>0</SafetyWay>\n'
body += '<RegisterWay>1</RegisterWay>\n'
body += '<Secrecy>0</Secrecy>\n'
body += '<Status>ON</Status>\n'
body += '</Item>\n'
body += '</DeviceList>\n'
body += '</Response>\n'
str_send = 'MESSAGE sip:34020000002000000001@3402000000 SIP/2.0\r\n'
str_send += 'Via: SIP/2.0/UDP {}:{};rport;branch=z9hG4bK{}\r\n'.format(src_ip, src_port, generate_random_string(9))
str_send += 'From: <sip:{}@3402000000>;tag=1{}\r\n'.format(device_id, generate_random_string(9))
str_send += 'To: <sip:{}@3402000000>\r\n'.format(device_id)
str_send += 'Call-ID: 1{}\r\n'.format(generate_random_string(9))
str_send += 'CSeq: 2 MESSAGE\r\n'
str_send += 'Contact: <sip:{}@{}:{}>\r\n'.format(device_id, src_ip, src_port)
str_send += 'Content-Type: Application/MANSCDP+xml\r\n'
str_send += 'Max-Forwards: 70\r\n'
str_send += 'User-Agent: IP Camera\r\n'
str_send += 'Content-Length: {}\r\n\r\n'.format(len(body))
str_send += body
print(str_send)
b4 = str_send.encode()
s.sendto(b4, (host, port))
# 发送设备信息
def send_device_info(s, msg):
body = '<?xml version="1.0" encoding="GB2312"?>\n'
body += '<Response>\n'
body += '<CmdType>DeviceInfo</CmdType>\n'
body += '<SN>1</SN>\n'
body += '<DeviceID>34020000001320000001</DeviceID>\n'
body += '<Result>OK</Result>\n'
body += '<DeviceName>IP DOME</DeviceName>\n'
body += '<Manufacturer>Hikvision</Manufacturer>\n'
body += '<Model>DS-2DC4423IW-DE</Model>\n'
body += '<Firmware>V5.7.1</Firmware>\n'
body += '<Channel>1</Channel>\n'
body += '</Response>\n'
str_send = 'MESSAGE sip:34020000002000000001@3402000000 SIP/2.0\r\n'
str_send += 'Via: SIP/2.0/UDP {}:{};rport;branch=z9hG4bK{}\r\n'.format(src_ip, src_port, generate_random_string(9))
str_send += 'From: <sip:{}@3402000000>;tag=1{}\r\n'.format(device_id, generate_random_string(9))
str_send += 'To: <sip:{}@3402000000>\r\n'.format(device_id)
str_send += 'Call-ID: 1{}\r\n'.format(generate_random_string(9))
str_send += 'CSeq: 2 MESSAGE\r\n'
str_send += 'Contact: <sip:{}@{}:{}>\r\n'.format(device_id, src_ip, src_port)
str_send += 'Content-Type: Application/MANSCDP+xml\r\n'
str_send += 'Max-Forwards: 70\r\n'
str_send += 'User-Agent: IP Camera\r\n'
str_send += 'Content-Length: {}\r\n\r\n'.format(len(body))
str_send += body
print(str_send)
b4 = str_send.encode()
s.sendto(b4, (host, port))
def handle_message_xml(s, msg):
xml_str = msg.body
root = ET.fromstring(xml_str)
cmd_type = root.find('CmdType').text.strip()
device_no = root.find('DeviceID').text.strip()
if cmd_type == 'Catalog':
# 回复确认消息
message_ack(s, msg)
# 发送设备目录
send_device_catalog(s, msg)
elif cmd_type == 'DeviceInfo':
# 回复确认消息
message_ack(s, msg)
# 发送设备信息
send_device_info(s, msg)
else:
print("不支持的CmdType：{}".format(cmd_type))
def ack_subscribe(s, msg, cmd_type, device_no):
body = '<?xml version="1.0" encoding="GB2312"?>\n'
body += '<Response>\n'
body += '<CmdType>{}</CmdType>\n'.format(cmd_type)
body += '<SN>1</SN>\n'
body += '<DeviceID>{}</DeviceID>\n'.format(device_no)
body += '<Result>OK</Result>\n'
body += '</Response>\n'
str_send = 'SIP/2.0 200 OK\r\n'
str_send += 'Via: {}\r\n'.format(msg.header_dict['Via'])
str_send += 'From: <sip:{}@3402000000>;tag={}\r\n'.format(device_id, generate_random_string(9))
str_send += 'To: {}\r\n'.format(msg.header_dict['To'])
str_send += 'Call-ID: {}\r\n'.format(msg.header_dict['Call-ID'])
str_send += 'CSeq: {}\r\n'.format(msg.header_dict['CSeq'])
str_send += 'Expires: {}\r\n'.format(msg.header_dict['Expires'])
str_send += 'User-Agent: {}\r\n'.format(src_user_agent)
str_send += 'Content-Length: {}\r\n\r\n'.format(len(body))
str_send += body
print(str_send)
b4 = str_send.encode()
s.sendto(b4, (host, port))
# 处理消息订阅
def handle_subscribe_xml(s, msg):
xml_str = msg.body
root = ET.fromstring(xml_str)
cmd_type = root.find('CmdType').text.strip()
device_no = root.find('DeviceID').text.strip()
# 目录订阅
if cmd_type == 'Catalog':
# 回复确认消息
ack_subscribe(s, msg, cmd_type, device_no)
# TODO 目录通知消息
def monitor_messages(s):
while True:
data, addr = sock.recvfrom(1500) # 接收数据
msg = data.decode() # 数据从byte格式转出为str
print('recv----------')
print(msg)
sip_msg = SIPMessage(msg)
device_no = sip_msg.get_device_id_by_to()
csep = sip_msg.header_dict['CSeq']
num, msg_type = csep.split(' ')
if msg_type == 'REGISTER':
if sip_msg.first_line.find('401 Unauthorized') != -1:
register_auth(s, sip_msg)
elif sip_msg.first_line.find('200 OK') != -1:
# 创建线程
heartbeat_thread = Thread(target=heartbeat_monitor, args=(sock,), name="heartbeat_thread")
# 启动线程
heartbeat_thread.start()
print('注册成功')
else:
print('不支持的内容：{}'.format(sip_msg.first_line))
elif msg_type == 'MESSAGE':
if sip_msg.first_line.find('200 OK') != -1:
print('MESSAGE 200 OK')
continue
if sip_msg.header_dict['Content-Type'] == 'Application/MANSCDP+xml':
handle_message_xml(s, sip_msg)
elif msg_type == 'SUBSCRIBE':
if sip_msg.header_dict['Content-Type'] == 'Application/MANSCDP+xml':
handle_subscribe_xml(s, sip_msg)
else:
print("不支持的类型：{}".format(msg_type))
if __name__ == '__main__':
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) # 创建socket对象
# 绑定套接字到源IP地址和端口
sock.bind((src_ip, src_port))
# 创建线程
thread01 = Thread(target=monitor_messages, args=(sock,), name="线程1")
# 启动线程
thread01.start()
time.sleep(1)
register(sock)
time.sleep(2000)