标签：socket 在线音乐 数据库 db link recv 客户端

模拟一个在线音乐播放程序（数据库 + socket（TCP协议））

1，使用C/S架构来进行设计，分别写出客户端和服务器程序，

2，客户端链接服务器之后，服务器向用户提示可以选择的歌曲列表，用户选择后开始播放（音频文件存放在本地即可）。不需要实现暂停、切歌等功能

3，需要把常用功能封装为一个工具模块（.py文件），并对其进行调用

1. 创建数据库数据

 1 1. 创建数据库
 2    create database song;
 3    use song;
 4 
 5 2. 创建表
 6    create table t_list(
 7    id int primary key auto_increment,
 8    name varchar(32) not null,
 9    link varchar(2000) not null
10    );

11 3. 数据库插入数据(后面的link字段中 需要放音乐文件在电脑上的本地路径，以供后面播放文件时调用)
12    Insert into t_list(name,link) values('stay_with_me', '/Users/.../StayWithMe.mp3');
13    insert into t_list(name,link) values('Virtual Riot Lift Me_Up', '/Users/.../VirtualRiotLiftMe_Up.mp3');
14    insert into t_list(name,link) values('阿刁', '/Users/.../阿刁.mp3');

2.在.py文件中 将数据库的功能做一下简单封装（db_helper.py）

 1 import pymysql
 2 
 3 
 4 def get_conn():　　　　　　# 将数据库的连接做单独封装
 5     con = pymysql.connect(
 6         host='localhost',
 7         user='root',
 8         password='123123',
 9         db='song',　　　　# db的值等于想要查询的数据库名
10         charset='utf8'
11     )
12     return con
13 
14 
15 def search_s(sql):　　　　# 将查询数据库功能做封装
16     con = get_conn()
17     cursor = con.cursor()
18     cursor.execute(sql)
19     data = cursor.fetchall()
20     return data
21 
22 
23 def instert_s(sql):　　　　# 将插入数据到数据库做封装（本次用不到）
24     con = get_conn()
25     cursor = con.cursor()
26     cursor.execute(sql)
27     con.commit()

3. 编写socket服务器

　　主要功能：跟socket客户端通信，给客户端发送数据库中歌曲列表，用户选择的歌曲序号，服务器从数据库中查询到对应歌曲的本地路径到客户端

 1 from socket import *
 2 from db_helper import *　　　　# db_helper是上面数据库功能封装后的.py文件名
 3 import struct
 4 
 5 
 6 server = socket()　　　　　　　　# socket服务器的常规设置
 7 server.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
 8 server.bind(("", 8081))
 9 server.listen(5)
10 
11 print('服务器启动...')
12 
13 while True:
14     lst = []
15     total = ''
16 
17     newsocket, addr = server.accept()
18     recv_data = newsocket.recv(1024)
19 
20     db_data = search_s('select id,name from t_list')　　# 调用db_helper中的查询方法，从数据库中获取到id和歌名
21 
22     for i in db_data:
23         new = str(i[0])+' '+i[1]
24         lst.append(new)
25 
26     total = '&'.join(lst)
27     name_len = len(total)
28 
29     length = struct.pack('i', name_len)　　　　# 将字符串长度通过struct打包后发送到客户端（解决socket服务器沾包问题）
30     newsocket.send(length)
31     newsocket.send(total.encode())
32 
33     select1 = newsocket.recv(1024)
34     s = select1.decode()
35     db_data1 = search_s(f'select link from t_list where id={s}')　　# 获取到用户选择的歌曲id之后，去数据库中查询对应歌曲的link
36 
37     newsocket.send(db_data1[0][0].encode())　　　　# 将link发送到客户端

4. socket客户端

　　主要功能：跟socket服务器通信，接收服务器发送的数据并打印，发送用户选择的歌曲序号至服务器，获取到link后开始播放本地音乐文件

 1 import socket
 2 import subprocess
 3 import struct
 4 
 5 lst = []
 6 
 7 client = socket.socket()　　　　# socket客户端常规设置
 8 client.connect(('127.0.0.1', 8081))
 9 
10 while True:
11     client.send('song_list'.encode())
12     recv_num = client.recv(4)
13     total_size = struct.unpack('i', recv_num)[0]
14 
15     recv_size = 0
16     recv_msg = b''
17 
18     while recv_size < total_size:
19 
20         every_recv = client.recv(1024)
21         recv_msg += every_recv
22         recv_size += len(every_recv)
23 
24     data1 = recv_msg.decode()
25 
26     lst1 = data1.split('&')
27 
28     for i in lst1:
29         print(i)　　　　　　# 打印从服务器接收到的歌曲列表
30     break
31 
32 try:
33     choose = input('请输入ID：').strip()
34 
35     client.send(choose.encode())
36     filename = client.recv(1024).decode()　　　　# 获取服务器发送的歌曲本地路径
37 
38     print('歌曲播放中...')
39     return_code = subprocess.call(["afplay", filename])
40 
41     client.close()
42 
43 except Exception:
44     pass

标签：socket,在线音乐,数据库,db,link,recv,客户端
来源： https://www.cnblogs.com/wuaihua/p/12200041.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。