Я работаю над проектом, где мне нравится добавлять функциональность push-to-talk, и у меня есть android как клиенты и java как мой сервер. Что я делаю, это отправлять bytes с AudioRecord на мой сервер и передавать их обратно подключенным клиентам.
В чем моя проблема заключается в смешении data от разных клиентов, которые были отправлены одновременно.
Это то, что я пробовал на своем сервере:
static boolean status = true;
static int port = 1938;
static byte[] mixed_audio;
static byte[][] all_bytes;
static int client_count = 0;
static DatagramSocket socket;
static ArrayList<InetAddress> addresses;
public static void main(String args[]) throws Exception {
DatagramSocket serverSocket = new DatagramSocket(port);
System.out.println("Listening. . .");
addresses = new ArrayList<>();
for(int x = 0; x < args.length; x++){
if(args[x].equals("-p")){
port = Integer.parseInt(args[x+1]);
}
}
byte[] receiveData = new byte[1400];
DatagramPacket receivePacket = new DatagramPacket(receiveData,
receiveData.length);
socket = new DatagramSocket();
while (status == true) {
all_bytes = new byte[1400][1400];
mixed_audio = new byte[1400];
serverSocket.receive(receivePacket);
int a = addresses.indexOf(receivePacket.getAddress());
if(a < 0 ){
addresses.add(receivePacket.getAddress());
}
client_count++;
all_bytes[client_count] = receivePacket.getData();
new Thread(new ReceiveData(receivePacket.getData(), receivePacket.getAddress())).start();
}
}
public static class ReceiveData implements Runnable{
byte[] data;
InetAddress address;
public ReceiveData(byte[] b, InetAddress address){
this.data = b;
this.address = address;
}
@Override
public void run() {
try {
for(int i = 0; i < 1400; i++){
for(int j = 0; j < 1400; j++){
mixed_audio[j] += all_bytes[i][j];
}
}
if(client_count > 1){
int c=0;
for(int x = 0; x < 1400; x++){
mixed_audio[x] = (byte) (mixed_audio[x] / client_count + 1);
}
}else{
mixed_audio = data;
}
client_count--;
for(InetAddress add: addresses){
if(add != address){
DatagramPacket packet;
packet = new DatagramPacket(mixed_audio, mixed_audio.length, add, port);
socket.send(packet);
}
}
} catch (IOException ex) {
//Logger.getLogger(TeraMix.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
Аудиовыход, когда разговаривает только один клиент, ясен, но аудиовыход, когда несколько клиентов начинают говорить одновременно, становится очень неясным.
Я также попробовал свой алгоритм для смешивания звука, используя его в файлах на моем ПК, и он работал хорошо. Мне нужно смешивать data packets, которые одновременно отправляются разными клиентами.
Нужно ли мне обрабатывать клиентов на разных потоках? Я делаю это неправильно? есть ли лучший способ? пожалуйста, помогите мне по этому поводу. Спасибо!
