हाल ही में, मैं fluorinefx के कोड भी देखता हूं। यह अजीब बात है कि प्रकाशन कोड में लागू क्यों नहीं किया गया है, हालांकि डॉक्टर ने इसका उल्लेख किया था।
दरअसल, अपने PlayEngine.cs में, एक समान कार्यान्वयन पुल एंडपश() है जो एक एफएलवी फ़ाइल से डेटा खींच सकता है और इसे रिमोट पर धक्का दे सकता है।
तो, मैं netstream वर्ग में कुछ इसी तरह की कोशिश की कोड, यह लगभग काम कर सकते हैं और rtmplite सर्वर से धारा धक्का कर सकते हैं और rtmplite में परीक्षण वेब द्वारा खेला जा सकता है।
public void Publish(params object[] arguments)
{
ValidationUtils.ArgumentConditionTrue(arguments != null && arguments.Length > 0, "arguments", "At least the name of a file must be specified");
ValidationUtils.ArgumentNotNullOrEmptyOrWhitespace(arguments[0] as string, "name");
_name = arguments[0] as string;
INetConnectionClient client = _connection.NetConnectionClient;
RtmpConnection connection = _connection.NetConnectionClient.Connection as RtmpConnection;
IPendingServiceCallback callback = new CreateStreamCallBack(this, connection, new PublishCallBack(this,_connection, _name));
client.Call("createStream", callback);
}
public void AttachFile(string filepath)
{
FileProvider fileProvider = new FileProvider(this.Scope, new System.IO.FileInfo(filepath));
_pullPushPipe.Subscribe(fileProvider, null);
PullAndPush();
}
public void PullAndPush()
{
while(true)
{
var msg = _pullPushPipe.PullMessage();
if (msg == null)
{
// No more packets to send
Stop();
break;
}
else
{
if (msg is RtmpMessage)
{
RtmpMessage rtmpMessage = (RtmpMessage)msg;
IRtmpEvent body = rtmpMessage.body;
// SendMessage(rtmpMessage);
// Adjust timestamp when playing lists
// EnsurePullAndPushRunning();
_pullPushPipe.PushMessage(msg);
}
}
}
}
class PublishCallBack : IPendingServiceCallback
{
NetConnection _connection;
NetStream _stream;
string _name;
string _mode;
public PublishCallBack(NetStream stream, NetConnection connection, string name, string mode = "live")
{
_connection = connection;
_name = name;
_mode = mode;
_stream = stream;
}
public void ResultReceived(IPendingServiceCall call)
{
if ("createStream".Equals(call.ServiceMethodName))
{
RtmpConnection connection = _connection.NetConnectionClient.Connection as RtmpConnection;
object[] args = new object[2] {_name, _mode};
PendingCall pendingCall = new PendingCall("publish", args);
pendingCall.RegisterCallback(new PublishResultCallBack());
connection.Invoke(pendingCall, (byte)connection.GetChannelForStreamId(_stream.StreamId));
}
}
}
अब, फ्लोरिनफैक्स में प्रकाशित करना संभव है? 'Ns.publish (publishName.text," रिकॉर्ड ");' – ketan