python实现多进程监听声音播放并绘图

废话不多说，直接上代码：

# -*- coding: utf-8 -*-
import time
import pyaudio
import numpy as np
import matplotlib.pyplot as plt
from matplotlib import animation
from multiprocessing import Process,Event,Queue,freeze_support
import waveclass Audio:# 定义构造器audio_queue = Queue()audio_queue1 = Queue()event = Event() #init functiondef __init__(self, CHUNK=2000, FORMAT=pyaudio.paInt16, CHANNELS=1, RATE=10000):self.CHUNK = CHUNKself.FORMAT = FORMATself.CHANNELS = CHANNELSself.RATE = RATEdef listen(self,eve,que):print("listen")p = pyaudio.PyAudio()stream = p.open(format=self.FORMAT,channels=self.CHANNELS,rate=self.RATE,input=True,frames_per_buffer=self.CHUNK)while True:data = stream.read(10240)que.put(data)eve.set()def play(self,eve,que):print("play")p1 = pyaudio.PyAudio()# 打开音频流， output=True表示音频输出stream = p1.open(format=self.FORMAT,channels=self.CHANNELS,rate=self.RATE,output=True,frames_per_buffer=self.CHUNK)while True:if que.empty():#print("等待数据中..........")eve.wait()else:#playdata = que.get()# print("获取的数据data",data)#创建播放器stream.write(data)def display(self,eve,que):print("display")cnt = 0while True:if que.empty():eve.wait()else:#playdata = que.get()#print("获取的数据data",data)data1 = np.fromstring(data,dtype = np.int16)# First set up the figure, the axis, and the plot element we want to animatefig = plt.figure()ax = plt.axes(xlim=(0, len(data1)), ylim=(-50000, 50000))line, = ax.plot([], [], lw=2)# initialization function: plot the background of each framedef init():line.set_data([], [])return line,# animation function.  This is called sequentially# note: i is framenumberdef animate(i):data = que.get()data1 = np.fromstring(data,dtype=np.int16)x = range(len(data1))y = data1line.set_data(x, y)return line,# call the animator.  blit=True means only re-draw the parts that have changed.anim = animation.FuncAnimation(fig, animate, init_func=init,blit=True)                 #anim.save('basic_animation.mp4', fps=30, extra_args=['-vcodec', 'libx264']) if cnt == 0:plt.show()else:continuecnt += 1def fit(self,eve,que):print('fit')while True:if que.empty():eve.wait()else:data = que.get()data1 = np.fromstring(data,dtype = np.int16)max_freq = np.max(data1)#给PHP# print([np.max(data1),np.std(data1)])if np.max(data1) > 8000 :print ("检测到异常信号")print ('当前信号：',max_freq)#存入音频文件clc = int(time.time())file = wave.open(str(clc)+".wav","wb")file.setnchannels(1)file.setframerate(2000)file.setnframes(10000)file.setsampwidth(2)file.writeframes(data1)file.close()                else:print("信号正常")#实时性多进程处理def start(self):#监听audio_process = Process(target=self.listen,args=(self.event,self.audio_queue))audio_process.start()#监听audio_process1 = Process(target=self.listen,args=(self.event,self.audio_queue1))audio_process1.start()#播放play_process = Process(target=self.play,args=(self.event,self.audio_queue))play_process.start()# 绘图display_process = Process(target=self.display,args=(self.event,self.audio_queue1))display_process.start()#Judge and alarmjudge_alarm_process = Process(target=self.fit,args=(self.event,self.audio_queue))judge_alarm_process.start()if __name__ == '__main__':freeze_support()audio_main = Audio()audio_main.start()

代码运行效果：

python实现多进程监听声音播放并绘图相关推荐

类似ngnix的多进程监听用例
2019独角兽企业重金招聘Python工程师标准>>> 多进程监听适合于短连接,且连接间无交集的应用. 前两天简单写了一个,在这里保存一下. #include <sys/typ ...
python全局键盘监听(pynput快捷键)；利用pywin32快速截屏并生成视频
python全局键盘监听(pynput快捷键):利用pywin32快速截屏并生成视频第一次在CSDN写博客,有点小紧张(/ω＼) 以下内容完全个人理解,有错误请指出~ 最近在用python做一个小工 ...
js监听audio播放完毕
js监听audio播放完毕 <!DOCTYPE html> <html> <head><meta charset="UTF-8">& ...
python应用系列教程——python使用scapy监听网络数据包、按TCP/IP协议进行解析
分享一个朋友的人工智能教程.零基础!通俗易懂!风趣幽默!还带黄段子!大家可以看看是否对自己有帮助:点击打开 docker/kubernetes入门视频教程全栈工程师开发手册 (作者:栾鹏) pyth ...
android 监听gif播放,Glide4.0 以后监听Gif播放完成
在Glide3.0的时候,我们可以通过GifDecoder获取每一帧的播放时长然后相加得到gif的播放时长,即: GifDrawable drawable = (GifDrawable) glideD ...
video监听上次播放时间点下次进入后继续播放
最近被人问到如何打开视频播放接着上一次播放的时间点继续播放.由于之前只是采用最基本的视频播放或者利用第三方插件进行播放视频,根本没有考虑这么多:脑子里只有一个大概的想法但是不知道是否能实现所以就没有回 ...
浅谈javascript的事件监听——音乐播放器的控制
javascript的事件 javascript是一门基于事件驱动的语言,当html页面中的元素触发一些动作时,可以执行相关的js代码. 1.常见事件浏览器窗体事件事件名描述 onload 当窗 ...
Python 键盘鼠标监听
异想天开的想记录一下自己每天的键盘键位走向,于是就在网上搜索了一下相关的实现,然后就发现了一个第三方的库pyHook.封装的很好,我们只需要傻瓜式的调用里面的API就可以了. 下面是我在使用pyHoo ...
python脚本如何监听终止进程行为，如何通过脚本名获取pid
文章目录一.前言二.最初的想法:直接获取脚本中的变量值 1.获取运行中py脚本的变量值 2.换一种方式 3.为什么不能获取脚本中的变量 4.下下策,使用使用python的gdb调试工具三.pyt ...
android开发监听媒体播放器,Android开发之媒体播放工具类完整示例
本文实例讲述了Android开发之媒体播放工具类.分享给大家供大家参考,具体如下: package com.maobang.imsdk.util; import android.media.Media ...

python实现多进程监听声音播放并绘图

python实现多进程监听声音播放并绘图相关推荐

最新文章

热门文章